You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tw...@apache.org on 2021/12/20 16:18:32 UTC
[flink] branch master updated (cdf3d48 -> 2e355d9)
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(-)