@Test public void testWriteWithoutEdges() throws Exception { String tmpPath = temporaryFolder.getRoot().getPath(); String tlfFileImport = getFilePath("/data/tlf/io_test_string_without_edges.tlf"); String tlfFileExport = tmpPath + "/data/tlf/io_test_output"; DataSource dataSource = new TLFDataSource(tlfFileImport, getConfig()); DataSink dataSink = new TLFDataSink(tlfFileExport, getConfig()); dataSink.write(dataSource.getGraphCollection(), true); DataSource dataSource2 = new TLFDataSource(tlfFileExport, getConfig()); getExecutionEnvironment().execute(); collectAndAssertTrue(dataSource.getGraphCollection() .equalsByGraphElementData(dataSource2.getGraphCollection())); }
@Override public void write(LogicalGraph logicalGraph) throws IOException { write(logicalGraph, false); }
TLFDataSink extends TLFBase implements DataSink { @Override public void write(LogicalGraph logicalGraph) throws IOException { write(logicalGraph, false); } }
TLFDataSink extends TLFBase implements DataSink { @Override public void write(LogicalGraph logicalGraph) throws IOException { write(logicalGraph, false); } TLFDataSink(String tlfPath, GradoopFlinkConfig config);  TLFDataSink(String tlfPath, String tlfVertexDictionaryPath,
    String tlfEdgeDictionaryPath, GradoopFlinkConfig config); }
TLFDataSink extends TLFBase implements DataSink { @Override public void write(LogicalGraph logicalGraph) throws IOException { write(logicalGraph, false); } TLFDataSink(String tlfPath, GradoopFlinkConfig config);  TLFDataSink(String tlfPath, String tlfVertexDictionaryPath,
    String tlfEdgeDictionaryPath, GradoopFlinkConfig config); @Override void write(LogicalGraph logicalGraph); @Override void write(GraphCollection graphCollection); @Override void write(LogicalGraph logicalGraph, boolean overwrite); @Override void write(GraphCollection graphCollection, boolean overWrite); }
TLFDataSink extends TLFBase implements DataSink { @Override public void write(LogicalGraph logicalGraph) throws IOException { write(logicalGraph, false); } TLFDataSink(String tlfPath, GradoopFlinkConfig config);  TLFDataSink(String tlfPath, String tlfVertexDictionaryPath,
    String tlfEdgeDictionaryPath, GradoopFlinkConfig config); @Override void write(LogicalGraph logicalGraph); @Override void write(GraphCollection graphCollection); @Override void write(LogicalGraph logicalGraph, boolean overwrite); @Override void write(GraphCollection graphCollection, boolean overWrite);  }