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 2aa598b [FLINK-20679][tests] Remove unstable test
JobMasterTest.testSlotRequestTimeoutWhenNoSlotOffering
add 467a0d1 [FLINK-20616][python] Support row-based operation to accept
user-defined function directly
No new revisions were added by this update.
Summary of changes:
.../pyflink/fn_execution/flink_fn_execution_pb2.py | 140 +++++++-------
.../pyflink/fn_execution/operation_utils.py | 23 ++-
flink-python/pyflink/java_gateway.py | 2 +-
.../pyflink/proto/flink-fn-execution.proto | 6 +
flink-python/pyflink/table/expressions.py | 6 +-
flink-python/pyflink/table/table.py | 202 ++++++++++++++++++++-
flink-python/pyflink/table/table_environment.py | 6 +-
.../table/tests/test_row_based_operation.py | 87 ++++-----
flink-python/pyflink/table/udf.py | 14 +-
.../streaming/api/utils/PythonOperatorUtils.java | 2 +
.../client/gateway/local/ExecutionContextTest.java | 2 +-
.../functions/python/PythonAggregateFunction.java | 8 +
.../table/functions/python/PythonFunction.java | 7 +
.../functions/python/PythonScalarFunction.java | 8 +
.../python/PythonTableAggregateFunction.java | 8 +
.../functions/python/PythonTableFunction.java | 8 +
16 files changed, 403 insertions(+), 126 deletions(-)
