Package 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:

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	Description
static final AvroDatumFactory.GenericDatumFactory	INSTANCE

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

type

Constructor Summary

Constructors

Constructor	Description
GenericDatumFactory()

Method Summary

Modifier and Type	Method	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 Details

INSTANCE

public static final AvroDatumFactory.GenericDatumFactory INSTANCE

Constructor Details

GenericDatumFactory

public GenericDatumFactory()

Method Details

apply

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

apply

public DatumWriter<GenericRecord> apply(Schema writer)