如何在flink中立即调用进程函数？

import org.apache.flink.streaming.api.functions.ProcessFunction;
import org.apache.flink.util.Collector;

public class MyProcessFunction extends ProcessFunction<InputEvent, OutputEvent> {
    
    @Override
    public void processElement(InputEvent inputEvent, Context context, Collector<OutputEvent> collector) throws Exception {
        // 自定义处理逻辑
        // 可以根据输入事件生成输出事件
        // 可以使用context对象访问时间戳、定时器和侧输出等功能
        
        // 示例：将输入事件的值加倍，并生成输出事件
        OutputEvent outputEvent = new OutputEvent(inputEvent.getValue() * 2);
        
        // 发送输出事件
        collector.collect(outputEvent);
    }
}

DataStream<InputEvent> input = ...; // 输入流

DataStream<OutputEvent> output = input
    .keyBy("key") // 按照指定的键进行分区
    .process(new MyProcessFunction()); // 应用自定义进程函数

output.print(); // 打印输出流