在Beam中，可以通過使用Windowing和Aggregation來實現數據的窗口化和聚合操作。
示例代碼：
PCollection<Integer> input = ...;
PCollection<Integer> windowedData = input.apply(
Window.into(FixedWindows.of(Duration.standardMinutes(5))));
示例代碼：
PCollection<Integer> windowedData = ...;
PCollection<Integer> aggregatedData = windowedData.apply(
Combine.globally(Sum.integersFn()));
通過結合窗口化和聚合操作，可以實現對數據流的靈活處理和計算。Beam還支持用戶自定義的窗口函數和聚合函數，可以根據具體需求進行定制化操作。
