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 and Description
protected	StructReader(java.util.List<org.apache.parquet.schema.Type> types, java.util.List<ParquetValueReader<?>> readers)

Method Summary

Modifier and Type	Method and 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)

Methods inherited from class java.lang.Object

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

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 interface ParquetValueReader<T>

column

public final org.apache.iceberg.parquet.TripleIterator<?> column()

Specified by:

column in interface ParquetValueReader<T>

read

public final T read(T reuse)

Specified by:

read in interface ParquetValueReader<T>

columns

public java.util.List<org.apache.iceberg.parquet.TripleIterator<?>> columns()

Specified by:

columns in interface ParquetValueReader<T>

newStructData

protected abstract I newStructData(T reuse)

getField

protected abstract java.lang.Object getField(I intermediate,
                                             int pos)

buildStruct

protected abstract T buildStruct(I struct)

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 by newStructData(Object)

pos - the position in the struct to set

value - 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)