Modifier and Type | Class and Description |
---|---|
class |
ParquetDecimalVector
Parquet write decimal as int32 and int64 and binary, this class wrap the real vector to provide
DecimalColumnVector interface. |
Modifier and Type | Method and Description |
---|---|
static ColumnVector |
ParquetSplitReaderUtil.createVectorFromConstant(LogicalType type,
Object value,
int batchSize) |
ColumnVector |
ParquetDecimalVector.getVector() |
Modifier and Type | Method and Description |
---|---|
VectorizedColumnBatch |
ColumnBatchFactory.create(SplitT split,
ColumnVector[] vectors) |
VectorizedColumnBatch |
ParquetColumnarRowSplitReader.ColumnBatchGenerator.generate(ColumnVector[] readVectors) |
Constructor and Description |
---|
ParquetDecimalVector(ColumnVector vector) |
Modifier and Type | Method and Description |
---|---|
void |
MapColumnReader.readBatch(int total,
ColumnVector column) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractOrcNoHiveVector
This column vector is used to adapt hive's ColumnVector to Flink's ColumnVector.
|
class |
OrcNoHiveBytesVector
This column vector is used to adapt hive's BytesColumnVector to Flink's BytesColumnVector.
|
class |
OrcNoHiveDecimalVector
This column vector is used to adapt hive's DecimalColumnVector to Flink's DecimalColumnVector.
|
class |
OrcNoHiveDoubleVector
This column vector is used to adapt hive's DoubleColumnVector to Flink's float and double
ColumnVector.
|
class |
OrcNoHiveLongVector
This column vector is used to adapt hive's LongColumnVector to Flink's boolean, byte, short, int
and long ColumnVector.
|
class |
OrcNoHiveTimestampVector
This column vector is used to adapt hive's TimestampColumnVector to Flink's
TimestampColumnVector.
|
Modifier and Type | Method and Description |
---|---|
static ColumnVector |
AbstractOrcNoHiveVector.createFlinkVector(org.apache.orc.storage.ql.exec.vector.ColumnVector vector) |
static ColumnVector |
AbstractOrcNoHiveVector.createFlinkVectorFromConstant(LogicalType type,
Object value,
int batchSize)
Create flink vector by hive vector from constant.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractOrcColumnVector
This column vector is used to adapt hive's ColumnVector to Flink's ColumnVector.
|
class |
OrcArrayColumnVector
This column vector is used to adapt hive's ListColumnVector to Flink's ArrayColumnVector.
|
class |
OrcBytesColumnVector
This column vector is used to adapt hive's BytesColumnVector to Flink's BytesColumnVector.
|
class |
OrcDecimalColumnVector
This column vector is used to adapt hive's DecimalColumnVector to Flink's DecimalColumnVector.
|
class |
OrcDoubleColumnVector
This column vector is used to adapt hive's DoubleColumnVector to Flink's float and double
ColumnVector.
|
class |
OrcLegacyTimestampColumnVector
This class is used to adapt to Hive's legacy (2.0.x) timestamp column vector which is a
LongColumnVector.
|
class |
OrcLongColumnVector
This column vector is used to adapt hive's LongColumnVector to Flink's boolean, byte, short, int
and long ColumnVector.
|
class |
OrcMapColumnVector
This column vector is used to adapt hive's MapColumnVector to Flink's MapColumnVector.
|
class |
OrcRowColumnVector
This column vector is used to adapt hive's StructColumnVector to Flink's RowColumnVector.
|
class |
OrcTimestampColumnVector
This column vector is used to adapt hive's TimestampColumnVector to Flink's
TimestampColumnVector.
|
Modifier and Type | Method and Description |
---|---|
static ColumnVector |
AbstractOrcColumnVector.createFlinkVector(org.apache.hadoop.hive.ql.exec.vector.ColumnVector vector,
LogicalType logicalType) |
static ColumnVector |
AbstractOrcColumnVector.createFlinkVectorFromConstant(LogicalType type,
Object value,
int batchSize)
Create flink vector by hive vector from constant.
|
Constructor and Description |
---|
ColumnarArrayData(ColumnVector data,
int offset,
int numElements) |
ColumnarMapData(ColumnVector keyColumnVector,
ColumnVector valueColumnVector,
int offset,
int numElements) |
Modifier and Type | Interface and Description |
---|---|
interface |
ArrayColumnVector
Array column vector.
|
interface |
BooleanColumnVector
Boolean column vector.
|
interface |
ByteColumnVector
Byte column vector.
|
interface |
BytesColumnVector
Bytes column vector to get
BytesColumnVector.Bytes , it include original data and offset and length. |
interface |
DecimalColumnVector
Decimal column vector.
|
interface |
DoubleColumnVector
Double column vector.
|
interface |
FloatColumnVector
Float column vector.
|
interface |
IntColumnVector
Int column vector.
|
interface |
LongColumnVector
Long column vector.
|
interface |
MapColumnVector
Map column vector.
|
interface |
RowColumnVector
Row column vector.
|
interface |
ShortColumnVector
Short column vector.
|
interface |
TimestampColumnVector
Timestamp column vector.
|
Modifier and Type | Field and Description |
---|---|
ColumnVector[] |
VectorizedColumnBatch.columns |
Constructor and Description |
---|
VectorizedColumnBatch(ColumnVector[] vectors) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractHeapVector
Heap vector that nullable shared structure.
|
class |
HeapArrayVector
This class represents a nullable heap array column vector.
|
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 |
HeapMapVector
This class represents a nullable heap map column vector.
|
class |
HeapRowVector
This class represents a nullable heap row 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 | Method and Description |
---|---|
ColumnVector |
HeapArrayVector.getChild() |
Modifier and Type | Method and Description |
---|---|
void |
HeapArrayVector.setChild(ColumnVector child) |
void |
HeapMapVector.setKeys(ColumnVector keys) |
void |
HeapMapVector.setValues(ColumnVector values) |
Constructor and Description |
---|
HeapArrayVector(int len,
ColumnVector vector) |
HeapMapVector(int len,
ColumnVector keys,
ColumnVector values) |
Modifier and Type | Interface and Description |
---|---|
interface |
WritableBooleanVector
Writable
BooleanColumnVector . |
interface |
WritableBytesVector
Writable
BytesColumnVector . |
interface |
WritableByteVector
Writable
ByteColumnVector . |
interface |
WritableColumnVector
Writable
ColumnVector . |
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. |
Modifier and Type | Method and Description |
---|---|
static ColumnVector |
ArrowUtils.createColumnVector(org.apache.arrow.vector.ValueVector vector,
LogicalType fieldType) |
ColumnVector[] |
ArrowReader.getColumnVectors()
Gets the column vectors.
|
Constructor and Description |
---|
ArrowReader(ColumnVector[] columnVectors) |
Modifier and Type | Class and Description |
---|---|
class |
ArrowArrayColumnVector
Arrow column vector for Array.
|
class |
ArrowBigIntColumnVector
Arrow column vector for BigInt.
|
class |
ArrowBooleanColumnVector
Arrow column vector for Boolean.
|
class |
ArrowDateColumnVector
Arrow column vector for Date.
|
class |
ArrowDecimalColumnVector
Arrow column vector for DecimalData.
|
class |
ArrowDoubleColumnVector
Arrow column vector for Double.
|
class |
ArrowFloatColumnVector
Arrow column vector for Float.
|
class |
ArrowIntColumnVector
Arrow column vector for Int.
|
class |
ArrowRowColumnVector
Arrow column vector for Row.
|
class |
ArrowSmallIntColumnVector
Arrow column vector for Int.
|
class |
ArrowTimeColumnVector
Arrow column vector for Time.
|
class |
ArrowTimestampColumnVector
Arrow column vector for Timestamp.
|
class |
ArrowTinyIntColumnVector
Arrow column vector for TinyInt.
|
class |
ArrowVarBinaryColumnVector
Arrow column vector for VarBinary.
|
class |
ArrowVarCharColumnVector
Arrow column vector for VarChar.
|
Constructor and Description |
---|
ArrowArrayColumnVector(org.apache.arrow.vector.complex.ListVector listVector,
ColumnVector elementVector) |
ArrowRowColumnVector(org.apache.arrow.vector.complex.StructVector structVector,
ColumnVector[] fieldColumns) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.