Flink provides a graph processing library called Gelly to simplify the development of graph analysis. It provides data structures to store and represent graph data and it provides methods to analyze the graphs. In Gelly, we can transform graphs from one state to another using Flink's higher-level functions. It also provides a set of algorithms used for detailed graph analysis.
Gelly is currently available as a part of the Flink libraries, so we need to add a Maven dependency in our programs to use it.
Java dependency:
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-gelly_2.11</artifactId>
<version>1.1.4</version>
</dependency>
Scala dependency:
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-gelly-scala_2.11</artifactId>
<version>1.1.4</version>
</dependency>
Now let's look at various options we have in...