@Test public void testReadExtendedProperties() throws Exception { LogicalGraph expected = getExtendedLogicalGraph(); String csvPath = getFilePath("/data/csv/input_extended_properties"); DataSource dataSource = new CSVDataSource(csvPath, getConfig()); LogicalGraph sourceLogicalGraph = dataSource.getLogicalGraph(); collectAndAssertTrue(sourceLogicalGraph.equalsByElementData(expected)); dataSource.getLogicalGraph().getEdges().collect() .forEach(this::checkProperties); dataSource.getLogicalGraph().getVertices().collect() .forEach(this::checkProperties); }
@Override public LogicalGraph getLogicalGraph() { GraphCollection collection = getGraphCollection(); return collection.getGraphFactory() .fromDataSets( collection.getGraphHeads().first(1), collection.getVertices(), collection.getEdges()); }
CSVDataSource extends CSVBase implements DataSource { @Override public LogicalGraph getLogicalGraph() { GraphCollection collection = getGraphCollection(); return collection.getGraphFactory() .fromDataSets( collection.getGraphHeads().first(1), collection.getVertices(), collection.getEdges()); } }
CSVDataSource extends CSVBase implements DataSource { @Override public LogicalGraph getLogicalGraph() { GraphCollection collection = getGraphCollection(); return collection.getGraphFactory() .fromDataSets( collection.getGraphHeads().first(1), collection.getVertices(), collection.getEdges()); } CSVDataSource(String csvPath, GradoopFlinkConfig config); }
CSVDataSource extends CSVBase implements DataSource { @Override public LogicalGraph getLogicalGraph() { GraphCollection collection = getGraphCollection(); return collection.getGraphFactory() .fromDataSets( collection.getGraphHeads().first(1), collection.getVertices(), collection.getEdges()); } CSVDataSource(String csvPath, GradoopFlinkConfig config); @Override LogicalGraph getLogicalGraph(); @Override GraphCollection getGraphCollection(); }
CSVDataSource extends CSVBase implements DataSource { @Override public LogicalGraph getLogicalGraph() { GraphCollection collection = getGraphCollection(); return collection.getGraphFactory() .fromDataSets( collection.getGraphHeads().first(1), collection.getVertices(), collection.getEdges()); } CSVDataSource(String csvPath, GradoopFlinkConfig config); @Override LogicalGraph getLogicalGraph(); @Override GraphCollection getGraphCollection();  }