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 0cc7aae [FLINK-13553][tests] Enable TRACE logging for
org.apache.flink.queryablestate
add 6186069 [FLINK-17303][python] Return TableResult for Python
TableEnvironment
No new revisions were added by this update.
Summary of changes:
flink-python/pyflink/common/__init__.py | 8 +
flink-python/pyflink/common/completable_future.py | 63 ++++++++
flink-python/pyflink/common/execution_mode.py | 2 +-
flink-python/pyflink/common/job_client.py | 114 ++++++++++++++
.../pyflink/common/job_execution_result.py | 3 +-
.../{table/explain_detail.py => common/job_id.py} | 23 +--
flink-python/pyflink/common/job_status.py | 167 +++++++++++++++++++++
flink-python/pyflink/table/__init__.py | 48 +++---
.../result_kind.py} | 41 +++--
flink-python/pyflink/table/table_environment.py | 4 +-
flink-python/pyflink/table/table_result.py | 69 +++++++++
flink-python/pyflink/table/tests/test_sql.py | 47 +++++-
12 files changed, 537 insertions(+), 52 deletions(-)
create mode 100644 flink-python/pyflink/common/completable_future.py
create mode 100644 flink-python/pyflink/common/job_client.py
copy flink-python/pyflink/{table/explain_detail.py => common/job_id.py} (64%)
create mode 100644 flink-python/pyflink/common/job_status.py
copy flink-python/pyflink/{pyflink_callback_server.py => table/result_kind.py}
(52%)
create mode 100644 flink-python/pyflink/table/table_result.py
