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 f765ad0 [FLINK-16727][table-planner-blink] Fix cast exception when
having time point literal as parameters
add ea1d15c [FLINK-16672][python] Support Counter, Gauge, Meter,
Distribution metric type for Python UDF (#11543)
No new revisions were added by this update.
Summary of changes:
flink-python/docs/index.rst | 1 +
.../{pyflink.dataset.rst => pyflink.metrics.rst} | 4 +-
flink-python/pom.xml | 11 +
.../pyflink/fn_execution/flink_fn_execution_pb2.py | 67 +++---
flink-python/pyflink/fn_execution/operations.py | 43 +++-
flink-python/pyflink/metrics/__init__.py | 4 +-
flink-python/pyflink/metrics/metricbase.py | 117 ++++++++++
flink-python/pyflink/metrics/tests/test_metric.py | 57 +++++
.../pyflink/proto/flink-fn-execution.proto | 1 +
flink-python/pyflink/shell.py | 3 +
flink-python/pyflink/table/tests/test_udf.py | 16 +-
flink-python/pyflink/table/udf.py | 3 +
flink-python/setup.py | 4 +
.../flink/python/AbstractPythonFunctionRunner.java | 27 ++-
.../flink/python/metric/FlinkMetricContainer.java | 250 ++++++++++++++++++++-
.../scalar/AbstractPythonScalarFunctionRunner.java | 1 +
.../python/metric/FlinkMetricContainerTest.java | 218 ++++++++++++++++++
17 files changed, 774 insertions(+), 53 deletions(-)
copy flink-python/docs/{pyflink.dataset.rst => pyflink.metrics.rst} (95%)
create mode 100644
flink-python/src/test/java/org/apache/flink/python/metric/FlinkMetricContainerTest.java
