Package org.apache.iceberg.parquet
Class ParquetValueReaders.StructReader<T,I>
- java.lang.Object
-
- org.apache.iceberg.parquet.ParquetValueReaders.StructReader<T,I>
-
- All Implemented Interfaces:
ParquetValueReader<T>
- Enclosing class:
- ParquetValueReaders
public abstract static class ParquetValueReaders.StructReader<T,I> extends java.lang.Object implements ParquetValueReader<T>
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
StructReader(java.util.List<org.apache.parquet.schema.Type> types, java.util.List<ParquetValueReader<?>> readers)
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description protected abstract T
buildStruct(I struct)
org.apache.iceberg.parquet.TripleIterator<?>
column()
java.util.List<org.apache.iceberg.parquet.TripleIterator<?>>
columns()
protected abstract java.lang.Object
getField(I intermediate, int pos)
protected abstract I
newStructData(T reuse)
T
read(T reuse)
protected abstract void
set(I struct, int pos, java.lang.Object value)
Used to set a struct value by position.protected void
setBoolean(I struct, int pos, boolean value)
protected void
setDouble(I struct, int pos, double value)
protected void
setFloat(I struct, int pos, float value)
protected void
setInteger(I struct, int pos, int value)
protected void
setLong(I struct, int pos, long value)
protected void
setNull(I struct, int pos)
void
setPageSource(org.apache.parquet.column.page.PageReadStore pageStore, long rowPosition)
-
-
-
Constructor Detail
-
StructReader
protected StructReader(java.util.List<org.apache.parquet.schema.Type> types, java.util.List<ParquetValueReader<?>> readers)
-
-
Method Detail
-
setPageSource
public final void setPageSource(org.apache.parquet.column.page.PageReadStore pageStore, long rowPosition)
- Specified by:
setPageSource
in interfaceParquetValueReader<T>
-
column
public final org.apache.iceberg.parquet.TripleIterator<?> column()
- Specified by:
column
in interfaceParquetValueReader<T>
-
read
public final T read(T reuse)
- Specified by:
read
in interfaceParquetValueReader<T>
-
columns
public java.util.List<org.apache.iceberg.parquet.TripleIterator<?>> columns()
- Specified by:
columns
in interfaceParquetValueReader<T>
-
getField
protected abstract java.lang.Object getField(I intermediate, int pos)
-
set
protected abstract void set(I struct, int pos, java.lang.Object value)
Used to set a struct value by position.To avoid boxing, override
setInteger(Object, int, int)
and similar methods.- Parameters:
struct
- a struct object created bynewStructData(Object)
pos
- the position in the struct to setvalue
- the value to set
-
setNull
protected void setNull(I struct, int pos)
-
setBoolean
protected void setBoolean(I struct, int pos, boolean value)
-
setInteger
protected void setInteger(I struct, int pos, int value)
-
setLong
protected void setLong(I struct, int pos, long value)
-
setFloat
protected void setFloat(I struct, int pos, float value)
-
setDouble
protected void setDouble(I struct, int pos, double value)
-
-