This is an automated email from the ASF dual-hosted git repository. twalthr pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git.
from cdf3d48 [FLINK-21406][parquet] Add AvroParquetReaders to read parquet files into Avro types. add 2e355d9 [FLINK-25364][python][table-planner] Remove dependency on planner for Python code generation No new revisions were added by this update. Summary of changes: .../python/AbstractStatelessFunctionOperator.java | 34 ++------- .../AbstractPythonStreamAggregateOperator.java | 8 +-- ...stractArrowPythonAggregateFunctionOperator.java | 36 ++++------ ...tBatchArrowPythonAggregateFunctionOperator.java | 55 ++++++--------- ...hArrowPythonGroupAggregateFunctionOperator.java | 25 +++---- ...PythonGroupWindowAggregateFunctionOperator.java | 29 +++----- ...wPythonOverWindowAggregateFunctionOperator.java | 29 ++++---- ...tractStreamArrowPythonBoundedRangeOperator.java | 13 ++-- ...stractStreamArrowPythonBoundedRowsOperator.java | 13 ++-- ...wPythonOverWindowAggregateFunctionOperator.java | 23 +++--- ...PythonGroupWindowAggregateFunctionOperator.java | 27 ++++---- ...eamArrowPythonProcTimeBoundedRangeOperator.java | 13 ++-- ...reamArrowPythonProcTimeBoundedRowsOperator.java | 13 ++-- ...reamArrowPythonRowTimeBoundedRangeOperator.java | 13 ++-- ...treamArrowPythonRowTimeBoundedRowsOperator.java | 13 ++-- .../AbstractPythonScalarFunctionOperator.java | 67 +++++------------- .../scalar/PythonScalarFunctionOperator.java | 22 ++++-- .../arrow/ArrowPythonScalarFunctionOperator.java | 20 ++++-- .../python/table/PythonTableFunctionOperator.java | 54 ++++----------- ...owPythonGroupAggregateFunctionOperatorTest.java | 61 +++++++++++----- ...onGroupWindowAggregateFunctionOperatorTest.java | 65 ++++++++++++----- ...honOverWindowAggregateFunctionOperatorTest.java | 70 +++++++++++++------ ...onGroupWindowAggregateFunctionOperatorTest.java | 47 +++++++++---- ...rrowPythonProcTimeBoundedRangeOperatorTest.java | 38 +++++++--- ...ArrowPythonProcTimeBoundedRowsOperatorTest.java | 38 +++++++--- ...ArrowPythonRowTimeBoundedRangeOperatorTest.java | 39 ++++++++--- ...mArrowPythonRowTimeBoundedRowsOperatorTest.java | 38 +++++++--- .../scalar/PythonScalarFunctionOperatorTest.java | 51 ++++++++++++-- .../ArrowPythonScalarFunctionOperatorTest.java | 51 ++++++++++++-- .../table/PythonTableFunctionOperatorTest.java | 43 +++++++++--- .../apache/flink/table/connector/Projection.java | 5 ++ .../exec/batch/BatchExecPythonGroupAggregate.java | 64 +++++++++++++---- .../batch/BatchExecPythonGroupWindowAggregate.java | 70 ++++++++++++++----- .../exec/batch/BatchExecPythonOverAggregate.java | 81 ++++++++++++++++------ .../nodes/exec/common/CommonExecPythonCalc.java | 62 +++++++++++++---- .../exec/common/CommonExecPythonCorrelate.java | 52 ++++++++++---- .../StreamExecPythonGroupWindowAggregate.java | 58 +++++++++++----- .../exec/stream/StreamExecPythonOverAggregate.java | 66 ++++++++++++------ .../plan/nodes/exec/utils/CommonPythonUtil.java | 3 +- 39 files changed, 953 insertions(+), 556 deletions(-)