Modifier and Type	Class and Description
public static interface	FastReaderBuilder.ExecutionStep
public static interface	FastReaderBuilder.FieldReader
public static class	FastReaderBuilder.MapReader
public static class	FastReaderBuilder.RecordReader
public static interface	FastReaderBuilder.ReusingFieldReader

Modifier and Type	Field and Description
private boolean	classPropEnabled
private final GenericData	data Generic/SpecificData instance that contains basic functionalities like instantiation of objects
private boolean	keyClassEnabled
private final Map<Schema, Map<Schema, FastReaderBuilder.RecordReader>>	readerCache first schema is reader schema, second is writer schema

Access	Constructor and Description
public	FastReaderBuilder(GenericData parentData)

Modifier and Type	Method and Description
private FastReaderBuilder.FieldReader	applyConversions(Schema readerSchema, FastReaderBuilder.FieldReader reader, Conversion<?> explicitConversion)
private FastReaderBuilder.FieldReader	createArrayReader(Schema readerSchema, Resolver.Container action)
private FastReaderBuilder.FieldReader	createBytesPromotingToStringReader(Schema readerSchema)
private FastReaderBuilder.FieldReader	createBytesReader()
public <D> DatumReader<D>	createDatumReader(Schema schema)
public <D> DatumReader<D>	createDatumReader(Schema writerSchema, Schema readerSchema)
private FastReaderBuilder.FieldReader	createEnumReader(Resolver.EnumAdjust action)
private FastReaderBuilder.ExecutionStep	createFieldSetter(Schema.Field field, FastReaderBuilder.FieldReader reader)
private FastReaderBuilder.FieldReader	createFixedReader(Schema readerSchema, Schema writerSchema)
private FastReaderBuilder.FieldReader	createMapKeyReader(Schema readerSchema)
private FastReaderBuilder.FieldReader	createMapReader(Schema readerSchema, Resolver.Container action)
private FastReaderBuilder.FieldReader	createPromotingReader(Resolver.Promote promote)
private FastReaderBuilder.RecordReader	createRecordReader(Resolver.RecordAdjust action)
private FastReaderBuilder.FieldReader	createSimpleStringReader(Schema readerSchema)
private FastReaderBuilder.FieldReader	createStringReader(Schema readerSchema, Schema writerSchema)
private FastReaderBuilder.FieldReader	createUnionReader(Resolver.WriterUnion action)
private FastReaderBuilder.FieldReader	createUnionReader(FastReaderBuilder.FieldReader[] unionReaders)
private Optional<Class<?>>	findClass(String clazz)
public static FastReaderBuilder	get()
private IntFunction<Conversion<?>>	getConversionSupplier(Object record)
private FastReaderBuilder.ExecutionStep	getDefaultingStep(Schema.Field field)
private byte[]	getEncodedValue(Schema.Field field)
private FastReaderBuilder.FieldReader	getNonConvertedReader(Resolver.Action action)
private FastReaderBuilder.FieldReader	getReaderFor(Schema readerSchema, Schema writerSchema)
private FastReaderBuilder.FieldReader	getReaderFor(Resolver.Action action, Conversion<?> explicitConversion)
private FastReaderBuilder.FieldReader	getReaderForBaseType(Schema readerSchema, Schema writerSchema)
private FastReaderBuilder.RecordReader	getRecordReaderFromCache(Schema readerSchema, Schema writerSchema)
public static FastReaderBuilder	getSpecific()
private String	getStringFromByteBuffer(ByteBuffer buffer)
private FastReaderBuilder.FieldReader	getTransformingStringReader(String valueClass, FastReaderBuilder.FieldReader stringReader)
private Utf8	getUtf8FromByteBuffer(Object old, ByteBuffer buffer)
private FastReaderBuilder.RecordReader	initializeRecordReader(FastReaderBuilder.RecordReader recordReader, Resolver.RecordAdjust action)
public boolean	isClassPropEnabled()
public boolean	isKeyClassEnabled()
private boolean	isObjectImmutable(Object object)
public static boolean	isSupportedData(GenericData data)
private Utf8	readUtf8(Object reuse, Utf8 newValue)
public static FastReaderBuilder.FieldReader	reusingReader(FastReaderBuilder.ReusingFieldReader reader)
public FastReaderBuilder	withClassPropEnabled(boolean enabled)
public FastReaderBuilder	withKeyClassEnabled(boolean enabled)

classPropEnabled	back to summary
private boolean classPropEnabled

data	back to summary
private final GenericData data Generic/SpecificData instance that contains basic functionalities like instantiation of objects

keyClassEnabled	back to summary
private boolean keyClassEnabled

readerCache	back to summary
private final Map<Schema, Map<Schema, FastReaderBuilder.RecordReader>> readerCache first schema is reader schema, second is writer schema

FastReaderBuilder	back to summary
public FastReaderBuilder(GenericData parentData)

Method Detail

applyConversions	back to summary
private FastReaderBuilder.FieldReader applyConversions(Schema readerSchema, FastReaderBuilder.FieldReader reader, Conversion<?> explicitConversion)

createArrayReader	back to summary
private FastReaderBuilder.FieldReader createArrayReader(Schema readerSchema, Resolver.Container action) throws IOException Annotations @SuppressWarnings:unchecked

createBytesPromotingToStringReader	back to summary
private FastReaderBuilder.FieldReader createBytesPromotingToStringReader(Schema readerSchema)

createBytesReader	back to summary
private FastReaderBuilder.FieldReader createBytesReader()

createDatumReader	back to summary
public <D> DatumReader<D> createDatumReader(Schema schema) throws IOException

createDatumReader	back to summary
public <D> DatumReader<D> createDatumReader(Schema writerSchema, Schema readerSchema) throws IOException Annotations @SuppressWarnings:unchecked

createEnumReader	back to summary
private FastReaderBuilder.FieldReader createEnumReader(Resolver.EnumAdjust action)

createFieldSetter	back to summary
private FastReaderBuilder.ExecutionStep createFieldSetter(Schema.Field field, FastReaderBuilder.FieldReader reader)

createFixedReader	back to summary
private FastReaderBuilder.FieldReader createFixedReader(Schema readerSchema, Schema writerSchema)

createMapKeyReader	back to summary
private FastReaderBuilder.FieldReader createMapKeyReader(Schema readerSchema)

createMapReader	back to summary
private FastReaderBuilder.FieldReader createMapReader(Schema readerSchema, Resolver.Container action) throws IOException

createPromotingReader	back to summary
private FastReaderBuilder.FieldReader createPromotingReader(Resolver.Promote promote) throws IOException

createRecordReader	back to summary
private FastReaderBuilder.RecordReader createRecordReader(Resolver.RecordAdjust action) throws IOException

createSimpleStringReader	back to summary
private FastReaderBuilder.FieldReader createSimpleStringReader(Schema readerSchema)

createStringReader	back to summary
private FastReaderBuilder.FieldReader createStringReader(Schema readerSchema, Schema writerSchema)

createUnionReader	back to summary
private FastReaderBuilder.FieldReader createUnionReader(Resolver.WriterUnion action) throws IOException

createUnionReader	back to summary
private FastReaderBuilder.FieldReader createUnionReader(FastReaderBuilder.FieldReader[] unionReaders)

findClass	back to summary
private Optional<Class<?>> findClass(String clazz)

get	back to summary
public static FastReaderBuilder get()

getConversionSupplier	back to summary
private IntFunction<Conversion<?>> getConversionSupplier(Object record)

getDefaultingStep	back to summary
private FastReaderBuilder.ExecutionStep getDefaultingStep(Schema.Field field) throws IOException

getEncodedValue	back to summary
private byte[] getEncodedValue(Schema.Field field) throws IOException

getNonConvertedReader	back to summary
private FastReaderBuilder.FieldReader getNonConvertedReader(Resolver.Action action) throws IOException

getReaderFor	back to summary
private FastReaderBuilder.FieldReader getReaderFor(Schema readerSchema, Schema writerSchema) throws IOException

getReaderFor	back to summary
private FastReaderBuilder.FieldReader getReaderFor(Resolver.Action action, Conversion<?> explicitConversion) throws IOException

getReaderForBaseType	back to summary
private FastReaderBuilder.FieldReader getReaderForBaseType(Schema readerSchema, Schema writerSchema) throws IOException

getRecordReaderFromCache	back to summary
private FastReaderBuilder.RecordReader getRecordReaderFromCache(Schema readerSchema, Schema writerSchema)

getSpecific	back to summary
public static FastReaderBuilder getSpecific()

getStringFromByteBuffer	back to summary
private String getStringFromByteBuffer(ByteBuffer buffer)

getTransformingStringReader	back to summary
private FastReaderBuilder.FieldReader getTransformingStringReader(String valueClass, FastReaderBuilder.FieldReader stringReader)

getUtf8FromByteBuffer	back to summary
private Utf8 getUtf8FromByteBuffer(Object old, ByteBuffer buffer)

initializeRecordReader	back to summary
private FastReaderBuilder.RecordReader initializeRecordReader(FastReaderBuilder.RecordReader recordReader, Resolver.RecordAdjust action) throws IOException

isClassPropEnabled	back to summary
public boolean isClassPropEnabled()

isKeyClassEnabled	back to summary
public boolean isKeyClassEnabled()

isObjectImmutable	back to summary
private boolean isObjectImmutable(Object object)

isSupportedData	back to summary
public static boolean isSupportedData(GenericData data)

readUtf8	back to summary
private Utf8 readUtf8(Object reuse, Utf8 newValue)

reusingReader	back to summary
public static FastReaderBuilder.FieldReader reusingReader(FastReaderBuilder.ReusingFieldReader reader)

withClassPropEnabled	back to summary
public FastReaderBuilder withClassPropEnabled(boolean enabled)

withKeyClassEnabled	back to summary
public FastReaderBuilder withKeyClassEnabled(boolean enabled)

org.apache.avro.io back to summary

public Interface FastReaderBuilder.ExecutionStep

Method Summary

Modifier and Type	Method and Description
public void	execute(Object record, Decoder decoder)

Method Detail

execute	back to summary
public void execute(Object record, Decoder decoder) throws IOException

org.apache.avro.io back to summary

public Interface FastReaderBuilder.FieldReader

Known Direct Subinterfaces: org.apache.avro.io.FastReaderBuilder.ReusingFieldReader
Known Direct Implementers: org.apache.avro.io.FastReaderBuilder.RecordReader, org.apache.avro.io.FastReaderBuilder.MapReader

Method Summary

Modifier and Type	Method and Description
public default boolean	canReuse()
public Object	read(Object reuse, Decoder decoder) Redeclares org.apache.avro.io.DatumReader.read. Read a datum.
public default void	setSchema(Schema schema) Implements org.apache.avro.io.DatumReader.setSchema. Set the writer's schema.

Method Detail

canReuse	back to summary
public default boolean canReuse()

read

back to summary

public Object read(Object reuse, Decoder decoder) throws IOException

Redeclares org.apache.avro.io.DatumReader.read.

Doc from org.apache.avro.io.DatumReader.read.

Read a datum. Traverse the schema, depth-first, reading all leaf values in the schema into a datum that is returned. If the provided datum is non-null it may be reused and returned.

Annotations

@Override

setSchema

back to summary

public default void setSchema(Schema schema)

Implements org.apache.avro.io.DatumReader.setSchema.

Doc from org.apache.avro.io.DatumReader.setSchema.

Set the writer's schema.

Annotations

@Override

org.apache.avro.io back to summary

public Class FastReaderBuilder.MapReader

Class Inheritance

extends Object
implements FieldReader

java.lang.Object
org.apache.avro.io.FastReaderBuilder.MapReader

All Implemented Interfaces

org.apache.avro.io.FastReaderBuilder.FieldReader, org.apache.avro.io.DatumReader

Field Summary

Modifier and Type	Field and Description
private final FastReaderBuilder.FieldReader	keyReader
private final FastReaderBuilder.FieldReader	valueReader

Constructor Summary

Access	Constructor and Description
public	MapReader(FastReaderBuilder.FieldReader keyReader, FastReaderBuilder.FieldReader valueReader)

Method Summary

Modifier and Type	Method and Description
public Object	read(Object reuse, Decoder decoder) Implements org.apache.avro.io.FastReaderBuilder.FieldReader.read. Read a datum.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

keyReader	back to summary
private final FastReaderBuilder.FieldReader keyReader

valueReader	back to summary
private final FastReaderBuilder.FieldReader valueReader

Constructor Detail

MapReader	back to summary
public MapReader(FastReaderBuilder.FieldReader keyReader, FastReaderBuilder.FieldReader valueReader)

Method Detail

read

back to summary

public Object read(Object reuse, Decoder decoder) throws IOException

Implements org.apache.avro.io.FastReaderBuilder.FieldReader.read.

Doc from org.apache.avro.io.DatumReader.read.

Read a datum. Traverse the schema, depth-first, reading all leaf values in the schema into a datum that is returned. If the provided datum is non-null it may be reused and returned.

Annotations

@Override

org.apache.avro.io back to summary

public Class FastReaderBuilder.RecordReader

Class Inheritance

extends Object
implements FieldReader

java.lang.Object
org.apache.avro.io.FastReaderBuilder.RecordReader

All Implemented Interfaces

org.apache.avro.io.FastReaderBuilder.FieldReader, org.apache.avro.io.DatumReader

Nested and Inner Type Summary

Modifier and Type	Class and Description
public static enum	FastReaderBuilder.RecordReader.Stage

Field Summary

Modifier and Type	Field and Description
private FastReaderBuilder.ExecutionStep[]	readSteps
private Schema	schema
private FastReaderBuilder.RecordReader.Stage	stage
private GenericData.InstanceSupplier	supplier

Constructor Summary

Access	Constructor and Description
public	RecordReader()

Method Summary

Modifier and Type	Method and Description
public boolean	canReuse() Overrides default org.apache.avro.io.FastReaderBuilder.FieldReader.canReuse.
public void	finishInitialization(FastReaderBuilder.ExecutionStep[] readSteps, Schema schema, GenericData.InstanceSupplier supp)
public FastReaderBuilder.RecordReader.Stage	getInitializationStage()
public Object	read(Object reuse, Decoder decoder) Implements org.apache.avro.io.FastReaderBuilder.FieldReader.read. Read a datum.
public void	reset()
public void	startInitialization()

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

readSteps	back to summary
private FastReaderBuilder.ExecutionStep[] readSteps

schema	back to summary
private Schema schema

stage	back to summary
private FastReaderBuilder.RecordReader.Stage stage

supplier	back to summary
private GenericData.InstanceSupplier supplier

Constructor Detail

RecordReader	back to summary
public RecordReader()

Method Detail

canReuse

back to summary

public boolean canReuse()

Overrides default org.apache.avro.io.FastReaderBuilder.FieldReader.canReuse.

Annotations

@Override

finishInitialization	back to summary
public void finishInitialization(FastReaderBuilder.ExecutionStep[] readSteps, Schema schema, GenericData.InstanceSupplier supp)

getInitializationStage	back to summary
public FastReaderBuilder.RecordReader.Stage getInitializationStage()

read

back to summary

public Object read(Object reuse, Decoder decoder) throws IOException

Implements org.apache.avro.io.FastReaderBuilder.FieldReader.read.

Doc from org.apache.avro.io.DatumReader.read.

Read a datum. Traverse the schema, depth-first, reading all leaf values in the schema into a datum that is returned. If the provided datum is non-null it may be reused and returned.

Annotations

@Override

reset	back to summary
public void reset()

startInitialization	back to summary
public void startInitialization()

org.apache.avro.io back to summary

public final Enum FastReaderBuilder.RecordReader.Stage

Class Inheritance

extends Enum<FastReaderBuilder.RecordReader.Stage>

java.lang.Object
java.lang.Enum
org.apache.avro.io.FastReaderBuilder.RecordReader.Stage

Field Summary

Modifier and Type	Field and Description
public static final FastReaderBuilder.RecordReader.Stage	INITIALIZED
public static final FastReaderBuilder.RecordReader.Stage	INITIALIZING
public static final FastReaderBuilder.RecordReader.Stage	NEW

Constructor Summary

Access	Constructor and Description
private	Stage()

Method Summary

Modifier and Type	Method and Description
public static FastReaderBuilder.RecordReader.Stage	valueOf(String name)
public static FastReaderBuilder.RecordReader.Stage[]	values()

Inherited from java.lang.Enum:: clone compareTo describeConstable equals finalize getDeclaringClass hashCode name ordinal toString valueOf

Field Detail

INITIALIZED	back to summary
public static final FastReaderBuilder.RecordReader.Stage INITIALIZED

INITIALIZING	back to summary
public static final FastReaderBuilder.RecordReader.Stage INITIALIZING

NEW	back to summary
public static final FastReaderBuilder.RecordReader.Stage NEW

Constructor Detail

Stage	back to summary
private Stage()

Method Detail

valueOf	back to summary
public static FastReaderBuilder.RecordReader.Stage valueOf(String name)

values	back to summary
public static FastReaderBuilder.RecordReader.Stage[] values()

public Class FastReaderBuilder

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

public Interface FastReaderBuilder.ExecutionStep

Method Summary

Method Detail

public Interface FastReaderBuilder.FieldReader

Method Summary

Method Detail

public Class FastReaderBuilder.MapReader

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

public Class FastReaderBuilder.RecordReader

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

public final Enum FastReaderBuilder.RecordReader.Stage

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

public Interface FastReaderBuilder.ReusingFieldReader

Method Summary

Method Detail