Package org.apache.iceberg.avro
Class GenericAvroReader<T>
- java.lang.Object
-
- org.apache.iceberg.avro.GenericAvroReader<T>
-
- All Implemented Interfaces:
org.apache.avro.io.DatumReader<T>
,SupportsRowPosition
public class GenericAvroReader<T> extends java.lang.Object implements org.apache.avro.io.DatumReader<T>, SupportsRowPosition
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods 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(java.lang.ClassLoader newClassLoader)
void
setRenames(java.util.Map<java.lang.String,java.lang.String> renames)
void
setRowPositionSupplier(java.util.function.Supplier<java.lang.Long> posSupplier)
void
setSchema(org.apache.avro.Schema schema)
-
-
-
Method Detail
-
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 interfaceorg.apache.avro.io.DatumReader<T>
-
setClassLoader
public void setClassLoader(java.lang.ClassLoader newClassLoader)
-
setRenames
public void setRenames(java.util.Map<java.lang.String,java.lang.String> renames)
-
setRowPositionSupplier
public void setRowPositionSupplier(java.util.function.Supplier<java.lang.Long> posSupplier)
- Specified by:
setRowPositionSupplier
in interfaceSupportsRowPosition
-
-