You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2018/12/07 04:08:00 UTC

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

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)