@Test public void testWriteExtendedProperties() throws Exception { String tmpPath = temporaryFolder.getRoot().getPath(); LogicalGraph logicalGraph = getExtendedLogicalGraph(); DataSink csvDataSink = new CSVDataSink(tmpPath, getConfig()); csvDataSink.write(logicalGraph, true); getExecutionEnvironment().execute(); DataSource csvDataSource = new CSVDataSource(tmpPath, getConfig()); LogicalGraph sourceLogicalGraph = csvDataSource.getLogicalGraph(); collectAndAssertTrue(logicalGraph.equalsByElementData(sourceLogicalGraph)); sourceLogicalGraph.getEdges().collect().forEach(this::checkProperties); sourceLogicalGraph.getVertices().collect().forEach(this::checkProperties); }
@Override public void write(LogicalGraph logicalGraph) throws IOException { write(logicalGraph, false); }
CSVDataSink extends CSVBase implements DataSink { @Override public void write(LogicalGraph logicalGraph) throws IOException { write(logicalGraph, false); } }
CSVDataSink extends CSVBase implements DataSink { @Override public void write(LogicalGraph logicalGraph) throws IOException { write(logicalGraph, false); } CSVDataSink(String csvPath, GradoopFlinkConfig config);  CSVDataSink(String csvPath, String metaDataPath, GradoopFlinkConfig config); }
CSVDataSink extends CSVBase implements DataSink { @Override public void write(LogicalGraph logicalGraph) throws IOException { write(logicalGraph, false); } CSVDataSink(String csvPath, GradoopFlinkConfig config);  CSVDataSink(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); }
CSVDataSink extends CSVBase implements DataSink { @Override public void write(LogicalGraph logicalGraph) throws IOException { write(logicalGraph, false); } CSVDataSink(String csvPath, GradoopFlinkConfig config);  CSVDataSink(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);  }