Use KeyProcessFunction on KeyBy

Question

我有一段代码如下：

DataStream<Tuple2<Long, Integer>> datastream = otherDatastream
.keyBy(event -> event.getField(1))
.process(new SomeFunction());

我的someFunction是一个扩展KeyedProcessFunction的类。但是尝试此代码会导致Cannot resolve method process(SomeFunction)。我不确定这种情况下的正确语法是什么样子的。

Answer 1

有必要准确掌握SomeFunction中的所有细节：类型参数、方法重写等。如果您共享所有细节，我们会提供更多帮助，但通常情况下，一个好的策略是依靠IDE为您生成样板。

首先，请确保SomeFunction类扩展了KeyedProcessFunction<KEY, IN, OUT>，其中KEY是event.getField(1)返回的任何类型，IN是event的任何类型并且OUT看起来是Tuple2<Long, Integer>。

另一种策略是从工作示例开始，比如ApacheFlink培训库中的示例。