apache_beam.runners.pipeline_context module¶
Utility class for serializing pipelines via the runner API.
For internal use only; no backwards-compatibility guarantees.
-
class
apache_beam.runners.pipeline_context.
PortableObject
(*args, **kwargs)[source]¶ Bases:
typing_extensions.Protocol
-
class
apache_beam.runners.pipeline_context.
PipelineContext
(proto=None, component_id_map=None, default_environment=None, use_fake_coders=False, iterable_state_read=None, iterable_state_write=None, namespace='ref', requirements=())[source]¶ Bases:
object
For internal use only; no backwards-compatibility guarantees.
Used for accessing and constructing the referenced objects of a Pipeline.