Permalink
Browse files

[#1032] Converted example csv's to new format (#1033)

  • Loading branch information...
ChrizZz110 authored and merando committed Oct 10, 2018
1 parent 36eb64a commit 9a0d65403bcf2f5acd3270e105a7f644824a3927
@@ -65,9 +65,9 @@ public static void main(String[] args) throws Exception {
"(u2:Person)<-[:hasMember]-(f)" +
"WHERE u1.name = \"Alice\"", statistics);
// this just prints the graph heads to system out
// Print the graph to system out
// alternatively, one can use a org.gradoop.flink.io.api.DataSink to store the whole collection
// or use the result in subsequent analytical steps
matches.getGraphHeads().print();
matches.print();
}
}
@@ -17,7 +17,6 @@
import org.apache.flink.api.common.functions.FilterFunction;
import org.apache.flink.api.java.ExecutionEnvironment;
import org.apache.flink.api.java.io.LocalCollectionOutputFormat;
import org.gradoop.common.model.impl.pojo.Edge;
import org.gradoop.common.model.impl.pojo.Vertex;
import org.gradoop.common.model.impl.properties.PropertyValue;
@@ -27,9 +26,6 @@
import org.gradoop.flink.model.impl.functions.epgm.ByProperty;
import org.gradoop.flink.util.GradoopFlinkConfig;
import java.util.ArrayList;
import java.util.List;
/**
* An example for the subgraph operator using combined filter functions.
*
@@ -73,18 +69,7 @@ public static void main(String[] args) throws Exception {
// Use these filters with a subgraph call:
LogicalGraph filteredGraph = inputGraph.subgraph(vertexFilter, edgeFilter);
// Collect vertices and edges to a local collection to output them both:
List<Vertex> resultVertices = new ArrayList<>();
List<Edge> resultEdges = new ArrayList<>();
filteredGraph.getVertices().output(new LocalCollectionOutputFormat<>(resultVertices));
filteredGraph.getEdges().output(new LocalCollectionOutputFormat<>(resultEdges));
executionEnvironment.execute();
// Print results:
System.out.println("Vertices:");
resultVertices.forEach(System.out::println);
System.out.println("Edges:");
resultEdges.forEach(System.out::println);
// Print result graph
filteredGraph.print();
}
}

Large diffs are not rendered by default.

Oops, something went wrong.
@@ -0,0 +1 @@
5bbda7a084411f2dd1b873d1;;
@@ -1,3 +1,4 @@
g;;
v;Client;account:string,city:string,contactPhone:string,erpCustNum:string,name:string,num:string,quality:double,superType:string
v;Customer;city:string,name:string,num:string,quality:double,superType:string
v;DeliveryNote;date:long,num:string,superType:string,trackingCode:string

Large diffs are not rendered by default.

Oops, something went wrong.
@@ -1,24 +1,24 @@
00000000000000000100000e;000000000000000000000002;000000000000000000000001;hasInterest;
000000000000000001000007;000000000000000000000008;000000000000000000000003;hasInterest;
000000000000000001000017;000000000000000000000006;000000000000000000000003;hasInterest;
00000000000000000100000b;000000000000000000000000;000000000000000000000001;hasInterest;
00000000000000000100000f;000000000000000000000005;000000000000000000000006;hasModerator;
00000000000000000100000d;000000000000000000000009;000000000000000000000000;hasModerator;
000000000000000001000016;000000000000000000000002;000000000000000000000004;knows;2015
000000000000000001000008;000000000000000000000007;000000000000000000000006;knows;2014
000000000000000001000009;000000000000000000000004;000000000000000000000000;knows;2014
00000000000000000100000a;000000000000000000000006;000000000000000000000007;knows;2014
000000000000000001000006;000000000000000000000007;000000000000000000000004;knows;2013
000000000000000001000014;000000000000000000000008;000000000000000000000006;knows;2013
000000000000000001000015;000000000000000000000000;000000000000000000000004;knows;2014
00000000000000000100000c;000000000000000000000004;000000000000000000000007;knows;2013
000000000000000001000011;000000000000000000000008;000000000000000000000007;knows;2014
000000000000000001000012;000000000000000000000002;000000000000000000000000;knows;2015
000000000000000001000001;000000000000000000000009;000000000000000000000004;hasMember;
000000000000000001000002;000000000000000000000005;000000000000000000000006;hasMember;
000000000000000001000003;000000000000000000000005;000000000000000000000007;hasMember;
000000000000000001000004;000000000000000000000009;000000000000000000000000;hasMember;
000000000000000001000000;000000000000000000000005;000000000000000000000003;hasTag;
000000000000000001000005;000000000000000000000009;00000000000000000000000a;hasTag;
000000000000000001000013;000000000000000000000009;000000000000000000000001;hasTag;
000000000000000001000010;000000000000000000000005;00000000000000000000000a;hasTag;
00000000000000000100000e;[5bbdb23484411f32e69b33da];000000000000000000000002;000000000000000000000001;hasInterest;
000000000000000001000007;[5bbdb23484411f32e69b33da];000000000000000000000008;000000000000000000000003;hasInterest;
000000000000000001000017;[5bbdb23484411f32e69b33da];000000000000000000000006;000000000000000000000003;hasInterest;
00000000000000000100000b;[5bbdb23484411f32e69b33da];000000000000000000000000;000000000000000000000001;hasInterest;
000000000000000001000004;[5bbdb23484411f32e69b33da];000000000000000000000009;000000000000000000000000;hasMember;
000000000000000001000003;[5bbdb23484411f32e69b33da];000000000000000000000005;000000000000000000000007;hasMember;
000000000000000001000002;[5bbdb23484411f32e69b33da];000000000000000000000005;000000000000000000000006;hasMember;
000000000000000001000001;[5bbdb23484411f32e69b33da];000000000000000000000009;000000000000000000000004;hasMember;
00000000000000000100000f;[5bbdb23484411f32e69b33da];000000000000000000000005;000000000000000000000006;hasModerator;
00000000000000000100000d;[5bbdb23484411f32e69b33da];000000000000000000000009;000000000000000000000000;hasModerator;
000000000000000001000010;[5bbdb23484411f32e69b33da];000000000000000000000005;00000000000000000000000a;hasTag;
000000000000000001000000;[5bbdb23484411f32e69b33da];000000000000000000000005;000000000000000000000003;hasTag;
000000000000000001000005;[5bbdb23484411f32e69b33da];000000000000000000000009;00000000000000000000000a;hasTag;
000000000000000001000013;[5bbdb23484411f32e69b33da];000000000000000000000009;000000000000000000000001;hasTag;
000000000000000001000011;[5bbdb23484411f32e69b33da];000000000000000000000008;000000000000000000000007;knows;2014
000000000000000001000012;[5bbdb23484411f32e69b33da];000000000000000000000002;000000000000000000000000;knows;2015
00000000000000000100000a;[5bbdb23484411f32e69b33da];000000000000000000000006;000000000000000000000007;knows;2014
000000000000000001000009;[5bbdb23484411f32e69b33da];000000000000000000000004;000000000000000000000000;knows;2014
000000000000000001000008;[5bbdb23484411f32e69b33da];000000000000000000000007;000000000000000000000006;knows;2014
000000000000000001000016;[5bbdb23484411f32e69b33da];000000000000000000000002;000000000000000000000004;knows;2015
000000000000000001000015;[5bbdb23484411f32e69b33da];000000000000000000000000;000000000000000000000004;knows;2014
000000000000000001000014;[5bbdb23484411f32e69b33da];000000000000000000000008;000000000000000000000006;knows;2013
000000000000000001000006;[5bbdb23484411f32e69b33da];000000000000000000000007;000000000000000000000004;knows;2013
00000000000000000100000c;[5bbdb23484411f32e69b33da];000000000000000000000004;000000000000000000000007;knows;2013
@@ -0,0 +1 @@
5bbdb23484411f32e69b33da;;
@@ -1,8 +1,9 @@
e;hasMember;
e;hasTag;
v;Person;age:int,city:string,gender:string,locIP:string,name:string,speaks:string
g;;
e;hasInterest;
e;hasMember;
e;hasModerator;
e;hasTag;
e;knows;since:int
v;Forum;title:string
v;Person;age:int,city:string,gender:string,locIP:string,name:string,speaks:string
v;Tag;name:string
@@ -1,11 +1,11 @@
000000000000000000000009;Forum;Graph Processing
000000000000000000000005;Forum;Graph Databases
000000000000000000000001;Tag;Hadoop
00000000000000000000000a;Tag;Graphs
000000000000000000000003;Tag;Databases
000000000000000000000006;Person;20|Leipzig|f||Alice|
000000000000000000000007;Person;30|Leipzig|m||Bob|
000000000000000000000000;Person;40|Dresden|m||Dave|
000000000000000000000002;Person;35|Berlin|m|127.0.0.1|Frank|
000000000000000000000008;Person;35|Dresden|f||Eve|English
000000000000000000000004;Person;30|Dresden|f||Carol|
000000000000000000000009;[5bbdb23484411f32e69b33da];Forum;Graph Processing
000000000000000000000005;[5bbdb23484411f32e69b33da];Forum;Graph Databases
000000000000000000000006;[5bbdb23484411f32e69b33da];Person;20|Leipzig|f||Alice|
000000000000000000000007;[5bbdb23484411f32e69b33da];Person;30|Leipzig|m||Bob|
000000000000000000000000;[5bbdb23484411f32e69b33da];Person;40|Dresden|m||Dave|
000000000000000000000002;[5bbdb23484411f32e69b33da];Person;35|Berlin|m|127.0.0.1|Frank|
000000000000000000000008;[5bbdb23484411f32e69b33da];Person;35|Dresden|f||Eve|English
000000000000000000000004;[5bbdb23484411f32e69b33da];Person;30|Dresden|f||Carol|
000000000000000000000001;[5bbdb23484411f32e69b33da];Tag;Hadoop
00000000000000000000000a;[5bbdb23484411f32e69b33da];Tag;Graphs
000000000000000000000003;[5bbdb23484411f32e69b33da];Tag;Databases

0 comments on commit 9a0d654

Please sign in to comment.