org.apache.beam.sdk.extensions.avro.io

Class AvroDatumFactory.GenericDatumFactory

java.lang.Object

org.apache.beam.sdk.extensions.avro.io.AvroDatumFactory<GenericRecord>

org.apache.beam.sdk.extensions.avro.io.AvroDatumFactory.GenericDatumFactory

All Implemented Interfaces:

java.io.Serializable, AvroSink.DatumWriterFactory<GenericRecord>, AvroSource.DatumReaderFactory<GenericRecord>

Enclosing class:

AvroDatumFactory<T>

public static class AvroDatumFactory.GenericDatumFactory
extends AvroDatumFactory<GenericRecord>

Specialized AvroDatumFactory for GenericRecord.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.beam.sdk.extensions.avro.io.AvroDatumFactory

AvroDatumFactory.GenericDatumFactory, AvroDatumFactory.ReflectDatumFactory<T>, AvroDatumFactory.SpecificDatumFactory<T>

Field Summary

Fields

Modifier and Type	Field and Description
static AvroDatumFactory.GenericDatumFactory	INSTANCE

Fields inherited from class org.apache.beam.sdk.extensions.avro.io.AvroDatumFactory

type

Constructor Summary

Constructors

Constructor and Description
GenericDatumFactory()

Method Summary

Modifier and Type	Method and Description
DatumWriter<GenericRecord>	apply(Schema writer)
DatumReader<GenericRecord>	apply(Schema writer, Schema reader)

Methods inherited from class org.apache.beam.sdk.extensions.avro.io.AvroDatumFactory

equals, generic, getType, hashCode, of, of, reflect, specific

Methods inherited from class java.lang.Object

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

Field Detail

INSTANCE

public static final AvroDatumFactory.GenericDatumFactory INSTANCE

Constructor Detail

GenericDatumFactory

public GenericDatumFactory()

Method Detail

apply

public DatumReader<GenericRecord> apply(Schema writer,
                                        Schema reader)

apply

public DatumWriter<GenericRecord> apply(Schema writer)