@Test public void testDontAlterEmbedding() throws Exception { CNF predicates = predicateFromQuery("MATCH (a),(b) WHERE a.age > b.age"); PropertyValue[] propertiesA = new PropertyValue[]{PropertyValue.create(42)}; PropertyValue[] propertiesB = new PropertyValue[]{PropertyValue.create(23)}; Embedding embedding = new Embedding(); embedding.add(GradoopId.get(), propertiesA); embedding.add(GradoopId.get()); embedding.add(GradoopId.get(), propertiesB); DataSet<Embedding> embeddings = getExecutionEnvironment().fromElements(embedding); EmbeddingMetaData metaData = new EmbeddingMetaData(); metaData.setEntryColumn("a", EntryType.VERTEX, 0); metaData.setEntryColumn("b", EntryType.VERTEX, 1); metaData.setPropertyColumn("a", "age", 0); metaData.setPropertyColumn("b", "age", 1); FilterEmbeddings filter = new FilterEmbeddings(embeddings, predicates, metaData); assertEquals(embedding, filter.evaluate().collect().get(0)); }
@Override public DataSet<Embedding> evaluate() { return input .filter(new FilterEmbedding(predicates, metaData)) .name(getName()); }
FilterEmbeddings implements PhysicalOperator { @Override public DataSet<Embedding> evaluate() { return input .filter(new FilterEmbedding(predicates, metaData)) .name(getName()); } }
FilterEmbeddings implements PhysicalOperator { @Override public DataSet<Embedding> evaluate() { return input .filter(new FilterEmbedding(predicates, metaData)) .name(getName()); } FilterEmbeddings(DataSet<Embedding> input, CNF predicates,
    EmbeddingMetaData metaData); }
FilterEmbeddings implements PhysicalOperator { @Override public DataSet<Embedding> evaluate() { return input .filter(new FilterEmbedding(predicates, metaData)) .name(getName()); } FilterEmbeddings(DataSet<Embedding> input, CNF predicates,
    EmbeddingMetaData metaData); @Override DataSet<Embedding> evaluate(); @Override void setName(String newName); @Override String getName(); }
FilterEmbeddings implements PhysicalOperator { @Override public DataSet<Embedding> evaluate() { return input .filter(new FilterEmbedding(predicates, metaData)) .name(getName()); } FilterEmbeddings(DataSet<Embedding> input, CNF predicates,
    EmbeddingMetaData metaData); @Override DataSet<Embedding> evaluate(); @Override void setName(String newName); @Override String getName();  }