Permalink
Browse files

[#1046] Fixes for InvertEdge JUnit test (#1048)

fixes #1046
  • Loading branch information...
merando authored and ChrizZz110 committed Oct 19, 2018
1 parent 544af63 commit 361d4b3a973e70468edf8c1393e51d5e889ecb4c
@@ -22,7 +22,7 @@
import org.gradoop.flink.model.GradoopFlinkTestBase;
import org.gradoop.flink.model.api.epgm.LogicalGraph;
import org.gradoop.flink.model.impl.functions.epgm.ByLabel;
import org.gradoop.flink.model.impl.functions.filters.And;
import org.gradoop.flink.model.impl.functions.filters.Or;
import org.junit.Assert;
import org.junit.Test;
@@ -81,14 +81,16 @@ public void testInvert() throws Exception {
*/
List<Vertex> vertices = new ArrayList<>();
invertedEdgeGraph.getVertices()
.filter(new And<>(new ByLabel<>("Person"), new ByLabel<>("Tag")))
.filter(new Or<>(new ByLabel<>("Person"), new ByLabel<>("Tag")))
.output(new LocalCollectionOutputFormat<>(vertices));
List<Edge> newEdges = new ArrayList<>();
invertedEdgeGraph
.getEdgesByLabel(invertedLabel)
.output(new LocalCollectionOutputFormat<>(newEdges));
getConfig().getExecutionEnvironment().execute();
Map<GradoopId, String> idMap = new HashMap<>();
vertices.forEach(v -> idMap.put(v.getId(), v.getPropertyValue("name").getString()));

0 comments on commit 361d4b3

Please sign in to comment.