如何使用Flink Java API在数据式中心进行计数

Question

我遇到了与如何计算流中唯一单词相同的问题？在Flink编程中。但是，答案使用Scala API解决了问题。Flink Java API是否支持filterWithState转换？Java API可以解决问题吗？

Answer 1

filterWithState和 mapWithState是flink scala api的句法糖，在Java API中不可用。但是，Java中确实存在编写状态转换和过滤器的基本机制 - 请参阅文档。