A general purpose reader of data from avro streams. This reader analyzes and resolves the reader and writer schemas when constructed so that reads can be more efficient. Once constructed, a reader can be reused or shared among threads to avoid incurring more resolution costs. More...

Inheritance diagram for Avro.Generic.PreresolvingDatumReader< T >:

Classes
interface	ArrayAccess
	Defines the interface for a class that provides access to an array implementation. More...

interface	EnumAccess
	Defines the interface for a class that provides access to an enum implementation. More...

interface	FixedAccess
	Defines the interface for a class that provides access to a fixed implementation. More...

interface	MapAccess
	Defines the interface for a class that provides access to a map implementation. More...

interface	RecordAccess
	Defines the interface for a class that provides access to a record implementation. More...

Public Member Functions

T Read (T reuse, Decoder decoder)

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.

Parameters

reuse	Optional object to deserialize the datum into. May be null.
decoder	Decoder to read data from.

Returns: Deserialized datum.

Protected Member Functions
delegate object	ReadItem (object reuse, Decoder dec)
	Defines the signature for a function that reads an item from a decoder.

	PreresolvingDatumReader (Schema writerSchema, Schema readerSchema)
	Initializes a new instance of the PreresolvingDatumReader<T> class.

ArrayAccess	GetArrayAccess (ArraySchema readerSchema)
	Returns an ArrayAccess implementation for the given schema.

EnumAccess	GetEnumAccess (EnumSchema readerSchema)
	Returns an EnumAccess implementation for the given schema.

MapAccess	GetMapAccess (MapSchema readerSchema)
	Returns a MapAccess implementation for the given schema.

RecordAccess	GetRecordAccess (RecordSchema readerSchema)
	Returns a RecordAccess implementation for the given schema.

FixedAccess	GetFixedAccess (FixedSchema readerSchema)
	Returns a FixedAccess implementation for the given schema.

virtual bool	IsReusable (Schema.Type tag)
	Indicates if it's possible to reuse an object of the specified type. Generally false for immutable objects like int, long, string, etc but may differ between the Specific and Generic implementations. Used to avoid retrieving the existing value if it's not reusable.

Static Protected Member Functions
static Schema	FindBranch (UnionSchema us, Schema s)
	Finds the branch of the union schema associated with the given schema.

Properties
Schema	ReaderSchema `[get]`
	Schema used to read the data.

Schema	WriterSchema `[get]`
	Schema that was used to write the data.

Properties inherited from Avro.Generic.DatumReader< T >

Detailed Description

A general purpose reader of data from avro streams. This reader analyzes and resolves the reader and writer schemas when constructed so that reads can be more efficient. Once constructed, a reader can be reused or shared among threads to avoid incurring more resolution costs.

Constructor & Destructor Documentation

◆ PreresolvingDatumReader()

Avro.Generic.PreresolvingDatumReader< T >.PreresolvingDatumReader	(	Schema	writerSchema,
		Schema	readerSchema
	)

inlineprotected

Initializes a new instance of the PreresolvingDatumReader<T> class.

Parameters

writerSchema	Schema that was used to write the data.
readerSchema	Schema to use to read the data.

Member Function Documentation

◆ FindBranch()

static Schema Avro.Generic.PreresolvingDatumReader< T >.FindBranch	(	UnionSchema	us,
		Schema	s
	)

inlinestaticprotected

Finds the branch of the union schema associated with the given schema.

Parameters

us	Union schema.
s	Schema to find in the union schema.

Returns: Schema branch in the union schema.

◆ GetArrayAccess()

ArrayAccess Avro.Generic.PreresolvingDatumReader< T >.GetArrayAccess ( ArraySchema readerSchema )

abstractprotected

Returns an ArrayAccess implementation for the given schema.

Parameters

readerSchema Schema for the array.

Returns: An ArrayAccess implementation.

◆ GetEnumAccess()

EnumAccess Avro.Generic.PreresolvingDatumReader< T >.GetEnumAccess ( EnumSchema readerSchema )

abstractprotected

Returns an EnumAccess implementation for the given schema.

Parameters

readerSchema Schema for the enum.

Returns: An EnumAccess implementation.

◆ GetFixedAccess()

FixedAccess Avro.Generic.PreresolvingDatumReader< T >.GetFixedAccess ( FixedSchema readerSchema )

abstractprotected

Returns a FixedAccess implementation for the given schema.

Parameters

readerSchema Schema for the fixed.

Returns: A FixedAccess implementation.

◆ GetMapAccess()

MapAccess Avro.Generic.PreresolvingDatumReader< T >.GetMapAccess ( MapSchema readerSchema )

abstractprotected

Returns a MapAccess implementation for the given schema.

Parameters

readerSchema Schema for the map.

Returns: A MapAccess implementation.

◆ GetRecordAccess()

RecordAccess Avro.Generic.PreresolvingDatumReader< T >.GetRecordAccess ( RecordSchema readerSchema )

abstractprotected

Returns a RecordAccess implementation for the given schema.

Parameters

readerSchema Schema for the record.

Returns: A RecordAccess implementation.

◆ IsReusable()

virtual bool Avro.Generic.PreresolvingDatumReader< T >.IsReusable ( Schema::Type tag )

inlineprotectedvirtual

Indicates if it's possible to reuse an object of the specified type. Generally false for immutable objects like int, long, string, etc but may differ between the Specific and Generic implementations. Used to avoid retrieving the existing value if it's not reusable.

Parameters

tag	Schema type to test for reusability.

Reimplemented in Avro.Generic.GenericDatumReader< T >, and Avro.Specific.SpecificDatumReader< T >.

◆ Read()

T Avro.Generic.PreresolvingDatumReader< T >.Read	(	T	reuse,
		Decoder	decoder
	)

inline

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.

Parameters

reuse	Optional object to deserialize the datum into. May be null.
decoder	Decoder to read data from.

Returns: Deserialized datum.

Implements Avro.Generic.DatumReader< T >.

◆ ReadItem()

delegate object Avro.Generic.PreresolvingDatumReader< T >.ReadItem	(	object	reuse,
		Decoder	dec
	)

protected

Defines the signature for a function that reads an item from a decoder.

Parameters

reuse	Optional object to deserialize the datum into. May be null.
dec	Decoder to read data from.

Returns: Deserialized datum.

Property Documentation

◆ ReaderSchema

Schema Avro.Generic.PreresolvingDatumReader< T >.ReaderSchema

get

Schema used to read the data.

Implements Avro.Generic.DatumReader< T >.

◆ WriterSchema

Schema Avro.Generic.PreresolvingDatumReader< T >.WriterSchema

get

Schema that was used to write the data.

Implements Avro.Generic.DatumReader< T >.

The documentation for this class was generated from the following file:

src/apache/main/Generic/PreresolvingDatumReader.cs

Classes

Public Member Functions

Protected Member Functions

Static Protected Member Functions

Properties

Detailed Description

Constructor & Destructor Documentation

◆ PreresolvingDatumReader()

Member Function Documentation

◆ FindBranch()

◆ GetArrayAccess()

◆ GetEnumAccess()

◆ GetFixedAccess()

◆ GetMapAccess()

◆ GetRecordAccess()

◆ IsReusable()

◆ Read()

◆ ReadItem()

Property Documentation

◆ ReaderSchema

◆ WriterSchema