@Test public void testWrite() throws Exception { FlinkAsciiGraphLoader testLoader = getSocialNetworkLoader(); GraphCollection expectedCollection = testLoader.getGraphCollectionByVariables("g0", "g1", "g2", "g3"); String path = temporaryFolder.getRoot().getPath() + "/graph.gdl"; DataSink gdlsink = new GDLDataSink(path); gdlsink.write(expectedCollection, true); getExecutionEnvironment().execute(); FlinkAsciiGraphLoader sinkLoader = getLoaderFromFile(path); GraphCollection sinkCollection = sinkLoader .getGraphCollectionByVariables("g0", "g1", "g2", "g3"); collectAndAssertTrue(sinkCollection.equalsByGraphElementData(expectedCollection)); }
@Override public void write(LogicalGraph logicalGraph) throws IOException { write(logicalGraph, false); }
GDLDataSink implements DataSink { @Override public void write(LogicalGraph logicalGraph) throws IOException { write(logicalGraph, false); } }
GDLDataSink implements DataSink { @Override public void write(LogicalGraph logicalGraph) throws IOException { write(logicalGraph, false); } GDLDataSink(String path); }
GDLDataSink implements DataSink { @Override public void write(LogicalGraph logicalGraph) throws IOException { write(logicalGraph, false); } GDLDataSink(String path); @Override void write(LogicalGraph logicalGraph); @Override void write(GraphCollection graphCollection); @Override void write(LogicalGraph logicalGraph, boolean overwrite); @Override void write(GraphCollection graphCollection, boolean overwrite); }
GDLDataSink implements DataSink { @Override public void write(LogicalGraph logicalGraph) throws IOException { write(logicalGraph, false); } GDLDataSink(String path); @Override void write(LogicalGraph logicalGraph); @Override void write(GraphCollection graphCollection); @Override void write(LogicalGraph logicalGraph, boolean overwrite); @Override void write(GraphCollection graphCollection, boolean overwrite);  }