@Test public void testWriteWithExistingMetaData() throws Exception { String tmpPath = temporaryFolder.getRoot().getPath(); String csvPath = getFilePath("/data/csv/input_indexed_graph_collection"); String gdlPath = getFilePath("/data/csv/expected/expected_graph_collection.gdl"); GraphCollection input = getLoaderFromFile(gdlPath).getGraphCollectionByVariables("expected1", "expected2"); DataSink csvDataSink = new IndexedCSVDataSink(tmpPath, csvPath + "/metadata.csv", getConfig()); csvDataSink.write(input, true); getExecutionEnvironment().execute(); DataSource csvDataSource = new IndexedCSVDataSource(tmpPath, getConfig()); GraphCollection output = csvDataSource.getGraphCollection(); collectAndAssertTrue(input.equalsByGraphElementData(output)); }
@Override public void write(LogicalGraph logicalGraph) throws IOException { write(logicalGraph, false); }
IndexedCSVDataSink extends CSVBase implements DataSink { @Override public void write(LogicalGraph logicalGraph) throws IOException { write(logicalGraph, false); } }
IndexedCSVDataSink extends CSVBase implements DataSink { @Override public void write(LogicalGraph logicalGraph) throws IOException { write(logicalGraph, false); } IndexedCSVDataSink(String csvPath, GradoopFlinkConfig config);  IndexedCSVDataSink(String csvPath, String metaDataPath, GradoopFlinkConfig config); }
IndexedCSVDataSink extends CSVBase implements DataSink { @Override public void write(LogicalGraph logicalGraph) throws IOException { write(logicalGraph, false); } IndexedCSVDataSink(String csvPath, GradoopFlinkConfig config);  IndexedCSVDataSink(String csvPath, String metaDataPath, 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); }
IndexedCSVDataSink extends CSVBase implements DataSink { @Override public void write(LogicalGraph logicalGraph) throws IOException { write(logicalGraph, false); } IndexedCSVDataSink(String csvPath, GradoopFlinkConfig config);  IndexedCSVDataSink(String csvPath, String metaDataPath, 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);  }