Package | Description |
---|---|
org.apache.flink.orc.vector | |
org.apache.flink.table.dataformat.vector | |
org.apache.flink.table.dataformat.vector.heap |
Modifier and Type | Class and Description |
---|---|
class |
AbstractOrcColumnVector
This column vector is used to adapt hive's ColumnVector to Flink's ColumnVector.
|
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 |
OrcLongColumnVector
This column vector is used to adapt hive's LongColumnVector to
Flink's boolean, byte, short, int and long ColumnVector.
|
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.createVector(org.apache.hadoop.hive.ql.exec.vector.ColumnVector vector) |
static ColumnVector |
AbstractOrcColumnVector.createVectorFromConstant(LogicalType type,
Object value,
int batchSize)
Create flink vector by hive vector from constant.
|
Modifier and Type | Interface and Description |
---|---|
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 |
ShortColumnVector
Short column vector.
|
interface |
TimestampColumnVector
Timestamp column vector.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractColumnVector
Contains the shared structure for
ColumnVector s, including NULL information and dictionary. |
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 |
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.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.