用于有限流实时处理的Apache Flink
用于有限流实时处理的Apache Flink
提问于 2016-06-09 15:15:37
我正在考虑如何在我目前正在开发的投票系统中使用Apache。我是一个完整的新手对弗林克和任何帮助将不胜感激。
所需经费如下：
- 拥有某种特权的用户可以开始对任意问题进行投票。用户可以随时结束投票。
- 多达数十万人可能参加投票。
- 应在开始投票后立即开始点票，并应随着时间的推移更新中间结果，以便向与会者显示。
- 当系统在投票结束后完成计数时，应将最终结果通知参与者。
据我理解，Flink的流处理是对无限流的实时处理，而批处理是针对有限流的非实时处理。
如何将Flink应用到我的需求中，这是有限流的实时处理？
回答 1
Stack Overflow用户
回答已采纳
发布于 2016-06-09 20:56:21
Flink的DataStream API可以处理有限流的事件，没有任何问题。当流到达其结束时，DataStream程序将简单地终止。
如果使用SocketTextStreamFunction从套接字读取文本数据，则可以模拟此行为。一旦关闭套接字，程序将终止。或者，您也可以从文件中读取数据，该文件也是某种有限的流。但是，请记住，不完整的窗口不会自动评估。因此，如果使用这些数据，您必须确保在windows中不会丢失数据。
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/37729949
复制相关文章
相似问题
腾讯云开发者
