HuangXingBo commented on a change in pull request #14389:
URL: https://github.com/apache/flink/pull/14389#discussion_r544067798
##########
File path:
flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/aggregate/PythonStreamGroupTableAggregateOperator.java
##########
@@ -39,30 +37,19 @@
@VisibleForTesting
protected static final String STREAM_GROUP_TABLE_AGGREGATE_URN =
"flink:transform:stream_group_table_aggregate:v1";
- private final PythonAggregateFunctionInfo aggregateFunction;
-
- private final DataViewUtils.DataViewSpec[] dataViewSpecs;
-
public PythonStreamGroupTableAggregateOperator(
Configuration config,
RowType inputType,
RowType outputType,
- PythonAggregateFunctionInfo aggregateFunction,
Review comment:
When there are multiple flat_maps, an additional
PythonAggregateFunctionInfo of count(*) will be added to handle the situation
of retract.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
