@Test public void testWriteWithoutEdgesWithDictionaries() 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"; String tlfVertexDictionaryFileExport = tmpPath + "/data/tlf/dictionaries/io_test_output_vertex_dictionary"; DataSource dataSource = new TLFDataSource(tlfFileImport, getConfig()); GraphCollection input = dataSource.getGraphCollection(); DataSink dataSink = new TLFDataSink(tlfFileExport, tlfVertexDictionaryFileExport, "", getConfig()); dataSink.write(input, true); DataSource dataSource2 = new TLFDataSource(tlfFileExport, tlfVertexDictionaryFileExport, "", getConfig()); GraphCollection output = dataSource2.getGraphCollection(); getExecutionEnvironment().execute(); collectAndAssertTrue(input.equalsByGraphElementData(output)); }
@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);  }