@Test public void testFilterEdgesByLabel() throws Exception { CNF predicates = predicateFromQuery("MATCH ()-[a:likes]->()"); EPGMEdgeFactory edgeFactory = new EPGMEdgeFactory(); EPGMEdge e1 = edgeFactory.createEdge("likes", GradoopId.get(), GradoopId.get()); EPGMEdge e2 = edgeFactory.createEdge("knows", GradoopId.get(), GradoopId.get()); DataSet<EPGMEdge> edges = getExecutionEnvironment().fromElements(e1, e2); List<Embedding> result = new FilterAndProjectEdges<>(edges, predicates, new ArrayList<>(), false) .evaluate() .collect(); assertEquals(1, result.size()); assertEquals(result.get(0).getId(1), e1.getId()); }
@Override public DataSet<Embedding> evaluate() { return input .flatMap(new FilterAndProjectEdge<>(predicates, projectionPropertyKeys, isLoop)) .name(getName()); }
FilterAndProjectEdges implements PhysicalOperator { @Override public DataSet<Embedding> evaluate() { return input .flatMap(new FilterAndProjectEdge<>(predicates, projectionPropertyKeys, isLoop)) .name(getName()); } }
FilterAndProjectEdges implements PhysicalOperator { @Override public DataSet<Embedding> evaluate() { return input .flatMap(new FilterAndProjectEdge<>(predicates, projectionPropertyKeys, isLoop)) .name(getName()); } FilterAndProjectEdges(DataSet<E> input, CNF predicates,
    List<String> projectionPropertyKeys, boolean isLoop); }
FilterAndProjectEdges implements PhysicalOperator { @Override public DataSet<Embedding> evaluate() { return input .flatMap(new FilterAndProjectEdge<>(predicates, projectionPropertyKeys, isLoop)) .name(getName()); } FilterAndProjectEdges(DataSet<E> input, CNF predicates,
    List<String> projectionPropertyKeys, boolean isLoop); @Override DataSet<Embedding> evaluate(); @Override void setName(String newName); @Override String getName(); }
FilterAndProjectEdges implements PhysicalOperator { @Override public DataSet<Embedding> evaluate() { return input .flatMap(new FilterAndProjectEdge<>(predicates, projectionPropertyKeys, isLoop)) .name(getName()); } FilterAndProjectEdges(DataSet<E> input, CNF predicates,
    List<String> projectionPropertyKeys, boolean isLoop); @Override DataSet<Embedding> evaluate(); @Override void setName(String newName); @Override String getName();  }