apache-flink - flink官方文档中如何实现类MyTupleReducer

Question

我正在学习 flink 文档数据集 api

有一个班级叫mytupleReducer

我正在尝试完成它： https ://paste.ubuntu.com/p/3CjphGQrXP/

但它在 Intellij 中充满了红线。

你能给我一个正确的上述代码风格吗？

谢谢你的帮助~！

PS：

我正在写部分 MyTupleReduce https://pastebin.ubuntu.com/p/m4rjs6t8QP/

但返回部分是错误的。

Answer 1

我怀疑Reduce从 akka 导入会使你偏离正轨。Flink 的ReduceFunction<T>接口需要你实现一个reduce带有这个签名的方法：

T reduce(T value1, T value2) throws Exception;

这是一个经典的 reduce，它接受两个 T 类型的对象并产生第三个相同类型的对象。