[jira] [Created] (FLINK-11090) Unused parameter in WindowedStream.aggregate()

[Shang Yuanchun (Jira)]

Hequn Cheng created FLINK-11090:
-----------------------------------

             Summary: Unused parameter in WindowedStream.aggregate()
                 Key: FLINK-11090
                 URL: https://issues.apache.org/jira/browse/FLINK-11090
             Project: Flink
          Issue Type: Improvement
          Components: DataStream API
            Reporter: Hequn Cheng
            Assignee: Hequn Cheng


The {{aggregateResultType}} parameter in {{WindowedStream.aggregate()}} seems useless. Or what have I missed?

If it is useless, I prefer to remove the parameter by adding a new API and deprecate the current one. We can't remove it directly as it is PublicEvolving.
{code:java}
        @PublicEvolving
        public <ACC, V, R> SingleOutputStreamOperator<R> aggregate(
                        AggregateFunction<T, ACC, V> aggregateFunction,
                        ProcessWindowFunction<V, R, K, W> windowFunction,
                        TypeInformation<ACC> accumulatorType,
                        TypeInformation<V> aggregateResultType,
                        TypeInformation<R> resultType) {
        }
{code}



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)