apache_beam.coders.avro_coder module¶

Coder for AvroRecord serialization/deserialization.

class apache_beam.coders.avro_coder.AvroCoder(schema)[source]¶

Bases: apache_beam.coders.coders.FastCoder

A coder used for AvroRecord values.

is_deterministic()[source]¶

to_type_hint()[source]¶

to_runner_api_parameter(context)[source]¶

static from_runner_api_parameter(payload, unused_components, unused_context)[source]¶

class apache_beam.coders.avro_coder.AvroRecord(value)[source]¶

Bases: object

Simple wrapper class for dictionary records.