gpt4 book ai didi

java - 如何对 WindowedStream 数据使用指标系统或类似的东西?

转载 作者:行者123 更新时间:2023-12-02 05:59:00 24 4
gpt4 key购买 nike

我想测量 Apache Flink 中每个窗口的吞吐量。这些指标不适合 WindowedStream,因为它表示不支持 RichFunction 作为 AggregateFunction。我使用单例实例,但有人说它不适合分布式环境。 (本地运行ok)这种情况有什么解决办法吗?

最佳答案

有内置的指标来衡量

numBytesInLocalPerSecond
numBytesInRemotePerSecond
numBytesOutPerSecond
numRecordsInPerSecond
numRecordsOutPerSecond

这些吞吐量指标对于每个运算符(operator)都是开箱即用的(源的输入指标和接收器的输出指标除外),包括窗口。

关于java - 如何对 WindowedStream 数据使用指标系统或类似的东西?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/55990425/

24 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com