[flink] branch master updated (82b709f -> 91fcd83)

[he...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

hequn pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 82b709f  [FLINK-16057][runtime] chain ContinuousFileReaderOperator by default (HEAD)
     add 91fcd83  [FLINK-15961][table-planner][table-planner-blink] Add physical Python Correlate rules and RelNodes

No new revisions were added by this update.

Summary of changes:
 .../batch/BatchExecPythonCorrelateRule.java        | 127 ++++++++++++++++++
 .../stream/StreamExecPythonCorrelateRule.java      | 135 ++++++++++++++++++++
 .../nodes/physical/batch/BatchExecCorrelate.scala  | 142 +++------------------
 ...orrelate.scala => BatchExecCorrelateBase.scala} |  61 ++-------
 .../BatchExecPythonCorrelate.scala}                |  71 ++++++-----
 .../physical/stream/StreamExecCorrelate.scala      |  75 +++--------
 ...rrelate.scala => StreamExecCorrelateBase.scala} |  61 ++-------
 ...nCalc.scala => StreamExecPythonCorrelate.scala} |  65 +++++-----
 .../planner/plan/rules/FlinkBatchRuleSets.scala    |   1 +
 .../planner/plan/rules/FlinkStreamRuleSets.scala   |   1 +
 .../physical/batch/BatchExecCorrelateRule.scala    |  11 +-
 .../physical/stream/StreamExecCorrelateRule.scala  |  26 ++--
 .../table/planner/plan/utils/PythonUtil.scala      |   3 +-
 .../planner/plan/batch/table/CorrelateTest.xml     |  15 +++
 .../planner/plan/stream/table/CorrelateTest.xml    |  15 +++
 .../planner/plan/batch/table/CorrelateTest.scala   |  13 +-
 .../planner/plan/stream/table/CorrelateTest.scala  |  13 +-
 .../planner/utils/UserDefinedTableFunctions.scala  |  13 ++
 .../datastream/DataStreamPythonCorrelateRule.java  | 129 +++++++++++++++++++
 .../nodes/datastream/DataStreamCorrelate.scala     |  40 ++----
 ...rrelate.scala => DataStreamCorrelateBase.scala} |  94 +-------------
 ...egate.scala => DataStreamPythonCorrelate.scala} |  69 +++++-----
 .../flink/table/plan/rules/FlinkRuleSets.scala     |   3 +-
 .../rules/datastream/DataStreamCorrelateRule.scala |  10 +-
 .../apache/flink/table/plan/util/PythonUtil.scala  |   3 +-
 .../table/api/stream/table/CorrelateTest.scala     |  21 +++
 .../table/utils/UserDefinedTableFunctions.scala    |  13 ++
 27 files changed, 708 insertions(+), 522 deletions(-)
 create mode 100644 flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/physical/batch/BatchExecPythonCorrelateRule.java
 create mode 100644 flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/physical/stream/StreamExecPythonCorrelateRule.java
 copy flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/{BatchExecCorrelate.scala => BatchExecCorrelateBase.scala} (85%)
 copy flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/{stream/StreamExecPythonCalc.scala => batch/BatchExecPythonCorrelate.scala} (50%)
 copy flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/{StreamExecCorrelate.scala => StreamExecCorrelateBase.scala} (71%)
 copy flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/{StreamExecPythonCalc.scala => StreamExecPythonCorrelate.scala} (58%)
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/plan/rules/datastream/DataStreamPythonCorrelateRule.java
 copy flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/datastream/{DataStreamCorrelate.scala => DataStreamCorrelateBase.scala} (50%)
 copy flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/datastream/{DataStreamGroupWindowAggregate.scala => DataStreamPythonCorrelate.scala} (55%)