apache_beam.runners.dataflow.ptransform_overrides module¶
Ptransform overrides for DataflowRunner.
-
class
apache_beam.runners.dataflow.ptransform_overrides.
NativeReadPTransformOverride
[source]¶ Bases:
apache_beam.pipeline.PTransformOverride
A
PTransformOverride
forRead
using native sources.The DataflowRunner expects that the Read PTransform using native sources act as a primitive. So this override replaces the Read with a primitive.