Package | Description |
---|---|
org.apache.hadoop.hive.llap.io.api.impl | |
org.apache.hadoop.hive.ql.exec.vector | |
org.apache.hadoop.hive.ql.exec.vector.expressions | |
org.apache.orc.impl |
Modifier and Type | Field and Description |
---|---|
ColumnVector[] |
ColumnVectorBatch.cols |
Modifier and Type | Method and Description |
---|---|
void |
ColumnVectorBatch.swapColumnVector(int ix,
ColumnVector[] other,
int otherIx) |
Modifier and Type | Class and Description |
---|---|
class |
BytesColumnVector
This class supports string and binary data by value reference -- i.e.
|
class |
DecimalColumnVector |
class |
DoubleColumnVector
This class represents a nullable double precision floating point column vector.
|
class |
IntervalDayTimeColumnVector
This class represents a nullable interval day time column vector capable of handing a
wide range of interval day time values.
|
class |
ListColumnVector
The representation of a vectorized column of list objects.
|
class |
LongColumnVector
This class represents a nullable int column vector.
|
class |
MapColumnVector
The representation of a vectorized column of map objects.
|
class |
MultiValuedColumnVector
The representation of a vectorized column of multi-valued objects, such
as lists and maps.
|
class |
StructColumnVector
The representation of a vectorized column of struct objects.
|
class |
TimestampColumnVector
This class represents a nullable timestamp column vector capable of handing a wide range of
timestamp values.
|
class |
UnionColumnVector
The representation of a vectorized column of struct objects.
|
Modifier and Type | Field and Description |
---|---|
ColumnVector |
ListColumnVector.child |
ColumnVector[] |
VectorizedRowBatch.cols |
ColumnVector[] |
UnionColumnVector.fields |
ColumnVector[] |
StructColumnVector.fields |
ColumnVector |
MapColumnVector.keys |
ColumnVector |
MapColumnVector.values |
Modifier and Type | Method and Description |
---|---|
static ColumnVector |
VectorizedBatchUtil.createColumnVector(String typeName) |
static ColumnVector |
VectorizedBatchUtil.createColumnVector(TypeInfo typeInfo) |
Modifier and Type | Method and Description |
---|---|
void |
UnionColumnVector.setElement(int outElementNum,
int inputElementNum,
ColumnVector inputVector) |
void |
TimestampColumnVector.setElement(int outElementNum,
int inputElementNum,
ColumnVector inputVector) |
void |
StructColumnVector.setElement(int outElementNum,
int inputElementNum,
ColumnVector inputVector) |
void |
MapColumnVector.setElement(int outElementNum,
int inputElementNum,
ColumnVector inputVector) |
void |
LongColumnVector.setElement(int outElementNum,
int inputElementNum,
ColumnVector inputVector) |
void |
ListColumnVector.setElement(int outElementNum,
int inputElementNum,
ColumnVector inputVector) |
void |
IntervalDayTimeColumnVector.setElement(int outElementNum,
int inputElementNum,
ColumnVector inputVector) |
void |
DoubleColumnVector.setElement(int outElementNum,
int inputElementNum,
ColumnVector inputVector) |
void |
DecimalColumnVector.setElement(int outElementNum,
int inputElementNum,
ColumnVector inputVector) |
abstract void |
ColumnVector.setElement(int outElementNum,
int inputElementNum,
ColumnVector inputVector)
Set the element in this column vector from the given input vector.
|
void |
BytesColumnVector.setElement(int outElementNum,
int inputElementNum,
ColumnVector inputVector) |
static void |
VectorizedBatchUtil.setNullColIsNullValue(ColumnVector cv,
int rowIndex)
Sets the IsNull value for ColumnVector at specified index
|
Constructor and Description |
---|
ListColumnVector(int len,
ColumnVector child)
Constructor for ListColumnVector.
|
MapColumnVector(int len,
ColumnVector keys,
ColumnVector values)
Constructor for MapColumnVector
|
StructColumnVector(int len,
ColumnVector... fields)
Constructor for StructColumnVector
|
UnionColumnVector(int len,
ColumnVector... fields)
Constructor for UnionColumnVector
|
Modifier and Type | Method and Description |
---|---|
protected int |
VectorUDFDateDiffScalarCol.evaluateDate(ColumnVector columnVector,
int index) |
protected int |
VectorUDFDateDiffColScalar.evaluateDate(ColumnVector columnVector,
int index) |
protected long |
VectorUDFDateAddColScalar.evaluateDate(ColumnVector columnVector,
int index) |
protected long |
VectorUDFDateAddColCol.evaluateDate(ColumnVector columnVector,
int index,
long numDays) |
protected void |
VectorUDFDateDiffScalarCol.evaluateString(ColumnVector columnVector,
LongColumnVector output,
int i) |
protected void |
VectorUDFDateDiffColScalar.evaluateString(ColumnVector columnVector,
LongColumnVector output,
int i) |
protected void |
VectorUDFDateAddColScalar.evaluateString(ColumnVector columnVector,
LongColumnVector outputVector,
int i) |
protected int |
VectorUDFDateDiffScalarCol.evaluateTimestamp(ColumnVector columnVector,
int index) |
protected int |
VectorUDFDateDiffColScalar.evaluateTimestamp(ColumnVector columnVector,
int index) |
protected long |
VectorUDFDateAddColScalar.evaluateTimestamp(ColumnVector columnVector,
int index) |
protected long |
VectorUDFDateAddColCol.evaluateTimestamp(ColumnVector columnVector,
int index,
long numDays) |
static int |
NullUtil.filterNulls(ColumnVector v,
boolean selectedInUse,
int[] sel,
int n)
Filter out rows with null values.
|
static void |
NullUtil.initOutputNullsToFalse(ColumnVector v,
boolean isRepeating,
boolean selectedInUse,
int[] sel,
int n) |
static void |
NullUtil.propagateNullsColCol(ColumnVector inputColVector1,
ColumnVector inputColVector2,
ColumnVector outputColVector,
int[] sel,
int n,
boolean selectedInUse) |
static void |
NullUtil.setNullOutputEntriesColScalar(ColumnVector v,
boolean selectedInUse,
int[] sel,
int n) |
Object |
VectorExpressionWriter.setValue(Object row,
ColumnVector column,
int columnRow) |
Object |
VectorExpressionWriter.writeValue(ColumnVector column,
int row) |
Modifier and Type | Method and Description |
---|---|
void |
ConvertTreeReaderFactory.ConvertTreeReader.convertVector(ColumnVector fromColVector,
ColumnVector resultColVector,
int batchSize) |
void |
TreeReaderFactory.TreeReader.nextVector(ColumnVector previous,
boolean[] isNull,
int batchSize)
Populates the isNull vector array in the previousVector object based on
the present stream values.
|
void |
TreeReaderFactory.NullTreeReader.nextVector(ColumnVector vector,
boolean[] isNull,
int size) |
void |
TreeReaderFactory.BooleanTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
TreeReaderFactory.ByteTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
TreeReaderFactory.ShortTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
TreeReaderFactory.IntTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
TreeReaderFactory.LongTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
TreeReaderFactory.FloatTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
TreeReaderFactory.DoubleTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
TreeReaderFactory.BinaryTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
TreeReaderFactory.TimestampTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
TreeReaderFactory.DateTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
TreeReaderFactory.DecimalTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
TreeReaderFactory.StringTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
TreeReaderFactory.StringDirectTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
TreeReaderFactory.StringDictionaryTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
TreeReaderFactory.CharTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
TreeReaderFactory.VarcharTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
TreeReaderFactory.StructTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
TreeReaderFactory.UnionTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
TreeReaderFactory.ListTreeReader.nextVector(ColumnVector previous,
boolean[] isNull,
int batchSize) |
void |
TreeReaderFactory.MapTreeReader.nextVector(ColumnVector previous,
boolean[] isNull,
int batchSize) |
void |
ConvertTreeReaderFactory.AnyIntegerTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
ConvertTreeReaderFactory.AnyIntegerFromAnyIntegerTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
ConvertTreeReaderFactory.AnyIntegerFromFloatTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
ConvertTreeReaderFactory.AnyIntegerFromDoubleTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
ConvertTreeReaderFactory.AnyIntegerFromDecimalTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
ConvertTreeReaderFactory.AnyIntegerFromStringGroupTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
ConvertTreeReaderFactory.AnyIntegerFromTimestampTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
ConvertTreeReaderFactory.FloatFromAnyIntegerTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
ConvertTreeReaderFactory.FloatFromDoubleTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
ConvertTreeReaderFactory.FloatFromDecimalTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
ConvertTreeReaderFactory.FloatFromStringGroupTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
ConvertTreeReaderFactory.FloatFromTimestampTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
ConvertTreeReaderFactory.DoubleFromAnyIntegerTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
ConvertTreeReaderFactory.DoubleFromFloatTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
ConvertTreeReaderFactory.DoubleFromDecimalTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
ConvertTreeReaderFactory.DoubleFromStringGroupTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
ConvertTreeReaderFactory.DoubleFromTimestampTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
ConvertTreeReaderFactory.DecimalFromAnyIntegerTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
ConvertTreeReaderFactory.DecimalFromFloatTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
ConvertTreeReaderFactory.DecimalFromDoubleTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
ConvertTreeReaderFactory.DecimalFromStringGroupTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
ConvertTreeReaderFactory.DecimalFromTimestampTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
ConvertTreeReaderFactory.DecimalFromDecimalTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
ConvertTreeReaderFactory.StringGroupFromAnyIntegerTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
ConvertTreeReaderFactory.StringGroupFromFloatTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
ConvertTreeReaderFactory.StringGroupFromDoubleTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
ConvertTreeReaderFactory.StringGroupFromDecimalTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
ConvertTreeReaderFactory.StringGroupFromTimestampTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
ConvertTreeReaderFactory.StringGroupFromDateTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
ConvertTreeReaderFactory.StringGroupFromStringGroupTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
ConvertTreeReaderFactory.StringGroupFromBinaryTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
ConvertTreeReaderFactory.TimestampFromAnyIntegerTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
ConvertTreeReaderFactory.TimestampFromFloatTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
ConvertTreeReaderFactory.TimestampFromDoubleTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
ConvertTreeReaderFactory.TimestampFromDecimalTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
ConvertTreeReaderFactory.TimestampFromStringGroupTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
ConvertTreeReaderFactory.TimestampFromDateTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
ConvertTreeReaderFactory.DateFromStringGroupTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
ConvertTreeReaderFactory.DateFromTimestampTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
ConvertTreeReaderFactory.BinaryFromStringGroupTreeReader.nextVector(ColumnVector previousVector,
boolean[] isNull,
int batchSize) |
void |
RunLengthIntegerReaderV2.nextVector(ColumnVector vector,
int[] data,
int size) |
void |
RunLengthIntegerReader.nextVector(ColumnVector vector,
int[] data,
int size) |
void |
IntegerReader.nextVector(ColumnVector column,
int[] data,
int length)
Return the next available vector for values.
|
void |
RunLengthIntegerReaderV2.nextVector(ColumnVector previous,
long[] data,
int previousLen) |
void |
RunLengthIntegerReader.nextVector(ColumnVector previous,
long[] data,
int previousLen) |
void |
IntegerReader.nextVector(ColumnVector column,
long[] data,
int length)
Return the next available vector for values.
|
void |
RunLengthByteReader.nextVector(ColumnVector previous,
long[] data,
long size) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.