트위터 스트림을 듣고 트윗에서 원하는 데이터를 추출하여 성공했습니다. 지금은이 그래프는 시간에 걸쳐 건물을 유지 나는이 그래프를 통해 쿼리를 실행하려는 동안Twitter Flick을 사용하여 트위터 스트림 및 쿼리로 그래프 작성
(user)--[tweets]-->(tweet)
(tweet)--[mentions]-->(user)
(tweet)--[tagged]-->(hashtag)
처럼, 추출 된 정보와 그래프를 구축 유지하려는. Apache Flink로 어떻게이 작업을 수행 할 수 있습니까?
포럼과 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는 다른 관련 링크입니다.
아파치 FLINK 메일 링리스트에스트림과 같은 그래프에 바 시아 Kalavri의 이야기 : https://berlinbuzzwords.de/session/graphs-streams-rethinking-graph-processing-streaming-era