You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by he...@apache.org on 2020/02/10 02:28:33 UTC
[flink] branch master updated (303b08a -> fee187e)
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 303b08a [hotfix][travis] Reduce depth for walkthrough module detection
add fee187e [FLINK-15913][python] Add Python TableFunction Runner and Operator in old planner (#11020)
No new revisions were added by this update.
Summary of changes:
.../pyflink/fn_execution/flink_fn_execution_pb2.py | 10 +-
.../pyflink/proto/flink-fn-execution.proto | 1 +
.../AbstractPythonScalarFunctionOperator.java | 142 +-----------------
.../AbstractPythonTableFunctionOperator.java | 77 ++++++++++
...java => AbstractStatelessFunctionOperator.java} | 158 ++++++++++++---------
.../BaseRowPythonScalarFunctionOperator.java | 41 +-----
.../python/PythonScalarFunctionOperator.java | 45 +-----
.../python/PythonTableFunctionOperator.java | 131 +++++++++++++++++
.../python/AbstractPythonScalarFunctionRunner.java | 152 ++------------------
... => AbstractPythonStatelessFunctionRunner.java} | 97 +++++--------
.../python/AbstractPythonTableFunctionRunner.java | 117 +++++++++++++++
...nRunner.java => PythonTableFunctionRunner.java} | 16 +--
.../table/runtime/typeutils/PythonTypeUtils.java | 9 +-
.../AbstractPythonTableFunctionRunnerTest.java | 44 ++++++
.../python/PythonTableFunctionRunnerTest.java | 147 +++++++++++++++++++
.../functions/python/PythonTypeUtilsTest.java | 3 +-
.../BaseRowPythonScalarFunctionOperatorTest.java | 2 +-
...a => PassThroughPythonTableFunctionRunner.java} | 11 +-
.../python/PythonScalarFunctionOperatorTest.java | 2 +-
...t.java => PythonTableFunctionOperatorTest.java} | 42 +++---
...va => PythonTableFunctionOperatorTestBase.java} | 130 ++++-------------
21 files changed, 743 insertions(+), 634 deletions(-)
create mode 100644 flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/AbstractPythonTableFunctionOperator.java
copy flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/{AbstractPythonScalarFunctionOperator.java => AbstractStatelessFunctionOperator.java} (59%)
create mode 100644 flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/PythonTableFunctionOperator.java
copy flink-python/src/main/java/org/apache/flink/table/runtime/runners/python/{AbstractPythonScalarFunctionRunner.java => AbstractPythonStatelessFunctionRunner.java} (77%)
create mode 100644 flink-python/src/main/java/org/apache/flink/table/runtime/runners/python/AbstractPythonTableFunctionRunner.java
copy flink-python/src/main/java/org/apache/flink/table/runtime/runners/python/{PythonScalarFunctionRunner.java => PythonTableFunctionRunner.java} (79%)
create mode 100644 flink-python/src/test/java/org/apache/flink/table/functions/python/AbstractPythonTableFunctionRunnerTest.java
create mode 100644 flink-python/src/test/java/org/apache/flink/table/functions/python/PythonTableFunctionRunnerTest.java
copy flink-python/src/test/java/org/apache/flink/table/runtime/operators/python/{PassThroughPythonFunctionRunner.java => PassThroughPythonTableFunctionRunner.java} (87%)
copy flink-python/src/test/java/org/apache/flink/table/runtime/operators/python/{PythonScalarFunctionOperatorTest.java => PythonTableFunctionOperatorTest.java} (63%)
copy flink-python/src/test/java/org/apache/flink/table/runtime/operators/python/{PythonScalarFunctionOperatorTestBase.java => PythonTableFunctionOperatorTestBase.java} (60%)