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 cc6d1a27baf [FLINK-27321][ci] Migrate java-ci-tools to JUnit 5
add bdd91141658 [examples][python] Add examples on how to use
json/csv/avro formats in Python DataStream API
No new revisions were added by this update.
Summary of changes:
.../examples/datastream/formats}/__init__.py | 0
.../examples/datastream/formats/avro_format.py | 91 ++++++++++++++++++++++
.../examples/datastream/formats/csv_format.py | 72 +++++++++++++++++
.../examples/datastream/formats/json_format.py | 73 +++++++++++++++++
4 files changed, 236 insertions(+)
copy {flink-end-to-end-tests/flink-python-test/python/datastream =>
flink-python/pyflink/examples/datastream/formats}/__init__.py (100%)
create mode 100644
flink-python/pyflink/examples/datastream/formats/avro_format.py
create mode 100644
flink-python/pyflink/examples/datastream/formats/csv_format.py
create mode 100644
flink-python/pyflink/examples/datastream/formats/json_format.py
