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

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

Direct Known Subclasses:

AvroDatumFactory.GenericDatumFactory, AvroDatumFactory.ReflectDatumFactory, AvroDatumFactory.SpecificDatumFactory

public abstract class AvroDatumFactory<T>
extends 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	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	Description
protected final Class<T>	type

Constructor Summary

Constructors

Constructor	Description
AvroDatumFactory(Class<T> type)

Method Summary

Modifier and Type	Method	Description
boolean	equals(@Nullable Object other)
static AvroDatumFactory<GenericRecord>	generic()	Returns an AvroDatumFactory instance for GenericRecord.
Class<T>	getType()	Returns the type for the datum factory.
int	hashCode()
static <T> AvroDatumFactory<T>	of(Class<T> type)	Returns an AvroDatumFactory instance for the provided element type.
static <T> AvroDatumFactory<T>	of(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(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(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.AvroSink.DatumWriterFactory

apply

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

apply

Field Details

type

protected final Class<T> type

Constructor Details

AvroDatumFactory

public AvroDatumFactory(Class<T> type)

Method Details

generic

public static AvroDatumFactory<GenericRecord> generic()

Returns an AvroDatumFactory instance for GenericRecord.

specific

public static <T> AvroDatumFactory<T> specific(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(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(Class<T> type)

Returns an AvroDatumFactory instance for the provided element type.

of

public static <T> AvroDatumFactory<T> of(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 Class<T> getType()

Returns the type for the datum factory.

equals

public boolean equals(@Nullable Object other)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object