apache_beam.coders.row_coder module

class apache_beam.coders.row_coder.RowCoder(schema, force_deterministic=False)

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

as_deterministic_coder(step_label, error_message=None)

to_type_hint()

to_runner_api_parameter(unused_context)

static from_runner_api_parameter(schema, components, unused_context)

classmethod from_type_hint(type_hint, registry)

static from_payload(payload: bytes) → RowCoder