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

Class AvroDatumFactory<T>

java.lang.Object

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

All Implemented Interfaces:

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

Direct Known Subclasses:

AvroDatumFactory.GenericDatumFactory, AvroDatumFactory.ReflectDatumFactory, AvroDatumFactory.SpecificDatumFactory

public abstract class AvroDatumFactory<T>
extends java.lang.Object
implements AvroSource.DatumReaderFactory<T>, AvroSink.DatumWriterFactory<T>

Create DatumReader and DatumWriter for given schemas.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AvroDatumFactory.GenericDatumFactory Specialized AvroDatumFactory for GenericRecord.
static class	AvroDatumFactory.ReflectDatumFactory<T> Specialized AvroDatumFactory for java classes transforming to avro through reflection.
static class	AvroDatumFactory.SpecificDatumFactory<T> Specialized AvroDatumFactory for SpecificRecord.

Field Summary

Fields

Modifier and Type	Field and Description
protected java.lang.Class<T>	type

Constructor Summary

Constructors

Constructor and Description
AvroDatumFactory(java.lang.Class<T> type)

Method Summary

Modifier and Type	Method and Description
boolean	equals(@Nullable java.lang.Object other)
static AvroDatumFactory<GenericRecord>	generic() Returns an AvroDatumFactory instance for GenericRecord.
java.lang.Class<T>	getType() Returns the type for the datum factory.
int	hashCode()
static <T> AvroDatumFactory<T>	of(java.lang.Class<T> type) Returns an AvroDatumFactory instance for the provided element type.
static <T> AvroDatumFactory<T>	of(java.lang.Class<T> type, boolean useReflectApi) Returns an AvroDatumFactory instance for the provided element type respecting Avro's Reflect* or Specific* suite for encoding and decoding.
static <T> AvroDatumFactory<T>	reflect(java.lang.Class<T> type) Returns an AvroDatumFactory instance for the provided element type respecting Avro's Reflect* suite for encoding and decoding.
static <T> AvroDatumFactory<T>	specific(java.lang.Class<T> type) Returns an AvroDatumFactory instance for the provided element type respecting Avro's Specific* suite for encoding and decoding.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.beam.sdk.extensions.avro.io.AvroSource.DatumReaderFactory

apply

Methods inherited from interface org.apache.beam.sdk.extensions.avro.io.AvroSink.DatumWriterFactory

apply

Field Detail

type

protected final java.lang.Class<T> type

Constructor Detail

AvroDatumFactory

public AvroDatumFactory(java.lang.Class<T> type)

Method Detail

generic

public static AvroDatumFactory<GenericRecord> generic()

Returns an AvroDatumFactory instance for GenericRecord.

specific

public static <T> AvroDatumFactory<T> specific(java.lang.Class<T> type)

Returns an AvroDatumFactory instance for the provided element type respecting Avro's Specific* suite for encoding and decoding.

reflect

public static <T> AvroDatumFactory<T> reflect(java.lang.Class<T> type)

Returns an AvroDatumFactory instance for the provided element type respecting Avro's Reflect* suite for encoding and decoding.

of

public static <T> AvroDatumFactory<T> of(java.lang.Class<T> type)

Returns an AvroDatumFactory instance for the provided element type.

of

public static <T> AvroDatumFactory<T> of(java.lang.Class<T> type,
                                         boolean useReflectApi)

Returns an AvroDatumFactory instance for the provided element type respecting Avro's Reflect* or Specific* suite for encoding and decoding.

getType

public java.lang.Class<T> getType()

Returns the type for the datum factory.

equals

public boolean equals(@Nullable java.lang.Object other)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object