@Test public void testRead() throws Exception { String edgeListFile = getFilePath("/data/edgelist/vertexlabeled/input"); String gdlFile = getFilePath("/data/edgelist/vertexlabeled/expected.gdl"); DataSource dataSource = new VertexLabeledEdgeListDataSource(edgeListFile, " ", "lan", getConfig()); LogicalGraph result = dataSource.getLogicalGraph(); FlinkAsciiGraphLoader loader = getLoaderFromFile(gdlFile); LogicalGraph expected = loader.getLogicalGraphByVariable("expected"); collectAndAssertTrue(expected.equalsByElementData(result)); }
@Override public LogicalGraph getLogicalGraph() throws IOException { return getGraphCollection().reduce(new ReduceCombination<>()); }
VertexLabeledEdgeListDataSource extends EdgeListDataSource { @Override public LogicalGraph getLogicalGraph() throws IOException { return getGraphCollection().reduce(new ReduceCombination<>()); } }
VertexLabeledEdgeListDataSource extends EdgeListDataSource { @Override public LogicalGraph getLogicalGraph() throws IOException { return getGraphCollection().reduce(new ReduceCombination<>()); } VertexLabeledEdgeListDataSource(String edgeListPath, String tokenSeparator,
    String propertyKey,
    GradoopFlinkConfig config); }
VertexLabeledEdgeListDataSource extends EdgeListDataSource { @Override public LogicalGraph getLogicalGraph() throws IOException { return getGraphCollection().reduce(new ReduceCombination<>()); } VertexLabeledEdgeListDataSource(String edgeListPath, String tokenSeparator,
    String propertyKey,
    GradoopFlinkConfig config); @Override LogicalGraph getLogicalGraph(); @Override GraphCollection getGraphCollection(); }
VertexLabeledEdgeListDataSource extends EdgeListDataSource { @Override public LogicalGraph getLogicalGraph() throws IOException { return getGraphCollection().reduce(new ReduceCombination<>()); } VertexLabeledEdgeListDataSource(String edgeListPath, String tokenSeparator,
    String propertyKey,
    GradoopFlinkConfig config); @Override LogicalGraph getLogicalGraph(); @Override GraphCollection getGraphCollection();  }