Flink用窗口函数聚合 options该怎么搞啊？

Flink 用窗口函数聚合可以使用 select() 算子。select() 算子可以对窗口中的数据进行聚合操作，并返回聚合结果。select() 算子的第一个参数是聚合函数，第二个参数是聚合的字段。

例如，下面的代码使用 sum() 函数对窗口中的数据进行求和操作，并将结果返回到 result 流中：

DataStream readings = ...;

// 创建一个滚动窗口，窗口大小为 5 秒，滑动间隔为 1 秒
WindowedStream windowedReadings = readings
.window(TumblingEventTimeWindows.of(Time.seconds(5)))
.assignTimestampsAndWatermarks(new AscendingTimestampExtractor() {
@Override
public long extractTimestamp(SensorReading reading) {
return reading.getTimestamp();
}
});

// 使用 select() 算子对窗口中的数据进行求和操作
DataStream result = windowedReadings
.select(new AggregateFunction() {
@Override
public Double createAccumulator() {
return 0.0;
}

  @Override
  public Double add(SensorReading reading, Double accumulator) {
    return accumulator + reading.getTemperature();
  }

  @Override
  public Double getResult(Double accumulator) {
    return accumulator;
  }

  @Override
  public Double merge(Double a, Double b) {
    return a + b;
  }
});

更多关于窗口函数的用法的详细信息，请参阅 Flink 文档。