Apache flink:当窗口关闭时，如何将timeWinow中的元素转发给进程函数？

public class MyProcessWindowFunction extends ProcessWindowFunction<InputType, OutputType, KeyType, TimeWindow> {
    @Override
    public void process(KeyType key, Context context, Iterable<InputType> elements, Collector<OutputType> out) throws Exception {
        for (InputType element : elements) {
            // 处理元素
            // ...

            // 发送处理结果到下游
            out.collect(outputElement);
        }
    }
}

// 使用进程函数
DataStream<InputType> input = ...;  // 输入流
KeyedStream<InputType, KeyType> keyedInput = input.keyBy(keySelector);  // 按照 key 分组
WindowedStream<InputType, KeyType, TimeWindow> windowedInput = keyedInput.window(TumblingEventTimeWindows.of(Time.minutes(1)));  // 定义窗口
windowedInput.process(new MyProcessWindowFunction());  // 应用进程函数