ImportError with current Apache Beam version (2.x)

Open de-code opened this issue 8 years ago • 1 comments

Thank you for providing the package.

The following import is failing:

from apache_beam.io import fileio

You are only using fileio for the CompressionType.

The correct import would be:

from apache_beam.io.filesystem import CompressionTypes

(are you still actively developing this package? I'd be happy to add more struff from my local beam_utils if you do)

Nov 28 '17 19:11 de-code

ping @pabloem?

Dec 27 '22 08:12 bfontaine