我正在考虑如何将 Apache Flink 用于我目前正在开发的投票系统。我是 Flink 的新手，任何帮助都将不胜感激。
要求是：
在我的理解中，Flink 的流处理是针对无限流的实时处理，而批处理是针对有限流的非实时处理。
如何将 Flink 应用于我的需求，即对有限流的实时处理？
【问题讨论】：
标签： apache-flink
Flink 的 DataStream API 可以毫无问题地处理有限流的事件。 DataStream 程序将在流到达终点时简单地终止。
如果您使用SocketTextStreamFunction 从套接字读取文本数据，您可以模拟这种行为。关闭套接字后，程序将终止。或者，您也可以从也是某种有限流的文件中读取数据。但是，请记住，不完整的窗口不会被自动评估。因此，您必须确保在使用 Windows 时不会丢失数据。
【讨论】：
SocketTextStreamFunction 的实现，并为我的用例提出了以下策略。你认为这是要走的路吗？ 1. 参与者的每张投票都作为一个事件发送到我的SourceFunction。 2. 当主机用户关闭投票时，在其有效负载中包含终止信号的特殊事件被发送到我的SourceFunction，这导致它退出run 方法。 3. 我的窗口应该有一个额外的触发器，在接受终止事件时触发，以免丢失数据。
Long.MAX_VALUE 的水印来触发窗口计算。