过滤元组列表的Java - Flink ->最快方法

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 TupleListFilteringExample {
    public static void main(String[] args) throws Exception {
        // 创建StreamExecutionEnvironment
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

        // 创建元组列表
        Tuple2<String, Integer> tuple1 = new Tuple2<>("A", 1);
        Tuple2<String, Integer> tuple2 = new Tuple2<>("B", 2);
        Tuple2<String, Integer> tuple3 = new Tuple2<>("C", 3);
        Tuple2<String, Integer> tuple4 = new Tuple2<>("D", 4);
        Tuple2<String, Integer> tuple5 = new Tuple2<>("E", 5);

        // 从元组列表创建DataStream
        DataStream<Tuple2<String, Integer>> dataStream = env.fromElements(tuple1, tuple2, tuple3, tuple4, tuple5);

        // 使用filter操作符过滤元组列表
        DataStream<Tuple2<String, Integer>> filteredStream = dataStream.filter(tuple -> tuple.f1 > 3);

        // 打印过滤后的结果
        filteredStream.print();

        // 执行任务
        env.execute("Tuple List Filtering Example");
    }
}