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/03/26 12:50:47 UTC
[flink] branch master updated (6b78fe0 -> cb67adc)

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 6b78fe0  [FLINK-16790][python][doc] Enables the interpretation of backslash escapes (#11526)
     add cb67adc  [FLINK-16671][python] Support for defining scopes on Python metric group (#11470)

No new revisions were added by this update.

Summary of changes:
 docs/_includes/generated/python_configuration.html |  6 ++
 flink-python/pyflink/fn_execution/operations.py    |  5 +-
 .../{setup.cfg => pyflink/metrics/__init__.py}     |  6 +-
 flink-python/pyflink/metrics/metricbase.py         | 78 ++++++++++++++++++++++
 .../pyflink/{util => metrics/tests}/__init__.py    |  0
 .../pyflink/metrics/tests/test_metric.py           | 37 +++++-----
 flink-python/pyflink/table/udf.py                  |  8 ++-
 flink-python/setup.py                              |  2 +
 .../flink/python/AbstractPythonFunctionRunner.java | 12 +++-
 .../java/org/apache/flink/python/PythonConfig.java | 10 +++
 .../org/apache/flink/python/PythonOptions.java     |  9 +++
 .../flink/python/metric/FlinkMetricContainer.java  | 19 +++---
 .../python/AbstractPythonFunctionOperator.java     |  6 ++
 .../python/PythonScalarFunctionFlatMap.java        |  9 ++-
 .../BaseRowPythonScalarFunctionOperator.java       |  3 +-
 .../scalar/PythonScalarFunctionOperator.java       |  3 +-
 .../arrow/ArrowPythonScalarFunctionOperator.java   |  3 +-
 .../BaseRowArrowPythonScalarFunctionOperator.java  |  3 +-
 .../table/BaseRowPythonTableFunctionOperator.java  |  3 +-
 .../python/table/PythonTableFunctionOperator.java  |  3 +-
 .../AbstractPythonStatelessFunctionRunner.java     |  6 +-
 .../AbstractGeneralPythonScalarFunctionRunner.java |  6 +-
 .../scalar/AbstractPythonScalarFunctionRunner.java |  7 +-
 .../scalar/BaseRowPythonScalarFunctionRunner.java  |  6 +-
 .../python/scalar/PythonScalarFunctionRunner.java  |  6 +-
 .../AbstractArrowPythonScalarFunctionRunner.java   |  6 +-
 .../arrow/ArrowPythonScalarFunctionRunner.java     |  6 +-
 .../BaseRowArrowPythonScalarFunctionRunner.java    |  6 +-
 .../table/AbstractPythonTableFunctionRunner.java   |  6 +-
 .../table/BaseRowPythonTableFunctionRunner.java    |  6 +-
 .../python/table/PythonTableFunctionRunner.java    |  6 +-
 .../org/apache/flink/python/PythonOptionsTest.java | 13 ++++
 .../BaseRowPythonScalarFunctionOperatorTest.java   |  4 +-
 .../scalar/PythonScalarFunctionOperatorTest.java   |  4 +-
 .../ArrowPythonScalarFunctionOperatorTest.java     |  4 +-
 ...seRowArrowPythonScalarFunctionOperatorTest.java |  4 +-
 .../BaseRowPythonScalarFunctionRunnerTest.java     |  4 +-
 .../scalar/PythonScalarFunctionRunnerTest.java     |  7 +-
 .../arrow/ArrowPythonScalarFunctionRunnerTest.java |  4 +-
 .../BaseRowPythonTableFunctionRunnerTest.java      |  4 +-
 .../table/PythonTableFunctionRunnerTest.java       | 13 ++--
 ...PassThroughArrowPythonScalarFunctionRunner.java | 11 +--
 .../PassThroughPythonScalarFunctionRunner.java     | 11 +--
 .../flink/table/runtime/utils/PythonTestUtils.java | 13 ++++
 44 files changed, 300 insertions(+), 88 deletions(-)
 copy flink-python/{setup.cfg => pyflink/metrics/__init__.py} (92%)
 create mode 100644 flink-python/pyflink/metrics/metricbase.py
 copy flink-python/pyflink/{util => metrics/tests}/__init__.py (100%)
 copy flink-contrib/docker-flink/remove-docker-swarm-service.sh => flink-python/pyflink/metrics/tests/test_metric.py (54%)
 mode change 100755 => 100644
 copy flink-core/src/main/java/org/apache/flink/core/memory/MemoryType.java => flink-python/src/main/java/org/apache/flink/python/metric/FlinkMetricContainer.java (71%)