@Test public void testGraphElementIdEquality() throws Exception { FlinkAsciiGraphLoader loader = getLoaderFromString(dataGraph); LogicalGraph db = loader.getLogicalGraphByVariable(TestData.DATA_GRAPH_VARIABLE); loader.appendToDatabaseFromString(expectedCollection); GraphCollection result = getImplementation(queryGraph, false).execute(db); GraphCollection expected = loader.getGraphCollectionByVariables(expectedGraphVariables); collectAndAssertTrue(result.equalsByGraphElementIds(expected)); }
@Override public GC execute(LG graph) { if (log.isDebugEnabled()) { initDebugMappings(graph); } GC result; if (queryHandler.isSingleVertexGraph()) { result = executeForVertex(graph); } else { result = executeForPattern(graph); } return result; }
PatternMatching implements UnaryBaseGraphToBaseGraphCollectionOperator<LG, GC> { @Override public GC execute(LG graph) { if (log.isDebugEnabled()) { initDebugMappings(graph); } GC result; if (queryHandler.isSingleVertexGraph()) { result = executeForVertex(graph); } else { result = executeForPattern(graph); } return result; } }
PatternMatching implements UnaryBaseGraphToBaseGraphCollectionOperator<LG, GC> { @Override public GC execute(LG graph) { if (log.isDebugEnabled()) { initDebugMappings(graph); } GC result; if (queryHandler.isSingleVertexGraph()) { result = executeForVertex(graph); } else { result = executeForPattern(graph); } return result; } PatternMatching(String query, boolean attachData, Logger log); }
PatternMatching implements UnaryBaseGraphToBaseGraphCollectionOperator<LG, GC> { @Override public GC execute(LG graph) { if (log.isDebugEnabled()) { initDebugMappings(graph); } GC result; if (queryHandler.isSingleVertexGraph()) { result = executeForVertex(graph); } else { result = executeForPattern(graph); } return result; } PatternMatching(String query, boolean attachData, Logger log); @Override GC execute(LG graph); }
PatternMatching implements UnaryBaseGraphToBaseGraphCollectionOperator<LG, GC> { @Override public GC execute(LG graph) { if (log.isDebugEnabled()) { initDebugMappings(graph); } GC result; if (queryHandler.isSingleVertexGraph()) { result = executeForVertex(graph); } else { result = executeForPattern(graph); } return result; } PatternMatching(String query, boolean attachData, Logger log); @Override GC execute(LG graph); static final transient String VARIABLE_MAPPING_KEY; }