[FLINK-11090] Remove unused parameter in WindowedStream.aggregate()

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.8.0
• Component/s: API / DataStream
• Labels: pull-request-available
• Assignee: Hequn Cheng
• Reporter: Hequn Cheng
• Created: 07/Dec/18 04:07
• Updated: 15/Mar/19 11:51
• Resolved: 11/Dec/18 12:45

Description

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.

	@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) {
        }

Issue Links

• links to: GitHub Pull Request #7274