Package org.apache.iceberg.orc

Class OrcValueReaders.StructReader<T>

java.lang.Object

org.apache.iceberg.orc.OrcValueReaders.StructReader<T>

All Implemented Interfaces:

OrcValueReader<T>

Enclosing class:

OrcValueReaders

public abstract static class OrcValueReaders.StructReader<T>
extends Object
implements OrcValueReader<T>

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	StructReader(List<OrcValueReader<?>> readers, Types.StructType struct, Map<Integer,?> idToConstant)	Deprecated. Use StructReader(TypeDescription, List, Types.StructType, Map) instead.
protected	StructReader(org.apache.orc.TypeDescription orcType, List<OrcValueReader<?>> readers, Types.StructType struct, Map<Integer,?> idToConstant)

Method Summary

Modifier and Type	Method	Description
protected abstract T	create()
T	nonNullRead(org.apache.orc.storage.ql.exec.vector.ColumnVector vector, int row)
OrcValueReader<?>	reader(int pos)
protected abstract void	set(T struct, int pos, Object value)
void	setBatchContext(long batchOffsetInFile)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.iceberg.orc.OrcValueReader

read

Constructor Details

StructReader

@Deprecated
protected StructReader(List<OrcValueReader<?>> readers,
 Types.StructType struct,
 Map<Integer,?> idToConstant)

Deprecated.

Use StructReader(TypeDescription, List, Types.StructType, Map) instead. This constructor uses position-based binding which may cause field misalignment in MOR scenarios. This doesn't work lineage scenarios.

Parameters:

readers - readers for each field

struct - struct type

idToConstant - constant values by field id

StructReader

protected StructReader(org.apache.orc.TypeDescription orcType,
 List<OrcValueReader<?>> readers,
 Types.StructType struct,
 Map<Integer,?> idToConstant)

Method Details

create

protected abstract T create()

set

protected abstract void set(T struct,
 int pos,
 Object value)

reader

public OrcValueReader<?> reader(int pos)

nonNullRead

public T nonNullRead(org.apache.orc.storage.ql.exec.vector.ColumnVector vector,
 int row)

Specified by:

nonNullRead in interface OrcValueReader<T>

setBatchContext

public void setBatchContext(long batchOffsetInFile)

Specified by:

setBatchContext in interface OrcValueReader<T>