apache_beam.coders.row_coder module

class apache_beam.coders.row_coder.RowCoder(schema, force_deterministic=False)[source]

Bases: FastCoder

Coder for typing.NamedTuple instances.

Implements the beam:coder:row:v1 standard coder spec.

Initializes a RowCoder.

Parameters:: schema (apache_beam.portability.api.schema_pb2.Schema) – The protobuf representation of the schema of the data that the RowCoder will be used to encode/decode.

is_deterministic()[source]

as_deterministic_coder(step_label, error_message=None)[source]

to_type_hint()[source]

to_runner_api_parameter(unused_context)[source]

static from_runner_api_parameter(schema, components, unused_context)[source]

classmethod from_type_hint(type_hint, registry)[source]

static from_payload(payload: bytes) → RowCoder[source]