apache_beam.coders.row_coder module

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

Bases: apache_beam.coders.coders.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)[source]