我需要在Flink有一个聚集窗口。我不能使用聚合函数。因为getresult计算需要状态访问。所以我试着用聚合和过程：

.aggregate( 
    new AggregateFunction<Entry, Double, Double>() {
                       ...........
                    };
            , new ProcessWindowFunction<Double,Result,Entry,TimeWindow>() {

                @Override
                public void process(Entry item,
                        ProcessWindowFunction<Double, Result, Entry, TimeWindow>.Context ctx,
                        Iterable<Double> aggInput, Collector<Result> output) throws Exception {

                }

    }

但是，我仍然只需要agginput的最新值，而且我不认为有理由将其保存在内存中，在我的应用程序中，它可能是数以百万计的数据。所以我想如果我能清除每次窗口的数据。