Flink+kafka+redisリアルタイム計算wordcount
前回はローカルでwordcountを走りましたが、今日はフロー式の計算wordcountを書き、kafkaのデータを読み出してリアルタイムの計算を行い、結果をredisに書きました.
pomファイルは次のとおりです.
pomファイルは次のとおりです.
org.apache.flink
flink-scala_2.11
1.6.0
org.apache.flink
flink-clients_2.11
1.6.0
org.apache.flink
flink-streaming-scala_2.11
1.6.0
org.apache.flink