What happened?
Currently, Python fileio.MatchAll takes a PCollection<string> as input as opposed to a PCollection<Row>. We should update Python/YAML code so that this transform is usable by Beam YAML.
[1]
|
class MatchAll(beam.PTransform): |
Issue Priority
Priority: 1 (data loss / total loss of function)
Issue Components
What happened?
Currently, Python
fileio.MatchAlltakes aPCollection<string>as input as opposed to aPCollection<Row>. We should update Python/YAML code so that this transform is usable by Beam YAML.[1]
beam/sdks/python/apache_beam/io/fileio.py
Line 198 in e08e9d5
Issue Priority
Priority: 1 (data loss / total loss of function)
Issue Components