用Twitter流和apacheflink构建一个图形


0

我收听Twitter流,并成功地从tweets中提取我想要的数据。现在我想继续构建一个包含提取信息的图表,比如

 (user)--[tweets]-->(tweet) 

(tweet)--[mentions]-->(user)

(tweet)--[tagged]-->(hashtag)

虽然这个图一直在构建,但我想对这个图运行 query。我怎么能用Apache Flink做到这一点呢?

1 答案


0

随着对论坛和JIRA的进一步挖掘,我发现gelly streaming符合我的需求。

有了它,我们可以创建一个图形流,

GraphStreamgraph=new SimpleEdgeStream<>(getEdgesDataSet(env),env);

示例: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


我来回答

写文章

提问题

面试题