Modifier and Type | Method and Description |
---|---|
ColumnVector |
Arrow2PaimonVectorConverter.convertVector(org.apache.arrow.vector.FieldVector vector) |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
ArrowFieldWriter.doWrite(ColumnVector columnVector,
int[] pickedInColumn,
int startIndex,
int batchRows) |
protected void |
ArrowFieldWriters.StringWriter.doWrite(ColumnVector columnVector,
int[] pickedInColumn,
int startIndex,
int batchRows) |
protected void |
ArrowFieldWriters.BooleanWriter.doWrite(ColumnVector columnVector,
int[] pickedInColumn,
int startIndex,
int batchRows) |
protected void |
ArrowFieldWriters.BinaryWriter.doWrite(ColumnVector columnVector,
int[] pickedInColumn,
int startIndex,
int batchRows) |
protected void |
ArrowFieldWriters.DecimalWriter.doWrite(ColumnVector columnVector,
int[] pickedInColumn,
int startIndex,
int batchRows) |
protected void |
ArrowFieldWriters.TinyIntWriter.doWrite(ColumnVector columnVector,
int[] pickedInColumn,
int startIndex,
int batchRows) |
protected void |
ArrowFieldWriters.SmallIntWriter.doWrite(ColumnVector columnVector,
int[] pickedInColumn,
int startIndex,
int batchRows) |
protected void |
ArrowFieldWriters.IntWriter.doWrite(ColumnVector columnVector,
int[] pickedInColumn,
int startIndex,
int batchRows) |
protected void |
ArrowFieldWriters.BigIntWriter.doWrite(ColumnVector columnVector,
int[] pickedInColumn,
int startIndex,
int batchRows) |
protected void |
ArrowFieldWriters.FloatWriter.doWrite(ColumnVector columnVector,
int[] pickedInColumn,
int startIndex,
int batchRows) |
protected void |
ArrowFieldWriters.DoubleWriter.doWrite(ColumnVector columnVector,
int[] pickedInColumn,
int startIndex,
int batchRows) |
protected void |
ArrowFieldWriters.DateWriter.doWrite(ColumnVector columnVector,
int[] pickedInColumn,
int startIndex,
int batchRows) |
protected void |
ArrowFieldWriters.TimeWriter.doWrite(ColumnVector columnVector,
int[] pickedInColumn,
int startIndex,
int batchRows) |
protected void |
ArrowFieldWriters.TimestampWriter.doWrite(ColumnVector columnVector,
int[] pickedInColumn,
int startIndex,
int batchRows) |
protected void |
ArrowFieldWriters.ArrayWriter.doWrite(ColumnVector columnVector,
int[] pickedInColumn,
int startIndex,
int batchRows) |
protected void |
ArrowFieldWriters.MapWriter.doWrite(ColumnVector columnVector,
int[] pickedInColumn,
int startIndex,
int batchRows) |
protected void |
ArrowFieldWriters.RowWriter.doWrite(ColumnVector columnVector,
int[] pickedInColumn,
int startIndex,
int batchRows) |
void |
ArrowFieldWriter.write(ColumnVector columnVector,
int[] pickedInColumn,
int startIndex,
int batchRows)
Write all data of a
ColumnVector . |
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 |
Modifier and Type | Method and Description |
---|---|
ColumnVector |
ArrayColumnVector.getColumnVector() |
ColumnVector |
MapColumnVector.getKeyColumnVector() |
ColumnVector |
MapColumnVector.getValueColumnVector() |
Modifier and Type | Method and Description |
---|---|
ColumnarRow |
ColumnarRow.copy(ColumnVector[] vectors) |
VectorizedColumnBatch |
VectorizedColumnBatch.copy(ColumnVector[] vectors) |
ColumnarRowIterator |
ColumnarRowIterator.copy(ColumnVector[] vectors) |
Constructor and Description |
---|
ColumnarArray(ColumnVector data,
int offset,
int numElements) |
ColumnarMap(ColumnVector keyColumnVector,
ColumnVector valueColumnVector,
int offset,
int numElements) |
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() |
ColumnVector |
HeapArrayVector.getColumnVector() |
ColumnVector |
HeapMapVector.getKeyColumnVector() |
ColumnVector |
HeapMapVector.getValueColumnVector() |
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 | Class and Description |
---|---|
class |
AbstractOrcColumnVector
This column vector is used to adapt hive's ColumnVector to Paimon's ColumnVector.
|
class |
OrcArrayColumnVector
This column vector is used to adapt hive's ListColumnVector to Paimon's ArrayColumnVector.
|
class |
OrcBytesColumnVector
This column vector is used to adapt hive's BytesColumnVector to Paimon's BytesColumnVector.
|
class |
OrcDecimalColumnVector
This column vector is used to adapt hive's DecimalColumnVector to Paimon's DecimalColumnVector.
|
class |
OrcDoubleColumnVector
This column vector is used to adapt hive's DoubleColumnVector to Paimon'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 Paimon's boolean, byte, short, int
and long ColumnVector.
|
class |
OrcMapColumnVector
This column vector is used to adapt hive's MapColumnVector to Paimon'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 Paimon's
TimestampColumnVector.
|
Modifier and Type | Method and Description |
---|---|
static ColumnVector |
AbstractOrcColumnVector.createPaimonVector(org.apache.hadoop.hive.ql.exec.vector.ColumnVector vector,
DataType dataType) |
ColumnVector |
OrcArrayColumnVector.getColumnVector() |
ColumnVector |
OrcMapColumnVector.getKeyColumnVector() |
ColumnVector |
OrcMapColumnVector.getValueColumnVector() |
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. |
class |
ParquetTimestampVector
Parquet write timestamp precision 0-3 as int64 mills, 4-6 as int64 micros, 7-9 as int96, this
class wrap the real vector to provide
TimestampColumnVector interface. |
Modifier and Type | Method and Description |
---|---|
ColumnVector |
ParquetDecimalVector.getVector() |
ColumnVector |
ParquetTimestampVector.getVector() |
Constructor and Description |
---|
ParquetDecimalVector(ColumnVector vector) |
ParquetTimestampVector(ColumnVector vector) |
Modifier and Type | Method and Description |
---|---|
static ColumnVector |
VectorMappingUtils.createFixedVector(DataType dataType,
BinaryRow partition,
int index) |
static ColumnVector[] |
VectorMappingUtils.createIndexMappedVectors(int[] indexMapping,
ColumnVector[] vectors) |
static ColumnVector[] |
VectorMappingUtils.createPartitionMappedVectors(PartitionInfo partitionInfo,
ColumnVector[] vectors) |
Modifier and Type | Method and Description |
---|---|
static ColumnVector[] |
VectorMappingUtils.createIndexMappedVectors(int[] indexMapping,
ColumnVector[] vectors) |
static ColumnVector[] |
VectorMappingUtils.createPartitionMappedVectors(PartitionInfo partitionInfo,
ColumnVector[] vectors) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.