Skip to content

Commit

Permalink
[dbs-leipzig#1032] Converted example csv's to new format
Browse files Browse the repository at this point in the history
  • Loading branch information
ChrizZz110 committed Oct 10, 2018
1 parent 3091922 commit 30ed47a
Show file tree
Hide file tree
Showing 10 changed files with 2,743 additions and 2,748 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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();
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -73,18 +73,9 @@ 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();

executionEnvironment.execute();
}
}
3,784 changes: 1,892 additions & 1,892 deletions gradoop-examples/src/main/resources/data/csv/foodbroker/edges.csv

Large diffs are not rendered by default.

Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
5bbda7a084411f2dd1b873d1;;
Original file line number Diff line number Diff line change
@@ -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
Expand Down
1,608 changes: 804 additions & 804 deletions gradoop-examples/src/main/resources/data/csv/foodbroker/vertices.csv

Large diffs are not rendered by default.

48 changes: 24 additions & 24 deletions gradoop-examples/src/main/resources/data/csv/sna/edges.csv
Original file line number Diff line number Diff line change
@@ -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
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
5bbdb23484411f32e69b33da;;
7 changes: 4 additions & 3 deletions gradoop-examples/src/main/resources/data/csv/sna/metadata.csv
Original file line number Diff line number Diff line change
@@ -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
22 changes: 11 additions & 11 deletions gradoop-examples/src/main/resources/data/csv/sna/vertices.csv
Original file line number Diff line number Diff line change
@@ -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 30ed47a

Please sign in to comment.