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/22 07:53:23 UTC
[flink] branch master updated (2b1a9de -> 74ed032)

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