@Test public void testProjectLoop() throws Exception { GradoopId a = GradoopId.get(); EPGMEdge edge = new EPGMEdgeFactory().createEdge(a, a); DataSet<EPGMEdge> edges = getExecutionEnvironment().fromElements(edge); Embedding result = new ProjectEdges(edges, Collections.emptyList(), true) .evaluate().collect().get(0); assertEquals(result.size(), 2); assertEquals(a, result.getId(0)); assertEquals(edge.getId(), result.getId(1)); }
@Override public DataSet<Embedding> evaluate() { return input .map(new ProjectEdge(propertyKeys, isLoop)) .name(getName()); }
ProjectEdges implements PhysicalOperator { @Override public DataSet<Embedding> evaluate() { return input .map(new ProjectEdge(propertyKeys, isLoop)) .name(getName()); } }
ProjectEdges implements PhysicalOperator { @Override public DataSet<Embedding> evaluate() { return input .map(new ProjectEdge(propertyKeys, isLoop)) .name(getName()); } ProjectEdges(DataSet<EPGMEdge> input, List<String> propertyKeys, boolean isLoop);  ProjectEdges(DataSet<EPGMEdge> input, boolean isLoop); }
ProjectEdges implements PhysicalOperator { @Override public DataSet<Embedding> evaluate() { return input .map(new ProjectEdge(propertyKeys, isLoop)) .name(getName()); } ProjectEdges(DataSet<EPGMEdge> input, List<String> propertyKeys, boolean isLoop);  ProjectEdges(DataSet<EPGMEdge> input, boolean isLoop); @Override DataSet<Embedding> evaluate(); @Override void setName(String newName); @Override String getName(); }
ProjectEdges implements PhysicalOperator { @Override public DataSet<Embedding> evaluate() { return input .map(new ProjectEdge(propertyKeys, isLoop)) .name(getName()); } ProjectEdges(DataSet<EPGMEdge> input, List<String> propertyKeys, boolean isLoop);  ProjectEdges(DataSet<EPGMEdge> input, boolean isLoop); @Override DataSet<Embedding> evaluate(); @Override void setName(String newName); @Override String getName();  }