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 = PropertiesFromEnumValue(urn='beam:runner:source:v1', constant='', spec=, label_props=)
DATA_SINK = PropertiesFromEnumValue(urn='beam:runner:sink:v1', constant='', spec=, label_props=)