gpt4 book ai didi

hadoop - Apache Flink - 跟踪最大值

转载 作者:可可西里 更新时间:2023-11-01 16:29:57 27 4
gpt4 key购买 nike

假设我有一个由元组组成的数据流 (t, q) 其中 t 是感兴趣的变量。

是否有一种分布式方式来跟踪具有最大 t 的元组?仅在 t 高于全局最大值时发出?

最佳答案

你考虑过Flink的状态特性吗? ( https://ci.apache.org/projects/flink/flink-docs-release-1.0/apis/streaming/state.html )

我自己对 Flink 很陌生,但我认为它提供了您正在寻找的功能。

关于hadoop - Apache Flink - 跟踪最大值,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/38643472/

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