Details
-
Improvement
-
Status: Resolved
-
P2
-
Resolution: Fixed
-
None
-
None
Description
Python AvroSource [1] currently only support 'deflate' compression. We should update it to support other compression types supported by the Avro library (e.g.: snappy, bzip2).
[1] https://github.com/apache/incubator-beam/blob/python-sdk/sdks/python/apache_beam/io/avroio.py