如何实现flink官方文档中的`MyTupleReducer`类

import org.apache.flink.api.common.functions.ReduceFunction;
import org.apache.flink.api.java.tuple.Tuple2;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

public class FlinkReduceExample {
    public static void main(String[] args) throws Exception {
        // 创建 Flink 执行环境
        final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

        // 创建一个包含 Tuple2<Integer, String> 的数据流
        DataStream<Tuple2<Integer, String>> inputStream = env.fromElements(
            new Tuple2<>(1, "Hello "),
            new Tuple2<>(2, "World "),
            new Tuple2<>(3, "from "),
            new Tuple2<>(4, "Flink ")
        );

        // 使用 MyTupleReducer 进行聚合
        DataStream<Tuple2<Integer, String>> reducedStream = inputStream.reduce(new MyTupleReducer());

        // 打印结果
        reducedStream.print();

        // 执行作业
        env.execute("Flink Reduce Example");
    }

    // MyTupleReducer 类定义
    public static class MyTupleReducer implements ReduceFunction<Tuple2<Integer, String>> {
        @Override
        public Tuple2<Integer, String> reduce(Tuple2<Integer, String> value1, Tuple2<Integer, String> value2) {
            return new Tuple2<>(value1.f0 + value2.f0, value1.f1 + value2.f1);
        }
    }
}