Thursday, October 31, 2019

Flink gelly graph example

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: