dianfu commented on a change in pull request #13475:
URL: https://github.com/apache/flink/pull/13475#discussion_r494761634
##########
File path: flink-python/pyflink/fn_execution/beam/beam_operations_fast.pyx
##########
@@ -192,6 +194,108 @@ cdef class
PandasAggregateFunctionOperation(BeamStatelessFunctionOperation):
return generate_func, user_defined_funcs
+cdef class
PandasBatchOverWindowAggregateFunctionOperation(BeamStatelessFunctionOperation):
Review comment:
It seems to me that most code of beam_operations_fast and
beam_operation_slow are the same. Is it possible to avoid the duplication?
PS: This is not an issue introduced in this PR. We could also address it in
a separate if it's possible.
----------------------------------------------------------------
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:
[email protected]
