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', '', , )