0
假设我有一个由元组$（t，q）$组成的数据流，其中$ t $是感兴趣的变量。是否有一种分布式方法来跟踪最大$ t $的元组？当$ t $高于全局最大值时才发射？Apache Flink - 保持最大值
问候， 凯文
A
回答
1
你有没有考虑弗林克的状态功能？ （https://ci.apache.org/projects/flink/flink-docs-release-1.0/apis/streaming/state.html）
我是Flink myselfe的新手，但我认为它提供了您正在寻找的功能。
相关问题
- 1. Apache Flink作业支持多流支持
- 2. Apache Apex与Apache Flink
- 3. Apache Beam/Flink ExceptionInChainedStubException
- 4. Apache Flink的XmlInputFormat
- 5. Apache Flink：如何并行执行但保持消息顺序？
- 6. 保持容器的最大值。
- 7. 保持双倍最大值为1.0
- 8. 保持最大值在范围R
- 9. 聚合保持最大值的行
- 10. Apache Flink流缩放
- 11. zipWithIndex Apache Flink
- 12. Apache Flink和事件排序
- 13. 从Apache Flink查询数据
- 14. flink是否支持暂停flink作业？
- 15. Apache Flink Kakfa XML流
- 16. Apache Camel consumer.delay最大值
- 17. flink-streaming-java在Apache Flink中不可用
- 18. Kafka Consumer Vs Apache Flink
- 19. Apache Flink Kafka集成
- 20. 作为大型机器学习平台的Apache Flink vs Apache Spark？
- 21. 使用Apache Spark/Apache Flink扩展
- 22. Apache Flink集成BuckingSink和s3
- 23. Apache Flink Dynamic sink of sink
- 24. Apache Flink和RxJava的使用
- 25. Apache网址重写保持参数=值
- 26. Apache Ignite中的Flink Streamer
- 27. Avro支持Flink - scala
- 28. Apache Flume与Apache Flink的区别
- 29. apache flink窗口顺序
- 30. Apache Flink REST API认证
谢谢！是的，但我认为是分享国家。这意味着如果状态变得越来越大，将会产生很多网络流量来维持状态。我现在正在研究'coGroup'，也许有可能？ –
据我所知，状态总是本地的TaskManager。但是如果你键入你的流，那么具有相同键的流的部分总是到达同一个TaskManager。 但我认为这不是你想要/可以对你的数据做什么！？ – Claudi
不，我不得不加入/组合它们，所以我需要维护一个全局状态（这不会有效）。 –