如何通过reduce函数在与当前状态合并之前聚合flink流中的事件？

DataStream<Event> stream = ...; // 输入流

DataStream<Event> aggregatedStream = stream
    .keyBy(Event::getKey) // 按照某个字段进行分组
    .window(TumblingEventTimeWindows.of(Time.seconds(5))) // 定义窗口
    .reduce(new ReduceFunction<Event>() {
        @Override
        public Event reduce(Event currentState, Event event) throws Exception {
            // 合并当前状态与事件，得到新的状态
            // 这里可以根据业务需求进行具体的合并操作
            // 例如，将事件的某个字段累加到当前状态中
            currentState.setCount(currentState.getCount() + event.getCount());
            return currentState;
        }
    });

aggregatedStream.print(); // 打印聚合结果