Modifier and Type | Method and Description |
---|---|
protected ParquetVectorizedInputFormat.ParquetReaderBatch<RowData> |
ParquetColumnarRowInputFormat.createReaderBatch(WritableColumnVector[] writableVectors,
VectorizedColumnBatch columnarBatch,
Pool.Recycler<ParquetVectorizedInputFormat.ParquetReaderBatch<RowData>> recycler) |
protected abstract ParquetVectorizedInputFormat.ParquetReaderBatch<T> |
ParquetVectorizedInputFormat.createReaderBatch(WritableColumnVector[] writableVectors,
VectorizedColumnBatch columnarBatch,
Pool.Recycler<ParquetVectorizedInputFormat.ParquetReaderBatch<T>> recycler) |
Constructor and Description |
---|
ParquetReaderBatch(WritableColumnVector[] writableVectors,
VectorizedColumnBatch columnarBatch,
Pool.Recycler<ParquetVectorizedInputFormat.ParquetReaderBatch<T>> recycler) |
Modifier and Type | Method and Description |
---|---|
static WritableColumnVector |
ParquetSplitReaderUtil.createWritableColumnVector(int batchSize,
LogicalType fieldType,
org.apache.parquet.schema.PrimitiveType primitiveType) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractColumnReader<VECTOR extends WritableColumnVector>
Abstract
ColumnReader . |
interface |
ColumnReader<VECTOR extends WritableColumnVector>
Read a batch of records for a column to
WritableColumnVector from parquet data file. |
class |
FixedLenBytesColumnReader<VECTOR extends WritableColumnVector>
Fixed length bytes
ColumnReader , just for decimal. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractHeapVector
Heap vector that nullable shared structure.
|
class |
HeapBooleanVector
This class represents a nullable heap boolean column vector.
|
class |
HeapBytesVector
This class supports string and binary data by value reference -- i.e.
|
class |
HeapByteVector
This class represents a nullable byte column vector.
|
class |
HeapDoubleVector
This class represents a nullable double precision floating point column vector.
|
class |
HeapFloatVector
This class represents a nullable double precision floating point column vector.
|
class |
HeapIntVector
This class represents a nullable int column vector.
|
class |
HeapLongVector
This class represents a nullable long column vector.
|
class |
HeapShortVector
This class represents a nullable short column vector.
|
class |
HeapTimestampVector
This class represents a nullable byte column vector.
|
Modifier and Type | Interface and Description |
---|---|
interface |
WritableBooleanVector
Writable
BooleanColumnVector . |
interface |
WritableBytesVector
Writable
BytesColumnVector . |
interface |
WritableByteVector
Writable
ByteColumnVector . |
interface |
WritableDoubleVector
Writable
DoubleColumnVector . |
interface |
WritableFloatVector
Writable
FloatColumnVector . |
interface |
WritableIntVector
Writable
IntColumnVector . |
interface |
WritableLongVector
Writable
LongColumnVector . |
interface |
WritableShortVector
Writable
ShortColumnVector . |
interface |
WritableTimestampVector
Writable
TimestampColumnVector . |
Modifier and Type | Class and Description |
---|---|
class |
AbstractWritableVector
Contains the shared structure for
ColumnVector s, including NULL information and
dictionary. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.