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.Environment(proto)

Bases: future.types.newobject.newobject

A wrapper around the environment proto.

Provides consistency with how the other componentes are accessed.

to_runner_api(context)

static from_runner_api(proto, context)

class apache_beam.runners.pipeline_context.PipelineContext(proto=None, default_environment=None, use_fake_coders=False, iterable_state_read=None, iterable_state_write=None, namespace='ref', allow_proto_holders=False)

Bases: future.types.newobject.newobject

For internal use only; no backwards-compatibility guarantees.

Used for accessing and constructing the referenced objects of a Pipeline.

coder_id_from_element_type(element_type)

element_type_from_coder_id(coder_id)

static from_runner_api(proto)

to_runner_api()

default_environment_id()