如何在Flink流中检索累加器？

vwoqyblh 于 2022-12-09 发布在 Apache

关注(0)|答案(1)|浏览(157)

我已经按照以下链接中的步骤实现了累加器
https://nightlies.apache.org/flink/flink-docs-master/docs/dev/datastream/user_defined_functions/#accumulators--counters
但在第三步之后，检索此

myJobExecutionResult.getAccumulatorResult("num-lines");

如果是批处理作业，我可以实现FlinkListener并覆盖onJobExecuted并使用“myJobExecutionResult”，但在流方法中，我可以从哪里获得myJobExecutionResult？有人能用示例片段来帮助我吗？

apache-flink

来源：https://stackoverflow.com/questions/73657957/how-to-retrieve-accumulator-in-flink-streaming

1条答案

按热度按时间

mwkjh3gx1#

如何在Apache Flink中使用累加器的示例可以在Immerok Cookbook的Session Windows中找到：https://www.docs.immerok.cloud/docs/cookbook/using-session-windows/
(Note：我为Immerok工作）

赞(0）回复(0）举报 2022-12-09

我来回答

如何在Flink流中检索累加器？

1条答案

相关问题

热门标签

最新问答