This is an automated email from the ASF dual-hosted git repository.
tvalentyn pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from df055c1 Support multilayer ZetaSQL UNNEST (#14342)
add 2c619c8 [BEAM-7372] delete codes for compatibility of py2 from
apache_beam/io except for io/gcp (#14352)
No new revisions were added by this update.
Summary of changes:
sdks/python/apache_beam/io/__init__.py | 2 -
sdks/python/apache_beam/io/avroio.py | 3 -
sdks/python/apache_beam/io/avroio_test.py | 6 --
sdks/python/apache_beam/io/aws/__init__.py | 2 -
sdks/python/apache_beam/io/aws/clients/__init__.py | 1 -
.../apache_beam/io/aws/clients/s3/__init__.py | 1 -
.../apache_beam/io/aws/clients/s3/boto3_client.py | 2 -
.../apache_beam/io/aws/clients/s3/fake_client.py | 2 -
.../apache_beam/io/aws/clients/s3/messages.py | 2 -
sdks/python/apache_beam/io/aws/s3filesystem.py | 8 +--
.../python/apache_beam/io/aws/s3filesystem_test.py | 2 -
sdks/python/apache_beam/io/aws/s3io.py | 3 -
sdks/python/apache_beam/io/aws/s3io_test.py | 2 -
sdks/python/apache_beam/io/azure/__init__.py | 2 -
.../apache_beam/io/azure/blobstoragefilesystem.py | 6 +-
.../io/azure/blobstoragefilesystem_test.py | 4 --
sdks/python/apache_beam/io/azure/blobstorageio.py | 3 -
.../apache_beam/io/azure/blobstorageio_test.py | 2 -
sdks/python/apache_beam/io/concat_source.py | 4 --
sdks/python/apache_beam/io/concat_source_test.py | 4 --
sdks/python/apache_beam/io/external/__init__.py | 2 -
.../python/apache_beam/io/external/gcp/__init__.py | 2 -
sdks/python/apache_beam/io/external/gcp/pubsub.py | 18 +++---
.../apache_beam/io/external/generate_sequence.py | 2 -
.../io/external/generate_sequence_test.py | 3 -
sdks/python/apache_beam/io/external/kafka.py | 2 -
sdks/python/apache_beam/io/external/snowflake.py | 2 -
.../io/external/xlang_jdbcio_it_test.py | 6 +-
.../io/external/xlang_kafkaio_it_test.py | 2 -
.../io/external/xlang_kinesisio_it_test.py | 2 -
.../io/external/xlang_parquetio_test.py | 3 -
.../io/external/xlang_snowflakeio_it_test.py | 2 -
sdks/python/apache_beam/io/filebasedsink.py | 17 ++----
sdks/python/apache_beam/io/filebasedsink_test.py | 5 --
sdks/python/apache_beam/io/filebasedsource.py | 13 ++--
sdks/python/apache_beam/io/filebasedsource_test.py | 7 ---
sdks/python/apache_beam/io/fileio.py | 6 +-
sdks/python/apache_beam/io/fileio_test.py | 2 -
sdks/python/apache_beam/io/filesystem.py | 15 +----
sdks/python/apache_beam/io/filesystem_test.py | 7 +--
sdks/python/apache_beam/io/filesystemio.py | 9 +--
sdks/python/apache_beam/io/filesystemio_test.py | 3 -
sdks/python/apache_beam/io/filesystems.py | 7 +--
sdks/python/apache_beam/io/filesystems_test.py | 4 --
sdks/python/apache_beam/io/flink/__init__.py | 2 -
.../io/flink/flink_streaming_impulse_source.py | 2 -
.../flink/flink_streaming_impulse_source_test.py | 2 -
sdks/python/apache_beam/io/hadoopfilesystem.py | 3 -
.../python/apache_beam/io/hadoopfilesystem_test.py | 8 +--
sdks/python/apache_beam/io/iobase.py | 5 --
sdks/python/apache_beam/io/iobase_test.py | 2 -
sdks/python/apache_beam/io/jdbc.py | 22 +++----
sdks/python/apache_beam/io/kafka.py | 18 +++---
sdks/python/apache_beam/io/kinesis.py | 32 +++++-----
sdks/python/apache_beam/io/localfilesystem.py | 3 -
sdks/python/apache_beam/io/localfilesystem_test.py | 4 --
sdks/python/apache_beam/io/mongodbio.py | 3 -
sdks/python/apache_beam/io/mongodbio_it_test.py | 2 -
sdks/python/apache_beam/io/mongodbio_test.py | 3 -
sdks/python/apache_beam/io/parquetio.py | 2 -
sdks/python/apache_beam/io/parquetio_it_test.py | 3 -
sdks/python/apache_beam/io/parquetio_test.py | 2 -
sdks/python/apache_beam/io/range_trackers.py | 12 +---
sdks/python/apache_beam/io/range_trackers_test.py | 7 +--
sdks/python/apache_beam/io/restriction_trackers.py | 4 --
.../apache_beam/io/restriction_trackers_test.py | 2 -
sdks/python/apache_beam/io/snowflake.py | 70 ++++++++++------------
sdks/python/apache_beam/io/source_test_utils.py | 6 --
.../apache_beam/io/source_test_utils_test.py | 3 -
sdks/python/apache_beam/io/sources_test.py | 2 -
sdks/python/apache_beam/io/textio.py | 8 +--
sdks/python/apache_beam/io/textio_test.py | 4 --
sdks/python/apache_beam/io/tfrecordio.py | 3 -
sdks/python/apache_beam/io/tfrecordio_test.py | 5 --
sdks/python/apache_beam/io/utils.py | 4 --
sdks/python/apache_beam/io/utils_test.py | 2 -
sdks/python/apache_beam/io/watermark_estimators.py | 2 -
.../apache_beam/io/watermark_estimators_test.py | 2 -
78 files changed, 97 insertions(+), 359 deletions(-)
