Package org.apache.iceberg.avro

Class InternalReader<T>

java.lang.Object

org.apache.iceberg.avro.InternalReader<T>

Type Parameters:

T - Java type returned by the reader

All Implemented Interfaces:

org.apache.avro.io.DatumReader<T>, SupportsRowPosition

public class InternalReader<T>
extends java.lang.Object
implements org.apache.avro.io.DatumReader<T>, SupportsRowPosition

A reader that produces Iceberg's internal in-memory object model.

Iceberg's internal in-memory object model produces the types defined in Type.TypeID.javaClass().

Method Summary

Modifier and Type	Method	Description
static <D> InternalReader<D>	create(Schema schema)
T	read(T reuse, org.apache.avro.io.Decoder decoder)
InternalReader<T>	setCustomType(int fieldId, java.lang.Class<? extends StructLike> structClass)
InternalReader<T>	setRootType(java.lang.Class<? extends StructLike> rootClass)
void	setRowPositionSupplier(java.util.function.Supplier<java.lang.Long> posSupplier)
void	setSchema(org.apache.avro.Schema schema)

Methods inherited from class java.lang.Object

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

Method Detail

create

public static <D> InternalReader<D> create(Schema schema)

setSchema

public void setSchema(org.apache.avro.Schema schema)

Specified by:

setSchema in interface org.apache.avro.io.DatumReader<T>

setRootType

public InternalReader<T> setRootType(java.lang.Class<? extends StructLike> rootClass)

setCustomType

public InternalReader<T> setCustomType(int fieldId,
                                       java.lang.Class<? extends StructLike> structClass)

setRowPositionSupplier

public void setRowPositionSupplier(java.util.function.Supplier<java.lang.Long> posSupplier)

Specified by:

setRowPositionSupplier in interface SupportsRowPosition

read

public T read(T reuse,
              org.apache.avro.io.Decoder decoder)
       throws java.io.IOException

Specified by:

read in interface org.apache.avro.io.DatumReader<T>

Throws:

java.io.IOException