沿着AggregateFunction之外，您还可以选择指定WindowFunction。
根据文档，您可以执行以下操作：

stream.
.keyBy()
.window()
.aggregate(new AverageAggregate(), new WindowFunctionTest());

public static class WindowFunctionTest implements WindowFunction<..., ..., 
    Tuple, TimeWindow> {
    public void apply(Tuple key, TimeWindow window, Iterable<...> input, 
    Collector<...> out) {
        long windowStartTime = window.getStart();
    }

我发现ElementConverter中的SinkWriter.Context有窗口和水印时间戳，我只需要写入接收器时的时间戳，所以这对我来说已经足够了。