如何在flink中实现一个在超时之前进行缓冲并在超时后触发的触发器？

import org.apache.flink.api.common.state.ValueState;
import org.apache.flink.api.common.state.ValueStateDescriptor;
import org.apache.flink.streaming.api.functions.ProcessFunction;
import org.apache.flink.streaming.api.windowing.time.Time;
import org.apache.flink.util.Collector;

public class TimeoutTrigger extends ProcessFunction<Event, Result> {
    private ValueState<Event> eventState;

    public void processElement(Event event, Context ctx, Collector<Result> out) throws Exception {
        // 获取当前事件的时间戳
        long timestamp = event.getTimestamp();

        // 获取当前事件的处理时间
        long currentProcessingTime = ctx.timerService().currentProcessingTime();

        // 计算超时时间
        long timeoutTime = currentProcessingTime + Time.minutes(5).toMilliseconds();

        // 注册定时器
        ctx.timerService().registerProcessingTimeTimer(timeoutTime);

        // 更新状态
        eventState.update(event);
    }

    public void onTimer(long timestamp, OnTimerContext ctx, Collector<Result> out) throws Exception {
        // 获取超时时间
        long timeoutTime = timestamp;

        // 获取状态中的事件
        Event event = eventState.value();

        // 处理超时逻辑
        if (event != null && event.getTimestamp() < timeoutTime) {
            // 触发逻辑
            Result result = processEvent(event);

            // 发送结果到下游
            out.collect(result);
        }
    }

    private Result processEvent(Event event) {
        // 处理事件逻辑
        // ...

        return result;
    }
}