Twitterのストリームでグラフを作成し、Apache Flinkを使用してクエリを作成します。

Question

Twitterのストリームを聴き、つぶやきから必要なデータを抽出して成功しました。今、私はこのグラフは、時間をかけて建物を維持しながら

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

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

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

のように、抽出された情報とのグラフを構築維持したい、私はこのグラフ上でクエリを実行します。 Apache Flinkでこれをどうすればできますか？

Answer 1

さらにフォーラムとJIRAを掘り下げて、私のニーズに合ったgelly-streamingが見つかりました。それによって

、我々はGraphStreamを作成行うことができ、

GraphStream<Long, NullValue, NullValue> graph = new SimpleEdgeStream<>(getEdgesDataSet(env), env);

例：https://github.com/vasia/gelly-streaming/tree/master/src/main/java/org/apache/flink/graph/streaming/example

---

ここではいくつかの他の関連するリンクです。

ApacheのFLINKメーリングリストで

：http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Graph-with-stream-of-updates-td5166.html

ストリームとしてグラフ上のバシアKalavriの話：https://berlinbuzzwords.de/session/graphs-streams-rethinking-graph-processing-streaming-era