public class ArrayReaderImpl extends Object implements ArrayReader, ReaderEvents
| Modifier and Type | Class and Description |
|---|---|
static class |
ArrayReaderImpl.ArrayObjectReader
Object representation of an array reader.
|
static class |
ArrayReaderImpl.ElementReaderIndex
Index into the vector of elements for a repeated vector.
|
| Modifier and Type | Field and Description |
|---|---|
protected ArrayReaderImpl.ElementReaderIndex |
elementIndex |
protected AbstractObjectReader |
elementReader |
protected NullStateReader |
nullStateReader |
| Constructor and Description |
|---|
ArrayReaderImpl(ColumnMetadata schema,
VectorAccessor va,
AbstractObjectReader elementReader) |
| Modifier and Type | Method and Description |
|---|---|
ArrayReader |
array() |
void |
bindBuffer() |
void |
bindIndex(ColumnReaderIndex index) |
void |
bindNullState(NullStateReader nullStateReader) |
static AbstractObjectReader |
buildList(ColumnMetadata schema,
VectorAccessor listAccessor,
AbstractObjectReader elementReader)
Build a list reader.
|
static AbstractObjectReader |
buildRepeatedList(ColumnMetadata schema,
VectorAccessor listAccessor,
AbstractObjectReader elementReader)
Build a 2+D array reader.
|
static ArrayReaderImpl.ArrayObjectReader |
buildScalar(ColumnMetadata schema,
VectorAccessor arrayAccessor,
BaseScalarReader elementReader)
Build a scalar array for a Repeated type.
|
static AbstractObjectReader |
buildTuple(ColumnMetadata schema,
VectorAccessor arrayAccessor,
AbstractObjectReader elementReader)
Build a repeated map reader.
|
ColumnReaderIndex |
elementIndex() |
ObjectReader |
entry()
Return the generic object reader for the array element.
|
ObjectType |
entryType()
The object type of the list entry.
|
String |
getAsString()
Return the entire object as a string.
|
Object |
getObject()
Return the value of the underlying data as a Java object.
|
boolean |
isNull()
Determine if this value is null.
|
boolean |
next()
Move forward one position.
|
NullStateReader |
nullStateReader() |
void |
reposition() |
void |
rewind() |
ScalarReader |
scalar() |
ColumnMetadata |
schema() |
void |
setPosn(int posn)
Set the array reader to read a given array entry.
|
int |
size()
Number of elements in the array.
|
TupleReader |
tuple() |
ObjectType |
type()
The type of this reader.
|
VariantReader |
variant() |
protected final AbstractObjectReader elementReader
protected ArrayReaderImpl.ElementReaderIndex elementIndex
protected NullStateReader nullStateReader
public ArrayReaderImpl(ColumnMetadata schema, VectorAccessor va, AbstractObjectReader elementReader)
public static ArrayReaderImpl.ArrayObjectReader buildScalar(ColumnMetadata schema, VectorAccessor arrayAccessor, BaseScalarReader elementReader)
arrayAccessor - vector accessor for the repeated vector that holds
the scalar valueselementReader - scalar reader used to decode each scalar valuepublic static AbstractObjectReader buildTuple(ColumnMetadata schema, VectorAccessor arrayAccessor, AbstractObjectReader elementReader)
arrayAccessor - vector accessor for the repeated map vectorelementReader - tuple reader that provides access to each
tuple in the arraypublic static AbstractObjectReader buildList(ColumnMetadata schema, VectorAccessor listAccessor, AbstractObjectReader elementReader)
listAccessor - elementReader - public static AbstractObjectReader buildRepeatedList(ColumnMetadata schema, VectorAccessor listAccessor, AbstractObjectReader elementReader)
schema - listAccessor - elementReader - public void bindIndex(ColumnReaderIndex index)
bindIndex in interface ReaderEventspublic void bindNullState(NullStateReader nullStateReader)
bindNullState in interface ReaderEventspublic ObjectType type()
ColumnReadertype in interface ColumnReaderpublic ColumnMetadata schema()
schema in interface ColumnReaderpublic NullStateReader nullStateReader()
nullStateReader in interface ReaderEventspublic boolean isNull()
ColumnReaderisNull in interface ColumnReaderpublic void reposition()
reposition in interface ReaderEventspublic boolean next()
ArrayReadernext in interface ArrayReaderpublic ColumnReaderIndex elementIndex()
public int size()
ArrayReadersize in interface ArrayReaderpublic void setPosn(int posn)
ArrayReaderArrayReader.entry(), ArrayReader.tuple() and ArrayReader.array().setPosn in interface ArrayReaderpublic void rewind()
rewind in interface ArrayReaderpublic void bindBuffer()
bindBuffer in interface ReaderEventspublic ObjectReader entry()
ArrayReaderArrayReader.setPosn(int) to set the position. This form allows
up-front setup of the readers when convenient for the caller.entry in interface ArrayReaderpublic ObjectType entryType()
ArrayReaderentryType in interface ArrayReaderpublic ScalarReader scalar()
scalar in interface ArrayReaderpublic TupleReader tuple()
tuple in interface ArrayReaderpublic ArrayReader array()
array in interface ArrayReaderpublic VariantReader variant()
variant in interface ArrayReaderpublic Object getObject()
ColumnReadergetObject in interface ColumnReaderpublic String getAsString()
ColumnReadergetAsString in interface ColumnReaderCopyright © 2021 The Apache Software Foundation. All rights reserved.