@Test public void testReadSingleGraph() throws Exception { String csvPath = getFilePath("/data/csv/input_indexed"); String gdlPath = getFilePath("/data/csv/expected/expected.gdl"); DataSource dataSource = new IndexedCSVDataSource(csvPath, getConfig()); LogicalGraph input = dataSource.getLogicalGraph(); LogicalGraph expected = getLoaderFromFile(gdlPath).getLogicalGraphByVariable("expected"); collectAndAssertTrue(input.equalsByData(expected)); }
@Override public LogicalGraph getLogicalGraph() throws IOException { GraphCollection collection = getGraphCollection(); return collection.getGraphFactory() .fromDataSets(collection.getGraphHeads().first(1), collection.getVertices(), collection.getEdges()); }
IndexedCSVDataSource extends CSVBase implements DataSource { @Override public LogicalGraph getLogicalGraph() throws IOException { GraphCollection collection = getGraphCollection(); return collection.getGraphFactory() .fromDataSets(collection.getGraphHeads().first(1), collection.getVertices(), collection.getEdges()); } }
IndexedCSVDataSource extends CSVBase implements DataSource { @Override public LogicalGraph getLogicalGraph() throws IOException { GraphCollection collection = getGraphCollection(); return collection.getGraphFactory() .fromDataSets(collection.getGraphHeads().first(1), collection.getVertices(), collection.getEdges()); } IndexedCSVDataSource(String csvPath, GradoopFlinkConfig config);  IndexedCSVDataSource(String csvPath, GradoopFlinkConfig conf, Configuration hdfsConf); }
IndexedCSVDataSource extends CSVBase implements DataSource { @Override public LogicalGraph getLogicalGraph() throws IOException { GraphCollection collection = getGraphCollection(); return collection.getGraphFactory() .fromDataSets(collection.getGraphHeads().first(1), collection.getVertices(), collection.getEdges()); } IndexedCSVDataSource(String csvPath, GradoopFlinkConfig config);  IndexedCSVDataSource(String csvPath, GradoopFlinkConfig conf, Configuration hdfsConf); @Override LogicalGraph getLogicalGraph(); @Override GraphCollection getGraphCollection(); }
IndexedCSVDataSource extends CSVBase implements DataSource { @Override public LogicalGraph getLogicalGraph() throws IOException { GraphCollection collection = getGraphCollection(); return collection.getGraphFactory() .fromDataSets(collection.getGraphHeads().first(1), collection.getVertices(), collection.getEdges()); } IndexedCSVDataSource(String csvPath, GradoopFlinkConfig config);  IndexedCSVDataSource(String csvPath, GradoopFlinkConfig conf, Configuration hdfsConf); @Override LogicalGraph getLogicalGraph(); @Override GraphCollection getGraphCollection();  }