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)
