开发者社区> 问答> 正文

请问假如在流式的wordcount里我想统计从开始到结束所有单词数,可以通过定义一个简单#Flink

请问假如在流式的wordcount里我想统计从开始到结束所有单词数,可以通过定义一个简单的Java map实现吗?是否会因为分布式而存在数据缺失的情况 #Flink

展开
收起
黄一刀 2020-07-26 21:06:08 871 0
1 条回答
写回答
取消 提交回答
  • 官网有这个例子的代码 https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/datastream_api.html

    2020-07-26 21:06:43
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载