Package org.apache.beam.sdk.extensions.avro.coders

Class AvroGenericCoder

java.lang.Object

org.apache.beam.sdk.coders.Coder<GenericRecord>

org.apache.beam.sdk.coders.CustomCoder<GenericRecord>

org.apache.beam.sdk.extensions.avro.coders.AvroCoder<GenericRecord>

org.apache.beam.sdk.extensions.avro.coders.AvroGenericCoder

All Implemented Interfaces:

Serializable

public class AvroGenericCoder
extends AvroCoder<GenericRecord>

AvroCoder specialisation for GenericRecord, needed for cross-language transforms.

See Also:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.beam.sdk.coders.Coder

Coder.Context, Coder.NonDeterministicException

Method Summary

Modifier and Type	Method	Description
static AvroGenericCoder	of(Schema schema)

Methods inherited from class org.apache.beam.sdk.extensions.avro.coders.AvroCoder

decode, encode, equals, generic, getCoderProvider, getDatumFactory, getDatumReader, getDatumWriter, getEncodedTypeDescriptor, getSchema, getType, hashCode, of, of, of, of, of, of, of, reflect, reflect, reflect, specific, specific, specific, useReflectApi, verifyDeterministic

Methods inherited from class org.apache.beam.sdk.coders.CustomCoder

getCoderArguments

Methods inherited from class org.apache.beam.sdk.coders.Coder

consistentWithEquals, decode, encode, getEncodedElementByteSize, getEncodedElementByteSizeUsingCoder, isRegisterByteSizeObserverCheap, registerByteSizeObserver, structuralValue, verifyDeterministic, verifyDeterministic

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Method Details

of

public static AvroGenericCoder of(Schema schema)