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 2b1a9de [FLINK-25132][connector/kafka] Move record deserializing from SplitFetcher to RecordEmitter to support object-reusing deserializer add 74ed032 [FLINK-25365][python] Remove remaining references to planner from Python No new revisions were added by this update. Summary of changes: flink-python/pom.xml | 13 +- .../datastream/stream_execution_environment.py | 2 +- flink-python/pyflink/table/table_environment.py | 4 +- .../flink/api/common/python/PythonBridgeUtils.java | 63 +-- .../flink/streaming/api/utils/ProtoUtils.java | 15 +- .../AbstractPythonStreamAggregateOperator.java | 8 +- ...AbstractPythonStreamGroupAggregateOperator.java | 4 +- .../PythonStreamGroupAggregateOperator.java | 4 +- .../PythonStreamGroupTableAggregateOperator.java | 4 +- .../PythonStreamGroupWindowAggregateOperator.java | 10 +- .../utils/python/PythonInputFormatTableSource.java | 68 +++ .../flink/table/utils/python/PythonTableUtils.java | 535 +++++++++++++++++++++ ...ghPythonStreamGroupWindowAggregateOperator.java | 4 +- .../PythonStreamGroupAggregateOperatorTest.java | 4 +- ...ythonStreamGroupTableAggregateOperatorTest.java | 4 +- .../stream/StreamExecPythonGroupAggregate.java | 13 +- .../StreamExecPythonGroupTableAggregate.java | 13 +- .../StreamExecPythonGroupWindowAggregate.java | 17 +- .../plan/nodes/exec/utils/CommonPythonUtil.java | 111 ++++- .../table/planner/typeutils/DataViewUtils.java | 117 +---- .../codegen/agg/AggsHandlerCodeGenerator.scala | 3 +- .../planner/codegen/agg/ImperativeAggCodeGen.scala | 2 +- .../table/planner/plan/utils/AggregateUtil.scala | 2 +- .../table/planner/plan/utils/aggregation.scala | 3 +- .../planner/typeutils/LegacyDataViewUtils.scala | 2 +- .../planner/utils/python/PythonTableUtils.scala | 476 ------------------ .../table/planner/codegen/agg/AggTestBase.scala | 2 +- .../plan/stream/table/PythonAggregateTest.scala | 2 +- .../flink/table/runtime/dataview/DataViewSpec.java | 35 +- .../flink/table/runtime/dataview/ListViewSpec.java | 59 +++ .../flink/table/runtime/dataview/MapViewSpec.java | 80 +++ 31 files changed, 923 insertions(+), 756 deletions(-) create mode 100644 flink-python/src/main/java/org/apache/flink/table/utils/python/PythonInputFormatTableSource.java create mode 100644 flink-python/src/main/java/org/apache/flink/table/utils/python/PythonTableUtils.java delete mode 100644 flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/utils/python/PythonTableUtils.scala copy flink-end-to-end-tests/flink-tpcds-test/src/main/java/org/apache/flink/table/tpcds/schema/Column.java => flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/dataview/DataViewSpec.java (59%) create mode 100644 flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/dataview/ListViewSpec.java create mode 100644 flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/dataview/MapViewSpec.java