Modifier and Type	Class and Description
private static class	GenericDatumReader.IdentitySchemaKey This class is used to reproduce part of IdentityHashMap in ConcurrentHashMap code.
pack-priv static class	GenericDatumReader.ReaderCache

Modifier and Type	Field and Description
private Schema	actual
private final Thread	creator
private ResolvingDecoder	creatorResolver
private final GenericData	data
private Schema	expected
private DatumReader<D>	fastDatumReader
private final GenericDatumReader.ReaderCache	readerCache
private static final ThreadLocal<Map<Schema, Map<Schema, ResolvingDecoder>>>	RESOLVER_CACHE

Access	Constructor and Description
public	GenericDatumReader()
public	GenericDatumReader(Schema schema) Construct where the writer's and reader's schemas are the same.
public	GenericDatumReader(Schema writer, Schema reader) Construct given writer's and reader's schema.
public	GenericDatumReader(Schema writer, Schema reader, GenericData data)
protected	GenericDatumReader(GenericData data)

Method Summary

Modifier and Type	Method and Description
protected void	addToArray(Object array, long pos, Object e) Called by the default implementation of `readArray` to add a value.
protected void	addToMap(Object map, Object key, Object value) Called by the default implementation of `readMap` to add a key/value pair.
protected Object	convert(Object datum, Schema schema, LogicalType type, Conversion<?> conversion) Convert an underlying representation of a logical type (such as a ByteBuffer) to a higher level object (such as a BigDecimal).
protected Object	createBytes(byte[] value) Called to create byte arrays from default values.
protected Object	createEnum(String symbol, Schema schema) Called to create an enum value.
protected Object	createFixed(Object old, Schema schema) Deprecated As of Avro 1.6.0 this method has been moved to `GenericData#createFixed(Object, Schema)` Called to create an fixed value.
protected Object	createFixed(Object old, byte[] bytes, Schema schema) Deprecated As of Avro 1.6.0 this method has been moved to `GenericData#createFixed(Object, byte[], Schema)` Called to create an fixed value.
protected Object	createString(String value) Called to create a string from a default value.
protected Class<T>	findStringClass(Schema schema) Determines the class to used to represent a string Schema.
public GenericData	getData() Return the `GenericData` implementation.
public Schema	getExpected() Get the reader's schema.
pack-priv GenericDatumReader.ReaderCache	getReaderCache()
protected final ResolvingDecoder	getResolver(Schema actual, Schema expected) Gets a resolving decoder for use by this GenericDatumReader.
public Schema	getSchema() Return the writer's schema.
protected Object	newArray(Object old, int size, Schema schema) Called to create new array instances.
protected Object	newInstanceFromString(Class<T> c, String s)
protected Object	newMap(Object old, int size) Called to create new array instances.
protected Object	newRecord(Object old, Schema schema) Deprecated As of Avro 1.6.0 this method has been moved to `GenericData#newRecord(Object, Schema)` Called to create new record instances.
protected Object	peekArray(Object array) Called by the default implementation of `readArray` to retrieve a value from a reused instance.
private Object	pruneArray(Object object)
public D	read(D reuse, Decoder in) Implements org.apache.avro.io.DatumReader.read. Read a datum.
protected Object	read(Object old, Schema expected, ResolvingDecoder in) Called to read data.
protected Object	readArray(Object old, Schema expected, ResolvingDecoder in) Called to read an array instance.
protected Object	readBytes(Object old, Schema s, Decoder in) Called to read byte arrays.
protected Object	readBytes(Object old, Decoder in) Called to read byte arrays.
protected Object	readEnum(Schema expected, Decoder in) Called to read an enum value.
protected void	readField(Object record, Schema.Field field, Object oldDatum, ResolvingDecoder in, Object state) Called to read a single field of a record.
protected Object	readFixed(Object old, Schema expected, Decoder in) Called to read a fixed value.
protected Object	readInt(Object old, Schema expected, Decoder in) Called to read integers.
protected Object	readMap(Object old, Schema expected, ResolvingDecoder in) Called to read a map instance.
protected Object	readMapKey(Object old, Schema expected, Decoder in) Called by the default implementation of `readMap` to read a key value.
protected Object	readRecord(Object old, Schema expected, ResolvingDecoder in) Called to read a record instance.
protected Object	readString(Object old, Schema expected, Decoder in) Called to read strings.
protected Object	readString(Object old, Decoder in) Called to read strings.
protected Object	readWithConversion(Object old, Schema expected, LogicalType logicalType, Conversion<?> conversion, ResolvingDecoder in)
protected Object	readWithoutConversion(Object old, Schema expected, ResolvingDecoder in)
public void	setExpected(Schema reader) Set the reader's schema.
public void	setSchema(Schema writer) Implements org.apache.avro.io.DatumReader.setSchema. Set the writer's schema.
public static void	skip(Schema schema, Decoder in) Skip an instance of a schema.

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

Field Detail

actual	back to summary
private Schema actual

creator	back to summary
private final Thread creator

creatorResolver	back to summary
private ResolvingDecoder creatorResolver

data	back to summary
private final GenericData data

expected	back to summary
private Schema expected

fastDatumReader	back to summary
private DatumReader<D> fastDatumReader

readerCache	back to summary
private final GenericDatumReader.ReaderCache readerCache

RESOLVER_CACHE	back to summary
private static final ThreadLocal<Map<Schema, Map<Schema, ResolvingDecoder>>> RESOLVER_CACHE

Constructor Detail

GenericDatumReader	back to summary
public GenericDatumReader()

GenericDatumReader	back to summary
public GenericDatumReader(Schema schema) Construct where the writer's and reader's schemas are the same.

GenericDatumReader	back to summary
public GenericDatumReader(Schema writer, Schema reader) Construct given writer's and reader's schema.

GenericDatumReader	back to summary
public GenericDatumReader(Schema writer, Schema reader, GenericData data)

GenericDatumReader	back to summary
protected GenericDatumReader(GenericData data)

Method Detail

addToArray back to summary

addToArray	back to summary
protected void addToArray(Object array, long pos, Object e) Called by the default implementation of `readArray` to add a value. The default implementation is for `Collection`. Annotations @SuppressWarnings:unchecked

protected void addToArray(Object array, long pos, Object e)

Called by the default implementation of readArray to add a value. The default implementation is for Collection.

Annotations

@SuppressWarnings:unchecked

addToMap back to summary

addToMap	back to summary
protected void addToMap(Object map, Object key, Object value) Called by the default implementation of `readMap` to add a key/value pair. The default implementation is for `Map`. Annotations @SuppressWarnings:unchecked

protected void addToMap(Object map, Object key, Object value)

Called by the default implementation of readMap to add a key/value pair. The default implementation is for Map.

Annotations

@SuppressWarnings:unchecked

convert	back to summary
protected Object convert(Object datum, Schema schema, LogicalType type, Conversion<?> conversion) Convert an underlying representation of a logical type (such as a ByteBuffer) to a higher level object (such as a BigDecimal). Exceptions IllegalArgumentException: if a null schema or logicalType is passed in while datum and conversion are not null. Please be noticed that the exception type has changed. With version 1.8.0 and earlier, in above circumstance, the exception thrown out depends on the implementation of conversion (most likely a NullPointerException). Now, an IllegalArgumentException will be thrown out instead.

convert

back to summary

protected Object convert(Object datum, Schema schema, LogicalType type, Conversion<?> conversion)

Convert an underlying representation of a logical type (such as a ByteBuffer) to a higher level object (such as a BigDecimal).

Exceptions

IllegalArgumentException:: if a null schema or logicalType is passed in while datum and conversion are not null. Please be noticed that the exception type has changed. With version 1.8.0 and earlier, in above circumstance, the exception thrown out depends on the implementation of conversion (most likely a NullPointerException). Now, an IllegalArgumentException will be thrown out instead.

createBytes	back to summary
protected Object createBytes(byte[] value) Called to create byte arrays from default values. Subclasses may override to use a different byte array representation. By default, this calls `ByteBuffer#wrap(byte[])`.

createEnum	back to summary
protected Object createEnum(String symbol, Schema schema) Called to create an enum value. May be overridden for alternate enum representations. By default, returns a GenericEnumSymbol.

createFixed back to summary

createFixed	back to summary
protected Object createFixed(Object old, Schema schema) Deprecated As of Avro 1.6.0 this method has been moved to `GenericData#createFixed(Object, Schema)` Called to create an fixed value. May be overridden for alternate fixed representations. By default, returns `GenericFixed`. Annotations @Deprecated

protected Object createFixed(Object old, Schema schema)

Deprecated

As of Avro 1.6.0 this method has been moved to GenericData#createFixed(Object, Schema)

Called to create an fixed value. May be overridden for alternate fixed representations. By default, returns GenericFixed.

Annotations

@Deprecated

createFixed back to summary

createFixed	back to summary
protected Object createFixed(Object old, byte[] bytes, Schema schema) Deprecated As of Avro 1.6.0 this method has been moved to `GenericData#createFixed(Object, byte[], Schema)` Called to create an fixed value. May be overridden for alternate fixed representations. By default, returns `GenericFixed`. Annotations @Deprecated

protected Object createFixed(Object old, byte[] bytes, Schema schema)

Deprecated

As of Avro 1.6.0 this method has been moved to GenericData#createFixed(Object, byte[], Schema)

Called to create an fixed value. May be overridden for alternate fixed representations. By default, returns GenericFixed.

Annotations

@Deprecated

createString	back to summary
protected Object createString(String value) Called to create a string from a default value. Subclasses may override to use a different string representation. By default, this calls `Utf8#Utf8(String)`.

findStringClass	back to summary
protected Class<T> findStringClass(Schema schema) Determines the class to used to represent a string Schema. By default uses `GenericData#STRING_PROP` to determine whether `Utf8` or `String` is used. Subclasses may override for alternate representations.

getData	back to summary
public GenericData getData() Return the `GenericData` implementation.

getExpected	back to summary
public Schema getExpected() Get the reader's schema.

getReaderCache	back to summary
pack-priv GenericDatumReader.ReaderCache getReaderCache()

getResolver	back to summary
protected final ResolvingDecoder getResolver(Schema actual, Schema expected) throws IOException Gets a resolving decoder for use by this GenericDatumReader. Unstable API. Currently uses a thread local cache to prevent constructing the resolvers too often, because that is very expensive.

getSchema	back to summary
public Schema getSchema() Return the writer's schema.

newArray back to summary

newArray	back to summary
protected Object newArray(Object old, int size, Schema schema) Called to create new array instances. Subclasses may override to use a different array implementation. By default, this returns a `GenericData.Array`. Annotations @SuppressWarnings:unchecked

protected Object newArray(Object old, int size, Schema schema)

Called to create new array instances. Subclasses may override to use a different array implementation. By default, this returns a GenericData.Array.

Annotations

@SuppressWarnings:unchecked

newInstanceFromString	back to summary
protected Object newInstanceFromString(Class<T> c, String s) Annotations @SuppressWarnings:unchecked

newMap back to summary

newMap	back to summary
protected Object newMap(Object old, int size) Called to create new array instances. Subclasses may override to use a different map implementation. By default, this returns a `HashMap`. Annotations @SuppressWarnings:unchecked

protected Object newMap(Object old, int size)

Called to create new array instances. Subclasses may override to use a different map implementation. By default, this returns a HashMap.

Annotations

@SuppressWarnings:unchecked

newRecord back to summary

newRecord	back to summary
protected Object newRecord(Object old, Schema schema) Deprecated As of Avro 1.6.0 this method has been moved to `GenericData#newRecord(Object, Schema)` Called to create new record instances. Subclasses may override to use a different record implementation. The returned instance must conform to the schema provided. If the old object contains fields not present in the schema, they should either be removed from the old object, or it should create a new instance that conforms to the schema. By default, this returns a `GenericData.Record`. Annotations @Deprecated

protected Object newRecord(Object old, Schema schema)

Deprecated

As of Avro 1.6.0 this method has been moved to GenericData#newRecord(Object, Schema)

Called to create new record instances. Subclasses may override to use a different record implementation. The returned instance must conform to the schema provided. If the old object contains fields not present in the schema, they should either be removed from the old object, or it should create a new instance that conforms to the schema. By default, this returns a GenericData.Record.

Annotations

@Deprecated

peekArray back to summary

peekArray	back to summary
protected Object peekArray(Object array) Called by the default implementation of `readArray` to retrieve a value from a reused instance. The default implementation is for `GenericArray`. Annotations @SuppressWarnings:unchecked

protected Object peekArray(Object array)

Called by the default implementation of readArray to retrieve a value from a reused instance. The default implementation is for GenericArray.

Annotations

@SuppressWarnings:unchecked

pruneArray	back to summary
private Object pruneArray(Object object)

read	back to summary
public D read(D reuse, Decoder in) throws IOException Implements 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 @SuppressWarnings:unchecked

read

back to summary

public D read(D reuse, Decoder in) throws IOException

Implements 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
@SuppressWarnings:unchecked

read	back to summary
protected Object read(Object old, Schema expected, ResolvingDecoder in) throws IOException Called to read data.

readArray	back to summary
protected Object readArray(Object old, Schema expected, ResolvingDecoder in) throws IOException Called to read an array instance. May be overridden for alternate array representations.

readBytes	back to summary
protected Object readBytes(Object old, Schema s, Decoder in) throws IOException Called to read byte arrays. Subclasses may override to use a different byte array representation. By default, this calls `Decoder#readBytes(ByteBuffer)`.

readBytes	back to summary
protected Object readBytes(Object old, Decoder in) throws IOException Called to read byte arrays. Subclasses may override to use a different byte array representation. By default, this calls `Decoder#readBytes(ByteBuffer)`.

readEnum	back to summary
protected Object readEnum(Schema expected, Decoder in) throws IOException Called to read an enum value. May be overridden for alternate enum representations. By default, returns a GenericEnumSymbol.

readField	back to summary
protected void readField(Object record, Schema.Field field, Object oldDatum, ResolvingDecoder in, Object state) throws IOException Called to read a single field of a record. May be overridden for more efficient or alternate implementations.

readFixed	back to summary
protected Object readFixed(Object old, Schema expected, Decoder in) throws IOException Called to read a fixed value. May be overridden for alternate fixed representations. By default, returns `GenericFixed`.

readInt	back to summary
protected Object readInt(Object old, Schema expected, Decoder in) throws IOException Called to read integers. Subclasses may override to use a different integer representation. By default, this calls `Decoder#readInt()`.

readMap	back to summary
protected Object readMap(Object old, Schema expected, ResolvingDecoder in) throws IOException Called to read a map instance. May be overridden for alternate map representations.

readMapKey	back to summary
protected Object readMapKey(Object old, Schema expected, Decoder in) throws IOException Called by the default implementation of `readMap` to read a key value. The default implementation returns delegates to `readString(Object, org.apache.avro.io.Decoder)`.

readRecord	back to summary
protected Object readRecord(Object old, Schema expected, ResolvingDecoder in) throws IOException Called to read a record instance. May be overridden for alternate record representations.

readString	back to summary
protected Object readString(Object old, Schema expected, Decoder in) throws IOException Called to read strings. Subclasses may override to use a different string representation. By default, this calls `readString(Object, Decoder)`.

readString	back to summary
protected Object readString(Object old, Decoder in) throws IOException Called to read strings. Subclasses may override to use a different string representation. By default, this calls `Decoder#readString(Utf8)`.

readWithConversion	back to summary
protected Object readWithConversion(Object old, Schema expected, LogicalType logicalType, Conversion<?> conversion, ResolvingDecoder in) throws IOException

readWithoutConversion	back to summary
protected Object readWithoutConversion(Object old, Schema expected, ResolvingDecoder in) throws IOException

setExpected	back to summary
public void setExpected(Schema reader) Set the reader's schema.

setSchema

back to summary

public void setSchema(Schema writer)

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

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

Set the writer's schema.

Annotations

@Override

skip	back to summary
public static void skip(Schema schema, Decoder in) throws IOException Skip an instance of a schema.

org.apache.avro.generic back to summary

private final Class GenericDatumReader.IdentitySchemaKey

Class Inheritance

extends Object

java.lang.Object
org.apache.avro.generic.GenericDatumReader.IdentitySchemaKey

This class is used to reproduce part of IdentityHashMap in ConcurrentHashMap code.

Field Summary

Modifier and Type	Field and Description
private final int	hashcode
private final Schema	schema

Constructor Summary

Access	Constructor and Description
public	IdentitySchemaKey(Schema schema)

Method Summary

Modifier and Type	Method and Description
public boolean	equals(Object the reference object with which to compare. obj) Overrides java.lang.Object.equals. Indicates whether some other object is "equal to" this one.
public int	hashCode() Overrides java.lang.Object.hashCode. Returns a hash code value for the object.

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

Field Detail

hashcode	back to summary
private final int hashcode

schema	back to summary
private final Schema schema

Constructor Detail

IdentitySchemaKey	back to summary
public IdentitySchemaKey(Schema schema)

Method Detail

equals back to summary

public boolean equals(Object obj)

Overrides java.lang.Object.equals.

Doc from java.lang.Object.equals.

Indicates whether some other object is "equal to" this one.

The equals method implements an equivalence relation on non-null object references:

It is reflexive: for any non-null reference value x, x.equals(x) should return true.
It is symmetric: for any non-null reference values x and y, x.equals(y) should return true if and only if y.equals(x) returns true.
It is transitive: for any non-null reference values x, y, and z, if x.equals(y) returns true and y.equals(z) returns true, then x.equals(z) should return true.
It is consistent: for any non-null reference values x and y, multiple invocations of x.equals(y) consistently return true or consistently return false, provided no information used in equals comparisons on the objects is modified.
For any non-null reference value x, x.equals(null) should return false.

An equivalence relation partitions the elements it operates on into equivalence classes; all the members of an equivalence class are equal to each other. Members of an equivalence class are substitutable for each other, at least for some purposes.

Parameters

obj:Object: the reference object with which to compare.

Returns:boolean

true if this object is the same as the obj argument; false otherwise.

Annotations

@Override

hashCode back to summary

public int hashCode()

Overrides java.lang.Object.hashCode.

Doc from java.lang.Object.hashCode.

Returns a hash code value for the object. This method is supported for the benefit of hash tables such as those provided by java.util.HashMap.

The general contract of hashCode is:

Whenever it is invoked on the same object more than once during an execution of a Java application, the hashCode method must consistently return the same integer, provided no information used in equals comparisons on the object is modified. This integer need not remain consistent from one execution of an application to another execution of the same application.
If two objects are equal according to the equals method, then calling the hashCode method on each of the two objects must produce the same integer result.
It is not required that if two objects are unequal according to the equals method, then calling the hashCode method on each of the two objects must produce distinct integer results. However, the programmer should be aware that producing distinct integer results for unequal objects may improve the performance of hash tables.

Returns:int

a hash code value for this object.

Annotations

@Override

Modifier and Type	Field and Description
private final Function<Schema, Class<T>>	findStringClass
private final Map<GenericDatumReader.IdentitySchemaKey, Class<T>>	stringClassCache
private final Map<Class<T>, Function<String, Object>>	stringCtorCache

Modifier and Type	Method and Description
private Function<String, Object>	buildFunction(Class<T> c)
public Class<T>	getStringClass(final Schema s)
public Object	newInstanceFromString(Class<T> c, String s)

public Class GenericDatumReader<D>

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private final Class GenericDatumReader.IdentitySchemaKey

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv Class GenericDatumReader.ReaderCache

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail