Stateful 函数中的时间特性
Time characteristic in Stateful functions
我大致理解事件时间使用水印来及时取得进展。对于更多基于迭代的 Flink Statefun，这可能是一个问题。所以我的问题是，如果我使用延迟消息 (https://nightlies.apache.org/flink/flink-statefun-docs-stable/docs/sdk/java/#sending-delayed-messages)，那么这是否意味着我们只能在有状态函数中使用处理时间概念？
我想更改为事件时间处理模型，但不确定它如何与有状态函数一起使用。
pipeline.time-characteristic: EventTime
pipeline.auto-watermark-interval: 200
有人可以解释一下吗？
有状态函数 (statefun) 不支持水印或 event-time 处理。但是您可以根据到达事件的时间戳实现自己的触发逻辑。
我大致理解事件时间使用水印来及时取得进展。对于更多基于迭代的 Flink Statefun，这可能是一个问题。所以我的问题是，如果我使用延迟消息 (https://nightlies.apache.org/flink/flink-statefun-docs-stable/docs/sdk/java/#sending-delayed-messages)，那么这是否意味着我们只能在有状态函数中使用处理时间概念？
我想更改为事件时间处理模型，但不确定它如何与有状态函数一起使用。
pipeline.time-characteristic: EventTime
pipeline.auto-watermark-interval: 200
有人可以解释一下吗？
有状态函数 (statefun) 不支持水印或 event-time 处理。但是您可以根据到达事件的时间戳实现自己的触发逻辑。