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 02a61e6af2a [hotfix][ci] Bump `github-script` to v9 in `action.yml`
add 696e6b2c63e [FLINK-40199][python] Add generic DataFrame I/O methods
(#28974)
No new revisions were added by this update.
Summary of changes:
.../docs/reference/pyflink.dataframe/index.rst | 1 +
.../serializer.rst => pyflink.dataframe/io.rst} | 32 +--
flink-python/pyflink/dataframe/__init__.py | 2 +
flink-python/pyflink/dataframe/dataframe.py | 41 +++
flink-python/pyflink/dataframe/io.py | 192 +++++++++++++
flink-python/pyflink/dataframe/tests/test_io.py | 311 +++++++++++++++++++++
6 files changed, 561 insertions(+), 18 deletions(-)
copy flink-python/docs/reference/{pyflink.common/serializer.rst =>
pyflink.dataframe/io.rst} (69%)
create mode 100644 flink-python/pyflink/dataframe/io.py
create mode 100644 flink-python/pyflink/dataframe/tests/test_io.py
