You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by he...@apache.org on 2020/05/14 14:07:12 UTC
[flink] branch master updated (b51101b -> 381131a)
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 b51101b [FLINK-15138][e2e][python] Add PyFlink e2e tests
add 381131a [FLINK-17303][python] Support Python TableResult
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 | 60 +++++++-
12 files changed, 550 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