Gelly：Flink Graph API
- 使用Gelly
- 运行Gelly示例

Gelly：Flink Graph API

译者：flink.sojb.cn

Gelly是Flink的Graph API。它包含一组方法和实用程序，旨在简化Flink中图形分析应用程序的开发。在Gelly中，可以使用与批处理API提供的类似的高级函数来转换和修改图形。Gelly提供了创建，转换和修改图形的方法，以及图形算法库。

使用Gelly

冻膜是目前的部分库 Maven项目。所有相关的类都位于org.apache.flink.graph包中。

将以下依赖项添加到您pom.xml使用Gelly。

Java
Scala

<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-gelly_2.11</artifactId>
    <version>1.7-SNAPSHOT</version>
</dependency>

<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-gelly-scala_2.11</artifactId>
    <version>1.7-SNAPSHOT</version>
</dependency>

请注意，Gelly不是二进制发行版的一部分。有关将 Gelly库打包到Flink用户程序的说明，请参阅链接。

其余部分提供了可用方法的说明，并提供了如何使用Gelly以及如何将其与Flink DataSet API混合的几个示例。

运行Gelly示例

Gelly库jar 在opt目录中的Flink发行版中提供（对于早于Flink 1.2的版本，这些可以从Maven Central手动下载）。要运行Gelly示例，必须将flink-gelly（对于Java）或flink-gelly-scala（对于Scala）jar复制到Flink的lib目录中。

cp opt/flink-gelly_*.jar lib/
cp opt/flink-gelly-scala_*.jar lib/

Gelly的示例jar包含每个库方法的驱动程序，并在示例目录中提供。配置并启动集群后，列出可用的算法类：

./bin/start-cluster.sh
./bin/flink run examples/gelly/flink-gelly-examples_*.jar

Gelly驱动程序可以生成图形数据或从CSV文件读取边缘列表（群集中的每个节点都必须能够访问输入文件）。选择算法时，将显示算法描述，可用输入和输出以及配置。JaccardIndex打印用法：

./bin/flink run examples/gelly/flink-gelly-examples_*.jar --algorithm JaccardIndex

显示一百万个顶点图的图表指标：

./bin/flink run examples/gelly/flink-gelly-examples_*.jar \
    --algorithm GraphMetrics --order directed \
    --input RMatGraph --type integer --scale 20 --simplify directed \
    --output print

图形的大小由—scale和—edge_factor参数调整。该库生成提供了访问其他配置调整幂律偏移和随机噪声。

示例社交网络数据由斯坦福网络分析项目提供。在COM-LJ数据集是一个很好的入门尺寸。运行一些算法并在Flink的Web UI中监控作业进度：

wget -O - http://snap.stanford.edu/data/bigdata/communities/com-lj.ungraph.txt.gz | gunzip -c > com-lj.ungraph.txt
./bin/flink run -q examples/gelly/flink-gelly-examples_*.jar \
    --algorithm GraphMetrics --order undirected \
    --input CSV --type integer --simplify undirected --input_filename com-lj.ungraph.txt --input_field_delimiter /figure>\t' \
    --output print
./bin/flink run -q examples/gelly/flink-gelly-examples_*.jar \
    --algorithm ClusteringCoefficient --order undirected \
    --input CSV --type integer --simplify undirected --input_filename com-lj.ungraph.txt --input_field_delimiter /figure>\t' \
    --output hash
./bin/flink run -q examples/gelly/flink-gelly-examples_*.jar \
    --algorithm JaccardIndex \
    --input CSV --type integer --simplify undirected --input_filename com-lj.ungraph.txt --input_field_delimiter /figure>\t' \
    --output hash

请在用户邮件列表或Flink Jira上提交函数请求和报告问题。我们欢迎有关新算法和函数以及代码贡献的建议。