apache_beam.portability.api.org.apache.beam.model.fn_execution.v1.beam_fn_api_pb2_urns module
-
class apache_beam.portability.api.org.apache.beam.model.fn_execution.v1.beam_fn_api_pb2_urns.FnApiTransforms[source]
Bases: object
-
class Runner[source]
Bases: object
-
DATA_SOURCE = ('beam:runner:source:v1', '', , )
-
DATA_SINK = ('beam:runner:sink:v1', '', , )