我收听Twitter流,并成功地从tweets中提取我想要的数据。现在我想继续构建一个包含提取信息的图表,比如
(user)--[tweets]-->(tweet)
(tweet)--[mentions]-->(user)
(tweet)--[tagged]-->(hashtag)
虽然这个图一直在构建,但我想对这个图运行 query。我怎么能用Apache Flink做到这一点呢?
我收听Twitter流,并成功地从tweets中提取我想要的数据。现在我想继续构建一个包含提取信息的图表,比如
(user)--[tweets]-->(tweet)
(tweet)--[mentions]-->(user)
(tweet)--[tagged]-->(hashtag)
虽然这个图一直在构建,但我想对这个图运行 query。我怎么能用Apache Flink做到这一点呢?
随着对论坛和JIRA的进一步挖掘,我发现gelly streaming符合我的需求。
有了它,我们可以创建一个图形流,
GraphStream
示例:https://github.com/vasia/gelly-streaming/tree/master/src/main/java/org/apache/flink/graph/streaming/example
以下是一些其他相关 chaining接。
在Apache Flink邮件列表中:http://apache-flink-user-mail-list-archive.2336050.n4.nabble.com/Graph-with-stream-of-updates-td5166.html
Vasia Kalavri关于图形即流的演讲:https://berlinbuzzwords.de/session/graphs-streams-reking-graph-processing-streaming-era