Just quick start Flink graph API.
D:\apps\flink-1.9.0>.\bin\flink.bat run examples\gelly\flink-gelly-examples_*.jar --algorithm GraphMetrics --order directed --input RMatGraph --type integer --scale 20 --simplify directed --output print
log4j:WARN No appenders could be found for logger (org.apache.flink.client.cli.CliFrontend).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info.
Starting execution of program
Vertex metrics:
vertex count: 646,203
edge count: 16,084,983
unidirectional edge count: 15,314,463
bidirectional edge count: 385,260
average degree: 24.892
density: 0.00003852
triplet count: 35,034,305,809
maximum degree: 64,779
maximum out degree: 39,706
maximum in degree: 39,636
maximum triplets: 2,098,127,031
Edge metrics:
triangle triplet count: 1,225,406,293
rectangle triplet count: 5,645,928,171
maximum triangle triplets: 226,128
maximum rectangle triplets: 2,284,162
Program execution finished
Job with JobID b5b98100cb4946167a3ad762922d305b has finished.
Job Runtime: 165189 ms
Accumulator Results:
- 032c2d57136783dd8ed0620a38b1e819-unidirectionalEdgeCount (java.lang.Long): 30628926
- 032c2d57136783dd8ed0620a38b1e819-tripletCount (java.lang.Long): 35034305809
- 032c2d57136783dd8ed0620a38b1e819-vertexCount (java.lang.Long): 646203
- 032c2d57136783dd8ed0620a38b1e819-maximumTriplets (java.lang.Long): 2098127031
- 032c2d57136783dd8ed0620a38b1e819-maximumInDegree (java.lang.Long): 39636
- 032c2d57136783dd8ed0620a38b1e819-maximumDegree (java.lang.Long): 64779
- 1fad2a0e0bb15832eb7ba669bf82a988-rectangleTripletCount (java.lang.Long): 5645928171
- 1fad2a0e0bb15832eb7ba669bf82a988-triangleTripletCount (java.lang.Long): 1225406293
- 1fad2a0e0bb15832eb7ba669bf82a988-maximumTriangleTriplets (java.lang.Long): 226128
- 032c2d57136783dd8ed0620a38b1e819-maximumOutDegree (java.lang.Long): 39706
- 1fad2a0e0bb15832eb7ba669bf82a988-maximumRectangleTriplets (java.lang.Long): 2284162
- 032c2d57136783dd8ed0620a38b1e819-bidirectionalEdgeCount (java.lang.Long): 770520
D:\apps\flink-1.9.0>
This is more like graph computation.
No comments:
Post a Comment