@Test public void testFilterWithNoPredicates() throws Exception { CNF predicates = predicateFromQuery("MATCH (a)"); Properties properties = Properties.create(); properties.set("name", "Anton"); DataSet<EPGMVertex> vertices = getExecutionEnvironment() .fromElements(new EPGMVertexFactory().createVertex("Person", properties)); FilterAndProjectVertices<EPGMVertex> filter = new FilterAndProjectVertices<>(vertices, predicates, new ArrayList<>()); assertEquals(1, filter.evaluate().count()); }
@Override public DataSet<Embedding> evaluate() { return input .flatMap(new FilterAndProjectVertex<>(predicates, projectionPropertyKeys)) .name(getName()); }
FilterAndProjectVertices implements PhysicalOperator { @Override public DataSet<Embedding> evaluate() { return input .flatMap(new FilterAndProjectVertex<>(predicates, projectionPropertyKeys)) .name(getName()); } }
FilterAndProjectVertices implements PhysicalOperator { @Override public DataSet<Embedding> evaluate() { return input .flatMap(new FilterAndProjectVertex<>(predicates, projectionPropertyKeys)) .name(getName()); } FilterAndProjectVertices(DataSet<V> input, CNF predicates,
    List<String> projectionPropertyKeys); }
FilterAndProjectVertices implements PhysicalOperator { @Override public DataSet<Embedding> evaluate() { return input .flatMap(new FilterAndProjectVertex<>(predicates, projectionPropertyKeys)) .name(getName()); } FilterAndProjectVertices(DataSet<V> input, CNF predicates,
    List<String> projectionPropertyKeys); @Override DataSet<Embedding> evaluate(); @Override void setName(String newName); @Override String getName(); }
FilterAndProjectVertices implements PhysicalOperator { @Override public DataSet<Embedding> evaluate() { return input .flatMap(new FilterAndProjectVertex<>(predicates, projectionPropertyKeys)) .name(getName()); } FilterAndProjectVertices(DataSet<V> input, CNF predicates,
    List<String> projectionPropertyKeys); @Override DataSet<Embedding> evaluate(); @Override void setName(String newName); @Override String getName();  }