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=)