You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by di...@apache.org on 2020/02/17 08:16:46 UTC
[flink] branch master updated (8887290 -> 85794f7)
This is an automated email from the ASF dual-hosted git repository.
dianfu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 8887290 [hotfix][docs] Regenerate documentation
add 85794f7 [FLINK-16109][python] Move the Python scalar operators and table operators to separate package
No new revisions were added by this update.
Summary of changes:
.../flink/python/AbstractPythonFunctionRunner.java | 46 ++--------
.../python/PythonScalarFunctionFlatMap.java | 2 +-
.../python/AbstractStatelessFunctionOperator.java | 8 +-
...stractBaseRowPythonScalarFunctionOperator.java} | 55 +-----------
.../AbstractPythonScalarFunctionOperator.java | 3 +-
.../AbstractRowPythonScalarFunctionOperator.java} | 49 ++---------
.../BaseRowPythonScalarFunctionOperator.java | 73 +---------------
.../{ => scalar}/PythonScalarFunctionOperator.java | 45 +---------
.../AbstractPythonTableFunctionOperator.java | 3 +-
.../BaseRowPythonTableFunctionOperator.java | 4 +-
.../{ => table}/PythonTableFunctionOperator.java | 4 +-
.../AbstractPythonStatelessFunctionRunner.java | 6 +-
.../AbstractGeneralPythonScalarFunctionRunner.java | 99 ++++++++++++++++++++++
.../AbstractPythonScalarFunctionRunner.java | 15 ++--
.../BaseRowPythonScalarFunctionRunner.java | 4 +-
.../{ => scalar}/PythonScalarFunctionRunner.java | 4 +-
.../AbstractPythonTableFunctionRunner.java | 50 ++++++++++-
.../BaseRowPythonTableFunctionRunner.java | 2 +-
.../{ => table}/PythonTableFunctionRunner.java | 2 +-
.../BaseRowPythonScalarFunctionOperatorTest.java | 2 +-
.../PassThroughPythonFunctionRunner.java | 2 +-
.../PassThroughPythonTableFunctionRunner.java | 6 +-
.../PythonScalarFunctionOperatorTest.java | 2 +-
.../PythonScalarFunctionOperatorTestBase.java | 4 +-
.../BaseRowPythonTableFunctionOperatorTest.java | 3 +-
.../PythonTableFunctionOperatorTest.java | 3 +-
.../PythonTableFunctionOperatorTestBase.java | 4 +-
.../AbstractPythonScalarFunctionRunnerTest.java | 14 +--
.../BaseRowPythonScalarFunctionRunnerTest.java | 13 ++-
.../scalar}/PythonScalarFunctionRunnerTest.java | 17 ++--
.../AbstractPythonTableFunctionRunnerTest.java | 5 +-
.../BaseRowPythonTableFunctionRunnerTest.java | 5 +-
.../table}/PythonTableFunctionRunnerTest.java | 6 +-
.../typeutils}/PythonTypeUtilsTest.java | 4 +-
.../plan/nodes/common/CommonPythonCalc.scala | 2 +-
.../nodes/datastream/DataStreamPythonCalc.scala | 2 +-
36 files changed, 247 insertions(+), 321 deletions(-)
copy flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/{BaseRowPythonScalarFunctionOperator.java => scalar/AbstractBaseRowPythonScalarFunctionOperator.java} (68%)
rename flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/{ => scalar}/AbstractPythonScalarFunctionOperator.java (95%)
copy flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/{PythonScalarFunctionOperator.java => scalar/AbstractRowPythonScalarFunctionOperator.java} (63%)
rename flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/{ => scalar}/BaseRowPythonScalarFunctionOperator.java (54%)
rename flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/{ => scalar}/PythonScalarFunctionOperator.java (64%)
rename flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/{ => table}/AbstractPythonTableFunctionOperator.java (95%)
rename flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/{ => table}/BaseRowPythonTableFunctionOperator.java (97%)
rename flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/{ => table}/PythonTableFunctionOperator.java (97%)
create mode 100644 flink-python/src/main/java/org/apache/flink/table/runtime/runners/python/scalar/AbstractGeneralPythonScalarFunctionRunner.java
rename flink-python/src/main/java/org/apache/flink/table/runtime/runners/python/{ => scalar}/AbstractPythonScalarFunctionRunner.java (89%)
rename flink-python/src/main/java/org/apache/flink/table/runtime/runners/python/{ => scalar}/BaseRowPythonScalarFunctionRunner.java (92%)
rename flink-python/src/main/java/org/apache/flink/table/runtime/runners/python/{ => scalar}/PythonScalarFunctionRunner.java (92%)
rename flink-python/src/main/java/org/apache/flink/table/runtime/runners/python/{ => table}/AbstractPythonTableFunctionRunner.java (73%)
rename flink-python/src/main/java/org/apache/flink/table/runtime/runners/python/{ => table}/BaseRowPythonTableFunctionRunner.java (97%)
rename flink-python/src/main/java/org/apache/flink/table/runtime/runners/python/{ => table}/PythonTableFunctionRunner.java (97%)
rename flink-python/src/test/java/org/apache/flink/table/runtime/operators/python/{ => scalar}/BaseRowPythonScalarFunctionOperatorTest.java (98%)
rename flink-python/src/test/java/org/apache/flink/table/runtime/operators/python/{ => scalar}/PassThroughPythonFunctionRunner.java (97%)
rename flink-python/src/test/java/org/apache/flink/table/runtime/operators/python/{ => scalar}/PassThroughPythonTableFunctionRunner.java (92%)
rename flink-python/src/test/java/org/apache/flink/table/runtime/operators/python/{ => scalar}/PythonScalarFunctionOperatorTest.java (98%)
rename flink-python/src/test/java/org/apache/flink/table/runtime/operators/python/{ => scalar}/PythonScalarFunctionOperatorTestBase.java (98%)
rename flink-python/src/test/java/org/apache/flink/table/runtime/operators/python/{ => table}/BaseRowPythonTableFunctionOperatorTest.java (96%)
rename flink-python/src/test/java/org/apache/flink/table/runtime/operators/python/{ => table}/PythonTableFunctionOperatorTest.java (95%)
rename flink-python/src/test/java/org/apache/flink/table/runtime/operators/python/{ => table}/PythonTableFunctionOperatorTestBase.java (98%)
rename flink-python/src/test/java/org/apache/flink/table/{functions/python => runtime/runners/python/scalar}/AbstractPythonScalarFunctionRunnerTest.java (86%)
rename flink-python/src/test/java/org/apache/flink/table/{functions/python => runtime/runners/python/scalar}/BaseRowPythonScalarFunctionRunnerTest.java (85%)
rename flink-python/src/test/java/org/apache/flink/table/{functions/python => runtime/runners/python/scalar}/PythonScalarFunctionRunnerTest.java (93%)
rename flink-python/src/test/java/org/apache/flink/table/{functions/python => runtime/runners/python/table}/AbstractPythonTableFunctionRunnerTest.java (88%)
rename flink-python/src/test/java/org/apache/flink/table/{functions/python => runtime/runners/python/table}/BaseRowPythonTableFunctionRunnerTest.java (92%)
rename flink-python/src/test/java/org/apache/flink/table/{functions/python => runtime/runners/python/table}/PythonTableFunctionRunnerTest.java (95%)
rename flink-python/src/test/java/org/apache/flink/table/{functions/python => runtime/typeutils}/PythonTypeUtilsTest.java (95%)