@Test public void testGetLogicalGraphByVariable() throws Exception { FlinkAsciiGraphLoader loader = getSocialNetworkLoader(); String graphVariable = "g1"; GradoopId graphId = loader.getGraphHeadByVariable(graphVariable).getId(); LogicalGraph graphFromLoader = loader.getLogicalGraphByVariable(graphVariable); LogicalGraph graphFromCollection = loader.getGraphCollection().getGraph(graphId); collectAndAssertTrue(graphFromLoader.equalsByElementData(graphFromCollection)); }
public LogicalGraph getLogicalGraphByVariable(String variable) { EPGMGraphHead graphHead = getGraphHeadByVariable(variable); Collection<EPGMVertex> vertices = getVerticesByGraphVariables(variable); Collection<EPGMEdge> edges = getEdgesByGraphVariables(variable); return config.getLogicalGraphFactory().fromCollections(graphHead, vertices, edges); }
FlinkAsciiGraphLoader { public LogicalGraph getLogicalGraphByVariable(String variable) { EPGMGraphHead graphHead = getGraphHeadByVariable(variable); Collection<EPGMVertex> vertices = getVerticesByGraphVariables(variable); Collection<EPGMEdge> edges = getEdgesByGraphVariables(variable); return config.getLogicalGraphFactory().fromCollections(graphHead, vertices, edges); } }
FlinkAsciiGraphLoader { public LogicalGraph getLogicalGraphByVariable(String variable) { EPGMGraphHead graphHead = getGraphHeadByVariable(variable); Collection<EPGMVertex> vertices = getVerticesByGraphVariables(variable); Collection<EPGMEdge> edges = getEdgesByGraphVariables(variable); return config.getLogicalGraphFactory().fromCollections(graphHead, vertices, edges); } FlinkAsciiGraphLoader(GradoopFlinkConfig config); }
FlinkAsciiGraphLoader { public LogicalGraph getLogicalGraphByVariable(String variable) { EPGMGraphHead graphHead = getGraphHeadByVariable(variable); Collection<EPGMVertex> vertices = getVerticesByGraphVariables(variable); Collection<EPGMEdge> edges = getEdgesByGraphVariables(variable); return config.getLogicalGraphFactory().fromCollections(graphHead, vertices, edges); } FlinkAsciiGraphLoader(GradoopFlinkConfig config); void initDatabaseFromString(String asciiGraphs); void initDatabaseFromStream(InputStream stream); void appendToDatabaseFromString(String asciiGraph); void initDatabaseFromFile(String fileName); LogicalGraph getLogicalGraph(); LogicalGraph getLogicalGraph(boolean withGraphContainment); LogicalGraph getLogicalGraphByVariable(String variable); GraphCollection getGraphCollection(); GraphCollection getGraphCollectionByVariables(String... variables); Collection<EPGMGraphHead> getGraphHeads(); EPGMGraphHead getGraphHeadByVariable(String variable); Collection<EPGMGraphHead> getGraphHeadsByVariables(String... variables); Collection<EPGMVertex> getVertices(); Collection<EPGMVertex> getVerticesByGraphVariables(String... variables); EPGMVertex getVertexByVariable(String variable); Collection<EPGMEdge> getEdges(); Collection<EPGMEdge> getEdgesByGraphVariables(String... variables); EPGMEdge getEdgeByVariable(String variable); }
FlinkAsciiGraphLoader { public LogicalGraph getLogicalGraphByVariable(String variable) { EPGMGraphHead graphHead = getGraphHeadByVariable(variable); Collection<EPGMVertex> vertices = getVerticesByGraphVariables(variable); Collection<EPGMEdge> edges = getEdgesByGraphVariables(variable); return config.getLogicalGraphFactory().fromCollections(graphHead, vertices, edges); } FlinkAsciiGraphLoader(GradoopFlinkConfig config); void initDatabaseFromString(String asciiGraphs); void initDatabaseFromStream(InputStream stream); void appendToDatabaseFromString(String asciiGraph); void initDatabaseFromFile(String fileName); LogicalGraph getLogicalGraph(); LogicalGraph getLogicalGraph(boolean withGraphContainment); LogicalGraph getLogicalGraphByVariable(String variable); GraphCollection getGraphCollection(); GraphCollection getGraphCollectionByVariables(String... variables); Collection<EPGMGraphHead> getGraphHeads(); EPGMGraphHead getGraphHeadByVariable(String variable); Collection<EPGMGraphHead> getGraphHeadsByVariables(String... variables); Collection<EPGMVertex> getVertices(); Collection<EPGMVertex> getVerticesByGraphVariables(String... variables); EPGMVertex getVertexByVariable(String variable); Collection<EPGMEdge> getEdges(); Collection<EPGMEdge> getEdgesByGraphVariables(String... variables); EPGMEdge getEdgeByVariable(String variable);  }