你能解释一下在flink中使用key/operator状态管理一个状态与使用会话窗口然后通过触发器减少状态的优缺点吗?谢谢
qxgroojn1#
flink的会话窗口数据也存储在flink的托管状态中。会话窗口的好处是,它以表现力为代价提供了更高级别的抽象。说到这里,您可以通过实现您自己的操作符来完成会话窗口所做的一切,该操作符将其数据保持在flink状态,但实现起来很可能更复杂。
1条答案
按热度按时间qxgroojn1#
flink的会话窗口数据也存储在flink的托管状态中。会话窗口的好处是,它以表现力为代价提供了更高级别的抽象。说到这里,您可以通过实现您自己的操作符来完成会话窗口所做的一切,该操作符将其数据保持在flink状态,但实现起来很可能更复杂。