GenericAvroReader

java.lang.Object

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

All Implemented Interfaces:: org.apache.avro.io.DatumReader<T>, SupportsRowPosition

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

Method Summary

Modifier and Type

Method

Description

static <D> GenericAvroReader<D>

create(org.apache.avro.Schema readSchema)

static <D> GenericAvroReader<D>

create(Schema expectedSchema)

T

read(T reuse, org.apache.avro.io.Decoder decoder)

void

setClassLoader(ClassLoader newClassLoader)

void

setRenames(Map<String,String> renames)

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> GenericAvroReader<D> create(Schema expectedSchema)
- create
  
  public static <D> GenericAvroReader<D> create(org.apache.avro.Schema readSchema)
- setSchema
  
  public void setSchema(org.apache.avro.Schema schema)
  
  Specified by:
  
  setSchema in interface org.apache.avro.io.DatumReader<T>
- setClassLoader
  
  public void setClassLoader(ClassLoader newClassLoader)
- setRenames
  
  public void setRenames(Map<String,String> renames)
- 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