InternalReader

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 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, Class<? extends StructLike> structClass)

InternalReader<T>

setRootType(Class<? extends StructLike> rootClass)

void

setRowPositionSupplier(Supplier<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 Details
- 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(Class<? extends StructLike> rootClass)
- setCustomType
  
  public InternalReader<T> setCustomType(int fieldId, Class<? extends StructLike> structClass)
- setRowPositionSupplier
  
  public void setRowPositionSupplier(Supplier<Long> posSupplier)
  
  Specified by:
  
  setRowPositionSupplier in interface SupportsRowPosition
- read
  
  public T read(T reuse, org.apache.avro.io.Decoder decoder) throws IOException
  
  Specified by:
  
  read in interface org.apache.avro.io.DatumReader<T>
  
  Throws:
  
  IOException