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 ReaderEvents
public void bindNullState(NullStateReader nullStateReader)
bindNullState
in interface ReaderEvents
public ObjectType type()
ColumnReader
type
in interface ColumnReader
public ColumnMetadata schema()
schema
in interface ColumnReader
public NullStateReader nullStateReader()
nullStateReader
in interface ReaderEvents
public boolean isNull()
ColumnReader
isNull
in interface ColumnReader
public void reposition()
reposition
in interface ReaderEvents
public boolean next()
ArrayReader
next
in interface ArrayReader
public ColumnReaderIndex elementIndex()
public int size()
ArrayReader
size
in interface ArrayReader
public void setPosn(int posn)
ArrayReader
ArrayReader.entry()
, ArrayReader.tuple()
and ArrayReader.array()
.setPosn
in interface ArrayReader
public void rewind()
rewind
in interface ArrayReader
public void bindBuffer()
bindBuffer
in interface ReaderEvents
public ObjectReader entry()
ArrayReader
ArrayReader.setPosn(int)
to set the position. This form allows
up-front setup of the readers when convenient for the caller.entry
in interface ArrayReader
public ObjectType entryType()
ArrayReader
entryType
in interface ArrayReader
public ScalarReader scalar()
scalar
in interface ArrayReader
public TupleReader tuple()
tuple
in interface ArrayReader
public ArrayReader array()
array
in interface ArrayReader
public VariantReader variant()
variant
in interface ArrayReader
public Object getObject()
ColumnReader
getObject
in interface ColumnReader
public String getAsString()
ColumnReader
getAsString
in interface ColumnReader
Copyright © 1970 The Apache Software Foundation. All rights reserved.