Modifier and Type | Field and Description |
---|---|
protected VectorizedRowBatch |
VectorMapJoinBaseOperator.outputBatch |
protected VectorizedRowBatch |
VectorMapJoinBaseOperator.scratchBatch |
Modifier and Type | Method and Description |
---|---|
static VectorizedRowBatch |
VectorizedBatchUtil.constructVectorizedRowBatch(StructObjectInspector oi)
Create VectorizedRowBatch from ObjectInspector
|
static VectorizedRowBatch |
VectorizedBatchUtil.constructVectorizedRowBatch(StructObjectInspector keyInspector,
StructObjectInspector valueInspector)
Create VectorizedRowBatch from key and value object inspectors
|
VectorizedRowBatch |
VectorizedRowBatchCtx.createVectorizedRowBatch()
Creates a Vectorized row batch and the column vectors.
|
static VectorizedRowBatch |
VectorizedBatchUtil.makeLike(VectorizedRowBatch batch)
Make a new (scratch) batch, which is exactly "like" the batch provided, except that it's empty
|
Modifier and Type | Method and Description |
---|---|
static void |
VectorizedBatchUtil.acidAddRowToBatch(Object row,
StructObjectInspector oi,
int rowIndex,
VectorizedRowBatch batch,
VectorizedRowBatchCtx context,
org.apache.hadoop.io.DataOutputBuffer buffer)
Iterates thru all the columns in a given row and populates the batch
from a given offset
|
void |
VectorizedRowBatchCtx.addPartitionColsToBatch(VectorizedRowBatch batch)
Add the partition values to the batch
|
static void |
VectorizedBatchUtil.addProjectedRowToBatchFrom(Object row,
StructObjectInspector oi,
int rowIndex,
VectorizedRowBatch batch,
org.apache.hadoop.io.DataOutputBuffer buffer)
Add only the projected column of a regular row to the specified vectorized row batch
|
void |
VectorizedRowBatchCtx.addRowToBatch(int rowIndex,
org.apache.hadoop.io.Writable rowBlob,
VectorizedRowBatch batch,
org.apache.hadoop.io.DataOutputBuffer buffer)
Adds the row to the batch after deserializing the row
|
static void |
VectorizedBatchUtil.addRowToBatch(Object row,
StructObjectInspector oi,
int rowIndex,
VectorizedRowBatch batch,
org.apache.hadoop.io.DataOutputBuffer buffer)
Iterates through all columns in a given row and populates the batch
|
static void |
VectorizedBatchUtil.addRowToBatchFrom(Object row,
StructObjectInspector oi,
int rowIndex,
int colOffset,
VectorizedRowBatch batch,
org.apache.hadoop.io.DataOutputBuffer buffer)
Iterates thru all the columns in a given row and populates the batch
from a given offset
|
void |
VectorColumnAssign.assignVectorValue(VectorizedRowBatch inBatch,
int batchIndex,
int valueColumn,
int destIndex) |
static VectorColumnAssign[] |
VectorColumnAssignFactory.buildAssigners(VectorizedRowBatch outputBatch) |
static VectorColumnAssign[] |
VectorColumnAssignFactory.buildAssigners(VectorizedRowBatch outputBatch,
ObjectInspector outputOI,
Map<String,Integer> columnMap,
List<String> outputColumnNames)
Builds the assigners from an object inspector and from a list of columns.
|
static VectorColumnAssign[] |
VectorColumnAssignFactory.buildAssigners(VectorizedRowBatch outputBatch,
org.apache.hadoop.io.Writable[] writables) |
static VectorColumnAssign |
VectorColumnAssignFactory.buildObjectAssign(VectorizedRowBatch outputBatch,
int outColIndex,
ObjectInspector objInspector) |
static VectorColumnAssign |
VectorColumnAssignFactory.buildObjectAssign(VectorizedRowBatch outputBatch,
int outColIndex,
PrimitiveObjectInspector.PrimitiveCategory category) |
void |
VectorizedRowBatchCtx.convertRowBatchBlobToVectorizedBatch(Object rowBlob,
int rowsInBlob,
VectorizedRowBatch batch)
Deserialized set of rows and populates the batch
|
void |
VectorCopyRow.copyByReference(VectorizedRowBatch inBatch,
int inBatchIndex,
VectorizedRowBatch outBatch,
int outBatchIndex) |
void |
VectorCopyRow.copyByValue(VectorizedRowBatch inBatch,
int inBatchIndex,
VectorizedRowBatch outBatch,
int outBatchIndex) |
void |
VectorGroupKeyHelper.copyGroupKey(VectorizedRowBatch inputBatch,
VectorizedRowBatch outputBatch,
org.apache.hadoop.io.DataOutputBuffer buffer) |
static void |
VectorizedBatchUtil.debugDisplayBatch(VectorizedRowBatch batch,
String prefix) |
static void |
VectorizedBatchUtil.debugDisplayOneRow(VectorizedRowBatch batch,
int index,
String prefix) |
void |
VectorDeserializeRow.deserializeByReference(VectorizedRowBatch batch,
int batchIndex) |
void |
VectorDeserializeRow.deserializeByValue(VectorizedRowBatch batch,
int batchIndex) |
void |
VectorizedSerde.deserializeVector(Object rowBlob,
int rowsInBlob,
VectorizedRowBatch reuseBatch) |
void |
VectorizedColumnarSerDe.deserializeVector(Object rowBlob,
int rowsInBlob,
VectorizedRowBatch reuseBatch)
Deserializes the rowBlob into Vectorized row batch
|
void |
VectorHashKeyWrapperBatch.evaluateBatch(VectorizedRowBatch batch)
Processes a batch:
Evaluates each key vector expression.
Copies out each key's primitive values into the key wrappers
computes the hashcode of the key wrappers
|
static VectorizedRowBatch |
VectorizedBatchUtil.makeLike(VectorizedRowBatch batch)
Make a new (scratch) batch, which is exactly "like" the batch provided, except that it's empty
|
org.apache.hadoop.io.Writable |
VectorizedSerde.serializeVector(VectorizedRowBatch vrg,
ObjectInspector objInspector) |
org.apache.hadoop.io.Writable |
VectorizedColumnarSerDe.serializeVector(VectorizedRowBatch vrg,
ObjectInspector objInspector)
Serialize a vectorized row batch
|
boolean |
VectorSerializeRow.serializeWrite(VectorizedRowBatch batch,
int batchIndex) |
void |
VectorSerializeRowNoNulls.serializeWriteNoNulls(VectorizedRowBatch batch,
int batchIndex) |
protected void |
VectorExtractRow.setBatch(VectorizedRowBatch batch) |
protected void |
VectorAssignRow.setBatch(VectorizedRowBatch batch) |
void |
VectorExtractRowDynBatch.setBatchOnEntry(VectorizedRowBatch batch) |
void |
VectorAssignRowDynBatch.setBatchOnEntry(VectorizedRowBatch batch) |
static void |
VectorizedBatchUtil.setBatchSize(VectorizedRowBatch batch,
int size)
Reduce the batch size for a vectorized row batch
|
static void |
VectorizedBatchUtil.setNoNullFields(VectorizedRowBatch batch)
Iterates thru all the column vectors and sets noNull to
specified value.
|
void |
VectorExtractRowSameBatch.setOneBatch(VectorizedRowBatch batch) |
void |
VectorAssignRowSameBatch.setOneBatch(VectorizedRowBatch batch) |
static void |
VectorizedBatchUtil.setRepeatingColumn(VectorizedRowBatch batch,
int column)
Iterates thru all the column vectors and sets repeating to
specified column.
|
Modifier and Type | Method and Description |
---|---|
void |
VectorUDFTimestampFieldString.evaluate(VectorizedRowBatch batch) |
void |
VectorUDFTimestampFieldLong.evaluate(VectorizedRowBatch batch) |
void |
VectorUDFDateDiffScalarCol.evaluate(VectorizedRowBatch batch) |
void |
VectorUDFDateDiffColScalar.evaluate(VectorizedRowBatch batch) |
void |
VectorUDFDateDiffColCol.evaluate(VectorizedRowBatch batch) |
void |
VectorUDFDateAddScalarCol.evaluate(VectorizedRowBatch batch) |
void |
VectorUDFDateAddColScalar.evaluate(VectorizedRowBatch batch) |
void |
VectorUDFDateAddColCol.evaluate(VectorizedRowBatch batch) |
abstract void |
VectorExpression.evaluate(VectorizedRowBatch batch)
This is the primary method to implement expression logic.
|
void |
VectorElt.evaluate(VectorizedRowBatch batch) |
void |
VectorCoalesce.evaluate(VectorizedRowBatch batch) |
void |
StringUnaryUDFDirect.evaluate(VectorizedRowBatch batch) |
void |
StringUnaryUDF.evaluate(VectorizedRowBatch batch) |
void |
StringSubstrColStartLen.evaluate(VectorizedRowBatch batch) |
void |
StringSubstrColStart.evaluate(VectorizedRowBatch batch) |
void |
StringScalarConcatStringGroupCol.evaluate(VectorizedRowBatch batch) |
void |
StringLength.evaluate(VectorizedRowBatch batch) |
void |
StringGroupConcatColCol.evaluate(VectorizedRowBatch batch) |
void |
StringGroupColConcatStringScalar.evaluate(VectorizedRowBatch batch) |
void |
StringColumnInList.evaluate(VectorizedRowBatch batch) |
void |
SelectColumnIsTrue.evaluate(VectorizedRowBatch batch) |
void |
SelectColumnIsNull.evaluate(VectorizedRowBatch batch) |
void |
SelectColumnIsNotNull.evaluate(VectorizedRowBatch batch) |
void |
SelectColumnIsFalse.evaluate(VectorizedRowBatch batch) |
void |
NotCol.evaluate(VectorizedRowBatch batch) |
void |
MathFuncLongToLong.evaluate(VectorizedRowBatch batch) |
void |
MathFuncLongToDouble.evaluate(VectorizedRowBatch batch) |
void |
MathFuncDoubleToDouble.evaluate(VectorizedRowBatch batch) |
void |
LongToStringUnaryUDF.evaluate(VectorizedRowBatch batch) |
void |
LongScalarDivideLongColumn.evaluate(VectorizedRowBatch batch) |
void |
LongColumnInList.evaluate(VectorizedRowBatch batch) |
void |
LongColDivideLongScalar.evaluate(VectorizedRowBatch batch) |
void |
LongColDivideLongColumn.evaluate(VectorizedRowBatch batch) |
void |
IsNull.evaluate(VectorizedRowBatch batch) |
void |
IsNotNull.evaluate(VectorizedRowBatch batch) |
void |
IfExprStringScalarStringScalar.evaluate(VectorizedRowBatch batch) |
void |
IfExprStringScalarStringGroupColumn.evaluate(VectorizedRowBatch batch) |
void |
IfExprStringGroupColumnStringScalar.evaluate(VectorizedRowBatch batch) |
void |
IfExprStringGroupColumnStringGroupColumn.evaluate(VectorizedRowBatch batch) |
void |
IdentityExpression.evaluate(VectorizedRowBatch batch) |
void |
FuncRoundWithNumDigitsDecimalToDecimal.evaluate(VectorizedRowBatch batch) |
void |
FuncRandNoSeed.evaluate(VectorizedRowBatch batch) |
void |
FuncRand.evaluate(VectorizedRowBatch batch) |
void |
FuncLongToString.evaluate(VectorizedRowBatch batch) |
void |
FuncLongToDecimal.evaluate(VectorizedRowBatch batch) |
void |
FuncDoubleToDecimal.evaluate(VectorizedRowBatch batch) |
void |
FuncDecimalToLong.evaluate(VectorizedRowBatch batch) |
void |
FuncDecimalToDouble.evaluate(VectorizedRowBatch batch) |
void |
FilterStringColumnInList.evaluate(VectorizedRowBatch batch) |
void |
FilterScalarOrColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterScalarAndColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterLongColumnInList.evaluate(VectorizedRowBatch batch) |
void |
FilterExprOrExpr.evaluate(VectorizedRowBatch batch) |
void |
FilterExprAndExpr.evaluate(VectorizedRowBatch batch) |
void |
FilterDoubleColumnInList.evaluate(VectorizedRowBatch batch) |
void |
FilterDecimalColumnInList.evaluate(VectorizedRowBatch batch) |
void |
FilterConstantBooleanVectorExpression.evaluate(VectorizedRowBatch vrg) |
void |
FilterColOrScalar.evaluate(VectorizedRowBatch batch) |
void |
FilterColAndScalar.evaluate(VectorizedRowBatch batch) |
void |
DoubleColumnInList.evaluate(VectorizedRowBatch batch) |
void |
DecimalToStringUnaryUDF.evaluate(VectorizedRowBatch batch) |
void |
DecimalColumnInList.evaluate(VectorizedRowBatch batch) |
void |
ConstantVectorExpression.evaluate(VectorizedRowBatch vrg) |
void |
ColOrCol.evaluate(VectorizedRowBatch batch) |
void |
ColAndCol.evaluate(VectorizedRowBatch batch) |
void |
CastStringToIntervalYearMonth.evaluate(VectorizedRowBatch batch) |
void |
CastStringToIntervalDayTime.evaluate(VectorizedRowBatch batch) |
void |
CastStringToDecimal.evaluate(VectorizedRowBatch batch) |
void |
CastStringToDate.evaluate(VectorizedRowBatch batch) |
void |
CastLongToDate.evaluate(VectorizedRowBatch batch) |
void |
CastDecimalToDecimal.evaluate(VectorizedRowBatch batch)
Cast decimal(p1, s1) to decimal(p2, s2).
|
void |
AbstractFilterStringColLikeStringScalar.evaluate(VectorizedRowBatch batch) |
protected void |
VectorExpression.evaluateChildren(VectorizedRowBatch vrg)
Evaluate the child expressions on the given input batch.
|
Modifier and Type | Method and Description |
---|---|
void |
TimestampScalarSubtractIntervalYearMonthColumn.evaluate(VectorizedRowBatch batch) |
void |
TimestampScalarSubtractDateColumn.evaluate(VectorizedRowBatch batch) |
void |
TimestampScalarAddIntervalYearMonthColumn.evaluate(VectorizedRowBatch batch) |
void |
TimestampColSubtractIntervalYearMonthScalar.evaluate(VectorizedRowBatch batch) |
void |
TimestampColSubtractIntervalYearMonthColumn.evaluate(VectorizedRowBatch batch) |
void |
TimestampColSubtractDateScalar.evaluate(VectorizedRowBatch batch) |
void |
TimestampColSubtractDateColumn.evaluate(VectorizedRowBatch batch) |
void |
TimestampColAddIntervalYearMonthScalar.evaluate(VectorizedRowBatch batch) |
void |
TimestampColAddIntervalYearMonthColumn.evaluate(VectorizedRowBatch batch) |
void |
StringGroupScalarNotEqualStringGroupColumnBase.evaluate(VectorizedRowBatch batch) |
void |
StringGroupScalarLessStringGroupColumnBase.evaluate(VectorizedRowBatch batch) |
void |
StringGroupScalarLessEqualStringGroupColumnBase.evaluate(VectorizedRowBatch batch) |
void |
StringGroupScalarGreaterStringGroupColumnBase.evaluate(VectorizedRowBatch batch) |
void |
StringGroupScalarGreaterEqualStringGroupColumnBase.evaluate(VectorizedRowBatch batch) |
void |
StringGroupScalarEqualStringGroupColumnBase.evaluate(VectorizedRowBatch batch) |
void |
StringGroupColNotEqualStringGroupScalarBase.evaluate(VectorizedRowBatch batch) |
void |
StringGroupColNotEqualStringGroupColumn.evaluate(VectorizedRowBatch batch) |
void |
StringGroupColLessStringGroupScalarBase.evaluate(VectorizedRowBatch batch) |
void |
StringGroupColLessStringGroupColumn.evaluate(VectorizedRowBatch batch) |
void |
StringGroupColLessEqualStringGroupScalarBase.evaluate(VectorizedRowBatch batch) |
void |
StringGroupColLessEqualStringGroupColumn.evaluate(VectorizedRowBatch batch) |
void |
StringGroupColGreaterStringGroupScalarBase.evaluate(VectorizedRowBatch batch) |
void |
StringGroupColGreaterStringGroupColumn.evaluate(VectorizedRowBatch batch) |
void |
StringGroupColGreaterEqualStringGroupScalarBase.evaluate(VectorizedRowBatch batch) |
void |
StringGroupColGreaterEqualStringGroupColumn.evaluate(VectorizedRowBatch batch) |
void |
StringGroupColEqualStringGroupScalarBase.evaluate(VectorizedRowBatch batch) |
void |
StringGroupColEqualStringGroupColumn.evaluate(VectorizedRowBatch batch) |
void |
LongScalarSubtractLongColumn.evaluate(VectorizedRowBatch batch) |
void |
LongScalarSubtractDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
LongScalarNotEqualLongColumn.evaluate(VectorizedRowBatch batch) |
void |
LongScalarNotEqualDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
LongScalarMultiplyLongColumn.evaluate(VectorizedRowBatch batch) |
void |
LongScalarMultiplyDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
LongScalarModuloLongColumn.evaluate(VectorizedRowBatch batch) |
void |
LongScalarModuloDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
LongScalarLessLongColumn.evaluate(VectorizedRowBatch batch) |
void |
LongScalarLessEqualLongColumn.evaluate(VectorizedRowBatch batch) |
void |
LongScalarLessEqualDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
LongScalarLessDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
LongScalarGreaterLongColumn.evaluate(VectorizedRowBatch batch) |
void |
LongScalarGreaterEqualLongColumn.evaluate(VectorizedRowBatch batch) |
void |
LongScalarGreaterEqualDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
LongScalarGreaterDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
LongScalarEqualLongColumn.evaluate(VectorizedRowBatch batch) |
void |
LongScalarEqualDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
LongScalarDivideDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
LongScalarAddLongColumn.evaluate(VectorizedRowBatch batch) |
void |
LongScalarAddDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
LongColUnaryMinus.evaluate(VectorizedRowBatch batch) |
void |
LongColSubtractLongScalar.evaluate(VectorizedRowBatch batch) |
void |
LongColSubtractLongColumn.evaluate(VectorizedRowBatch batch) |
void |
LongColSubtractDoubleScalar.evaluate(VectorizedRowBatch batch) |
void |
LongColSubtractDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
LongColNotEqualLongScalar.evaluate(VectorizedRowBatch batch) |
void |
LongColNotEqualLongColumn.evaluate(VectorizedRowBatch batch) |
void |
LongColNotEqualDoubleScalar.evaluate(VectorizedRowBatch batch) |
void |
LongColNotEqualDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
LongColMultiplyLongScalar.evaluate(VectorizedRowBatch batch) |
void |
LongColMultiplyLongColumn.evaluate(VectorizedRowBatch batch) |
void |
LongColMultiplyDoubleScalar.evaluate(VectorizedRowBatch batch) |
void |
LongColMultiplyDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
LongColModuloLongScalar.evaluate(VectorizedRowBatch batch) |
void |
LongColModuloLongColumn.evaluate(VectorizedRowBatch batch) |
void |
LongColModuloDoubleScalar.evaluate(VectorizedRowBatch batch) |
void |
LongColModuloDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
LongColLessLongScalar.evaluate(VectorizedRowBatch batch) |
void |
LongColLessLongColumn.evaluate(VectorizedRowBatch batch) |
void |
LongColLessEqualLongScalar.evaluate(VectorizedRowBatch batch) |
void |
LongColLessEqualLongColumn.evaluate(VectorizedRowBatch batch) |
void |
LongColLessEqualDoubleScalar.evaluate(VectorizedRowBatch batch) |
void |
LongColLessEqualDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
LongColLessDoubleScalar.evaluate(VectorizedRowBatch batch) |
void |
LongColLessDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
LongColGreaterLongScalar.evaluate(VectorizedRowBatch batch) |
void |
LongColGreaterLongColumn.evaluate(VectorizedRowBatch batch) |
void |
LongColGreaterEqualLongScalar.evaluate(VectorizedRowBatch batch) |
void |
LongColGreaterEqualLongColumn.evaluate(VectorizedRowBatch batch) |
void |
LongColGreaterEqualDoubleScalar.evaluate(VectorizedRowBatch batch) |
void |
LongColGreaterEqualDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
LongColGreaterDoubleScalar.evaluate(VectorizedRowBatch batch) |
void |
LongColGreaterDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
LongColEqualLongScalar.evaluate(VectorizedRowBatch batch) |
void |
LongColEqualLongColumn.evaluate(VectorizedRowBatch batch) |
void |
LongColEqualDoubleScalar.evaluate(VectorizedRowBatch batch) |
void |
LongColEqualDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
LongColDivideDoubleScalar.evaluate(VectorizedRowBatch batch) |
void |
LongColDivideDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
LongColAddLongScalar.evaluate(VectorizedRowBatch batch) |
void |
LongColAddLongColumn.evaluate(VectorizedRowBatch batch) |
void |
LongColAddDoubleScalar.evaluate(VectorizedRowBatch batch) |
void |
LongColAddDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
IntervalYearMonthScalarAddTimestampColumn.evaluate(VectorizedRowBatch batch) |
void |
IntervalYearMonthScalarAddDateColumn.evaluate(VectorizedRowBatch batch) |
void |
IntervalYearMonthColAddTimestampScalar.evaluate(VectorizedRowBatch batch) |
void |
IntervalYearMonthColAddTimestampColumn.evaluate(VectorizedRowBatch batch) |
void |
IntervalYearMonthColAddDateScalar.evaluate(VectorizedRowBatch batch) |
void |
IntervalYearMonthColAddDateColumn.evaluate(VectorizedRowBatch batch) |
void |
IntervalDayTimeScalarAddDateColumn.evaluate(VectorizedRowBatch batch) |
void |
IntervalDayTimeColAddDateScalar.evaluate(VectorizedRowBatch batch) |
void |
IntervalDayTimeColAddDateColumn.evaluate(VectorizedRowBatch batch) |
void |
IfExprLongScalarLongScalar.evaluate(VectorizedRowBatch batch) |
void |
IfExprLongScalarLongColumn.evaluate(VectorizedRowBatch batch) |
void |
IfExprLongScalarDoubleScalar.evaluate(VectorizedRowBatch batch) |
void |
IfExprLongScalarDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
IfExprLongColumnLongScalar.evaluate(VectorizedRowBatch batch) |
void |
IfExprLongColumnLongColumn.evaluate(VectorizedRowBatch batch) |
void |
IfExprLongColumnDoubleScalar.evaluate(VectorizedRowBatch batch) |
void |
IfExprDoubleScalarLongScalar.evaluate(VectorizedRowBatch batch) |
void |
IfExprDoubleScalarLongColumn.evaluate(VectorizedRowBatch batch) |
void |
IfExprDoubleScalarDoubleScalar.evaluate(VectorizedRowBatch batch) |
void |
IfExprDoubleScalarDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
IfExprDoubleColumnLongScalar.evaluate(VectorizedRowBatch batch) |
void |
IfExprDoubleColumnDoubleScalar.evaluate(VectorizedRowBatch batch) |
void |
IfExprDoubleColumnDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
FuncTanLongToDouble.evaluate(VectorizedRowBatch batch) |
void |
FuncTanDoubleToDouble.evaluate(VectorizedRowBatch batch) |
void |
FuncSqrtLongToDouble.evaluate(VectorizedRowBatch batch) |
void |
FuncSqrtDoubleToDouble.evaluate(VectorizedRowBatch batch) |
void |
FuncSinLongToDouble.evaluate(VectorizedRowBatch batch) |
void |
FuncSinDoubleToDouble.evaluate(VectorizedRowBatch batch) |
void |
FuncSignLongToDouble.evaluate(VectorizedRowBatch batch) |
void |
FuncSignDoubleToDouble.evaluate(VectorizedRowBatch batch) |
void |
FuncSignDecimalToLong.evaluate(VectorizedRowBatch batch) |
void |
FuncRoundDoubleToDouble.evaluate(VectorizedRowBatch batch) |
void |
FuncRoundDecimalToDecimal.evaluate(VectorizedRowBatch batch) |
void |
FuncRadiansLongToDouble.evaluate(VectorizedRowBatch batch) |
void |
FuncRadiansDoubleToDouble.evaluate(VectorizedRowBatch batch) |
void |
FuncNegateDecimalToDecimal.evaluate(VectorizedRowBatch batch) |
void |
FuncLog2LongToDouble.evaluate(VectorizedRowBatch batch) |
void |
FuncLog2DoubleToDouble.evaluate(VectorizedRowBatch batch) |
void |
FuncLog10LongToDouble.evaluate(VectorizedRowBatch batch) |
void |
FuncLog10DoubleToDouble.evaluate(VectorizedRowBatch batch) |
void |
FuncLnLongToDouble.evaluate(VectorizedRowBatch batch) |
void |
FuncLnDoubleToDouble.evaluate(VectorizedRowBatch batch) |
void |
FuncFloorLongToLong.evaluate(VectorizedRowBatch batch) |
void |
FuncFloorDoubleToLong.evaluate(VectorizedRowBatch batch) |
void |
FuncFloorDecimalToDecimal.evaluate(VectorizedRowBatch batch) |
void |
FuncExpLongToDouble.evaluate(VectorizedRowBatch batch) |
void |
FuncExpDoubleToDouble.evaluate(VectorizedRowBatch batch) |
void |
FuncDegreesLongToDouble.evaluate(VectorizedRowBatch batch) |
void |
FuncDegreesDoubleToDouble.evaluate(VectorizedRowBatch batch) |
void |
FuncCosLongToDouble.evaluate(VectorizedRowBatch batch) |
void |
FuncCosDoubleToDouble.evaluate(VectorizedRowBatch batch) |
void |
FuncCeilLongToLong.evaluate(VectorizedRowBatch batch) |
void |
FuncCeilDoubleToLong.evaluate(VectorizedRowBatch batch) |
void |
FuncCeilDecimalToDecimal.evaluate(VectorizedRowBatch batch) |
void |
FuncATanLongToDouble.evaluate(VectorizedRowBatch batch) |
void |
FuncATanDoubleToDouble.evaluate(VectorizedRowBatch batch) |
void |
FuncASinLongToDouble.evaluate(VectorizedRowBatch batch) |
void |
FuncASinDoubleToDouble.evaluate(VectorizedRowBatch batch) |
void |
FuncACosLongToDouble.evaluate(VectorizedRowBatch batch) |
void |
FuncACosDoubleToDouble.evaluate(VectorizedRowBatch batch) |
void |
FuncAbsLongToLong.evaluate(VectorizedRowBatch batch) |
void |
FuncAbsDoubleToDouble.evaluate(VectorizedRowBatch batch) |
void |
FuncAbsDecimalToDecimal.evaluate(VectorizedRowBatch batch) |
void |
FilterVarCharColumnNotBetween.evaluate(VectorizedRowBatch batch) |
void |
FilterVarCharColumnBetween.evaluate(VectorizedRowBatch batch) |
void |
FilterStringGroupScalarNotEqualStringGroupColumnBase.evaluate(VectorizedRowBatch batch) |
void |
FilterStringGroupScalarLessStringGroupColumnBase.evaluate(VectorizedRowBatch batch) |
void |
FilterStringGroupScalarLessEqualStringGroupColumnBase.evaluate(VectorizedRowBatch batch) |
void |
FilterStringGroupScalarGreaterStringGroupColumnBase.evaluate(VectorizedRowBatch batch) |
void |
FilterStringGroupScalarGreaterEqualStringGroupColumnBase.evaluate(VectorizedRowBatch batch) |
void |
FilterStringGroupScalarEqualStringGroupColumnBase.evaluate(VectorizedRowBatch batch) |
void |
FilterStringGroupColNotEqualStringGroupScalarBase.evaluate(VectorizedRowBatch batch) |
void |
FilterStringGroupColNotEqualStringGroupColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterStringGroupColLessStringGroupScalarBase.evaluate(VectorizedRowBatch batch) |
void |
FilterStringGroupColLessStringGroupColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterStringGroupColLessEqualStringGroupScalarBase.evaluate(VectorizedRowBatch batch) |
void |
FilterStringGroupColLessEqualStringGroupColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterStringGroupColGreaterStringGroupScalarBase.evaluate(VectorizedRowBatch batch) |
void |
FilterStringGroupColGreaterStringGroupColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterStringGroupColGreaterEqualStringGroupScalarBase.evaluate(VectorizedRowBatch batch) |
void |
FilterStringGroupColGreaterEqualStringGroupColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterStringGroupColEqualStringGroupScalarBase.evaluate(VectorizedRowBatch batch) |
void |
FilterStringGroupColEqualStringGroupColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterStringColumnNotBetween.evaluate(VectorizedRowBatch batch) |
void |
FilterStringColumnBetween.evaluate(VectorizedRowBatch batch) |
void |
FilterLongScalarNotEqualLongColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterLongScalarNotEqualDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterLongScalarLessLongColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterLongScalarLessEqualLongColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterLongScalarLessEqualDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterLongScalarLessDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterLongScalarGreaterLongColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterLongScalarGreaterEqualLongColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterLongScalarGreaterEqualDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterLongScalarGreaterDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterLongScalarEqualLongColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterLongScalarEqualDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterLongColumnNotBetween.evaluate(VectorizedRowBatch batch) |
void |
FilterLongColumnBetween.evaluate(VectorizedRowBatch batch) |
void |
FilterLongColNotEqualLongScalar.evaluate(VectorizedRowBatch batch) |
void |
FilterLongColNotEqualLongColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterLongColNotEqualDoubleScalar.evaluate(VectorizedRowBatch batch) |
void |
FilterLongColNotEqualDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterLongColLessLongScalar.evaluate(VectorizedRowBatch batch) |
void |
FilterLongColLessLongColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterLongColLessEqualLongScalar.evaluate(VectorizedRowBatch batch) |
void |
FilterLongColLessEqualLongColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterLongColLessEqualDoubleScalar.evaluate(VectorizedRowBatch batch) |
void |
FilterLongColLessEqualDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterLongColLessDoubleScalar.evaluate(VectorizedRowBatch batch) |
void |
FilterLongColLessDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterLongColGreaterLongScalar.evaluate(VectorizedRowBatch batch) |
void |
FilterLongColGreaterLongColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterLongColGreaterEqualLongScalar.evaluate(VectorizedRowBatch batch) |
void |
FilterLongColGreaterEqualLongColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterLongColGreaterEqualDoubleScalar.evaluate(VectorizedRowBatch batch) |
void |
FilterLongColGreaterEqualDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterLongColGreaterDoubleScalar.evaluate(VectorizedRowBatch batch) |
void |
FilterLongColGreaterDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterLongColEqualLongScalar.evaluate(VectorizedRowBatch batch) |
void |
FilterLongColEqualLongColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterLongColEqualDoubleScalar.evaluate(VectorizedRowBatch batch) |
void |
FilterLongColEqualDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterDoubleScalarNotEqualLongColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterDoubleScalarNotEqualDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterDoubleScalarLessLongColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterDoubleScalarLessEqualLongColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterDoubleScalarLessEqualDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterDoubleScalarLessDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterDoubleScalarGreaterLongColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterDoubleScalarGreaterEqualLongColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterDoubleScalarGreaterEqualDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterDoubleScalarGreaterDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterDoubleScalarEqualLongColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterDoubleScalarEqualDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterDoubleColumnNotBetween.evaluate(VectorizedRowBatch batch) |
void |
FilterDoubleColumnBetween.evaluate(VectorizedRowBatch batch) |
void |
FilterDoubleColNotEqualLongScalar.evaluate(VectorizedRowBatch batch) |
void |
FilterDoubleColNotEqualLongColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterDoubleColNotEqualDoubleScalar.evaluate(VectorizedRowBatch batch) |
void |
FilterDoubleColNotEqualDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterDoubleColLessLongScalar.evaluate(VectorizedRowBatch batch) |
void |
FilterDoubleColLessLongColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterDoubleColLessEqualLongScalar.evaluate(VectorizedRowBatch batch) |
void |
FilterDoubleColLessEqualLongColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterDoubleColLessEqualDoubleScalar.evaluate(VectorizedRowBatch batch) |
void |
FilterDoubleColLessEqualDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterDoubleColLessDoubleScalar.evaluate(VectorizedRowBatch batch) |
void |
FilterDoubleColLessDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterDoubleColGreaterLongScalar.evaluate(VectorizedRowBatch batch) |
void |
FilterDoubleColGreaterLongColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterDoubleColGreaterEqualLongScalar.evaluate(VectorizedRowBatch batch) |
void |
FilterDoubleColGreaterEqualLongColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterDoubleColGreaterEqualDoubleScalar.evaluate(VectorizedRowBatch batch) |
void |
FilterDoubleColGreaterEqualDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterDoubleColGreaterDoubleScalar.evaluate(VectorizedRowBatch batch) |
void |
FilterDoubleColGreaterDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterDoubleColEqualLongScalar.evaluate(VectorizedRowBatch batch) |
void |
FilterDoubleColEqualLongColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterDoubleColEqualDoubleScalar.evaluate(VectorizedRowBatch batch) |
void |
FilterDoubleColEqualDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterDecimalScalarNotEqualDecimalColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterDecimalScalarLessEqualDecimalColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterDecimalScalarLessDecimalColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterDecimalScalarGreaterEqualDecimalColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterDecimalScalarGreaterDecimalColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterDecimalScalarEqualDecimalColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterDecimalColumnNotBetween.evaluate(VectorizedRowBatch batch) |
void |
FilterDecimalColumnBetween.evaluate(VectorizedRowBatch batch) |
void |
FilterDecimalColNotEqualDecimalScalar.evaluate(VectorizedRowBatch batch) |
void |
FilterDecimalColNotEqualDecimalColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterDecimalColLessEqualDecimalScalar.evaluate(VectorizedRowBatch batch) |
void |
FilterDecimalColLessEqualDecimalColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterDecimalColLessDecimalScalar.evaluate(VectorizedRowBatch batch) |
void |
FilterDecimalColLessDecimalColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterDecimalColGreaterEqualDecimalScalar.evaluate(VectorizedRowBatch batch) |
void |
FilterDecimalColGreaterEqualDecimalColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterDecimalColGreaterDecimalScalar.evaluate(VectorizedRowBatch batch) |
void |
FilterDecimalColGreaterDecimalColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterDecimalColEqualDecimalScalar.evaluate(VectorizedRowBatch batch) |
void |
FilterDecimalColEqualDecimalColumn.evaluate(VectorizedRowBatch batch) |
void |
FilterCharColumnNotBetween.evaluate(VectorizedRowBatch batch) |
void |
FilterCharColumnBetween.evaluate(VectorizedRowBatch batch) |
void |
DoubleScalarSubtractLongColumn.evaluate(VectorizedRowBatch batch) |
void |
DoubleScalarSubtractDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
DoubleScalarNotEqualLongColumn.evaluate(VectorizedRowBatch batch) |
void |
DoubleScalarNotEqualDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
DoubleScalarMultiplyLongColumn.evaluate(VectorizedRowBatch batch) |
void |
DoubleScalarMultiplyDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
DoubleScalarModuloLongColumn.evaluate(VectorizedRowBatch batch) |
void |
DoubleScalarModuloDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
DoubleScalarLessLongColumn.evaluate(VectorizedRowBatch batch) |
void |
DoubleScalarLessEqualLongColumn.evaluate(VectorizedRowBatch batch) |
void |
DoubleScalarLessEqualDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
DoubleScalarLessDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
DoubleScalarGreaterLongColumn.evaluate(VectorizedRowBatch batch) |
void |
DoubleScalarGreaterEqualLongColumn.evaluate(VectorizedRowBatch batch) |
void |
DoubleScalarGreaterEqualDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
DoubleScalarGreaterDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
DoubleScalarEqualLongColumn.evaluate(VectorizedRowBatch batch) |
void |
DoubleScalarEqualDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
DoubleScalarDivideLongColumn.evaluate(VectorizedRowBatch batch) |
void |
DoubleScalarDivideDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
DoubleScalarAddLongColumn.evaluate(VectorizedRowBatch batch) |
void |
DoubleScalarAddDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
DoubleColUnaryMinus.evaluate(VectorizedRowBatch batch) |
void |
DoubleColSubtractLongScalar.evaluate(VectorizedRowBatch batch) |
void |
DoubleColSubtractLongColumn.evaluate(VectorizedRowBatch batch) |
void |
DoubleColSubtractDoubleScalar.evaluate(VectorizedRowBatch batch) |
void |
DoubleColSubtractDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
DoubleColNotEqualLongScalar.evaluate(VectorizedRowBatch batch) |
void |
DoubleColNotEqualLongColumn.evaluate(VectorizedRowBatch batch) |
void |
DoubleColNotEqualDoubleScalar.evaluate(VectorizedRowBatch batch) |
void |
DoubleColNotEqualDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
DoubleColMultiplyLongScalar.evaluate(VectorizedRowBatch batch) |
void |
DoubleColMultiplyLongColumn.evaluate(VectorizedRowBatch batch) |
void |
DoubleColMultiplyDoubleScalar.evaluate(VectorizedRowBatch batch) |
void |
DoubleColMultiplyDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
DoubleColModuloLongScalar.evaluate(VectorizedRowBatch batch) |
void |
DoubleColModuloLongColumn.evaluate(VectorizedRowBatch batch) |
void |
DoubleColModuloDoubleScalar.evaluate(VectorizedRowBatch batch) |
void |
DoubleColModuloDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
DoubleColLessLongScalar.evaluate(VectorizedRowBatch batch) |
void |
DoubleColLessLongColumn.evaluate(VectorizedRowBatch batch) |
void |
DoubleColLessEqualLongScalar.evaluate(VectorizedRowBatch batch) |
void |
DoubleColLessEqualLongColumn.evaluate(VectorizedRowBatch batch) |
void |
DoubleColLessEqualDoubleScalar.evaluate(VectorizedRowBatch batch) |
void |
DoubleColLessEqualDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
DoubleColLessDoubleScalar.evaluate(VectorizedRowBatch batch) |
void |
DoubleColLessDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
DoubleColGreaterLongScalar.evaluate(VectorizedRowBatch batch) |
void |
DoubleColGreaterLongColumn.evaluate(VectorizedRowBatch batch) |
void |
DoubleColGreaterEqualLongScalar.evaluate(VectorizedRowBatch batch) |
void |
DoubleColGreaterEqualLongColumn.evaluate(VectorizedRowBatch batch) |
void |
DoubleColGreaterEqualDoubleScalar.evaluate(VectorizedRowBatch batch) |
void |
DoubleColGreaterEqualDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
DoubleColGreaterDoubleScalar.evaluate(VectorizedRowBatch batch) |
void |
DoubleColGreaterDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
DoubleColEqualLongScalar.evaluate(VectorizedRowBatch batch) |
void |
DoubleColEqualLongColumn.evaluate(VectorizedRowBatch batch) |
void |
DoubleColEqualDoubleScalar.evaluate(VectorizedRowBatch batch) |
void |
DoubleColEqualDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
DoubleColDivideLongScalar.evaluate(VectorizedRowBatch batch) |
void |
DoubleColDivideLongColumn.evaluate(VectorizedRowBatch batch) |
void |
DoubleColDivideDoubleScalar.evaluate(VectorizedRowBatch batch) |
void |
DoubleColDivideDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
DoubleColAddLongScalar.evaluate(VectorizedRowBatch batch) |
void |
DoubleColAddLongColumn.evaluate(VectorizedRowBatch batch) |
void |
DoubleColAddDoubleScalar.evaluate(VectorizedRowBatch batch) |
void |
DoubleColAddDoubleColumn.evaluate(VectorizedRowBatch batch) |
void |
DecimalScalarSubtractDecimalColumn.evaluate(VectorizedRowBatch batch) |
void |
DecimalScalarMultiplyDecimalColumn.evaluate(VectorizedRowBatch batch) |
void |
DecimalScalarModuloDecimalColumn.evaluate(VectorizedRowBatch batch) |
void |
DecimalScalarDivideDecimalColumn.evaluate(VectorizedRowBatch batch) |
void |
DecimalScalarAddDecimalColumn.evaluate(VectorizedRowBatch batch) |
void |
DecimalColSubtractDecimalScalar.evaluate(VectorizedRowBatch batch) |
void |
DecimalColSubtractDecimalColumn.evaluate(VectorizedRowBatch batch) |
void |
DecimalColMultiplyDecimalScalar.evaluate(VectorizedRowBatch batch) |
void |
DecimalColMultiplyDecimalColumn.evaluate(VectorizedRowBatch batch) |
void |
DecimalColModuloDecimalScalar.evaluate(VectorizedRowBatch batch) |
void |
DecimalColModuloDecimalColumn.evaluate(VectorizedRowBatch batch) |
void |
DecimalColDivideDecimalScalar.evaluate(VectorizedRowBatch batch) |
void |
DecimalColDivideDecimalColumn.evaluate(VectorizedRowBatch batch) |
void |
DecimalColAddDecimalScalar.evaluate(VectorizedRowBatch batch) |
void |
DecimalColAddDecimalColumn.evaluate(VectorizedRowBatch batch) |
void |
DateScalarSubtractTimestampColumn.evaluate(VectorizedRowBatch batch) |
void |
DateScalarSubtractIntervalYearMonthColumn.evaluate(VectorizedRowBatch batch) |
void |
DateScalarSubtractIntervalDayTimeColumn.evaluate(VectorizedRowBatch batch) |
void |
DateScalarSubtractDateColumn.evaluate(VectorizedRowBatch batch) |
void |
DateScalarAddIntervalYearMonthColumn.evaluate(VectorizedRowBatch batch) |
void |
DateScalarAddIntervalDayTimeColumn.evaluate(VectorizedRowBatch batch) |
void |
DateColSubtractTimestampScalar.evaluate(VectorizedRowBatch batch) |
void |
DateColSubtractTimestampColumn.evaluate(VectorizedRowBatch batch) |
void |
DateColSubtractIntervalYearMonthScalar.evaluate(VectorizedRowBatch batch) |
void |
DateColSubtractIntervalYearMonthColumn.evaluate(VectorizedRowBatch batch) |
void |
DateColSubtractIntervalDayTimeScalar.evaluate(VectorizedRowBatch batch) |
void |
DateColSubtractIntervalDayTimeColumn.evaluate(VectorizedRowBatch batch) |
void |
DateColSubtractDateScalar.evaluate(VectorizedRowBatch batch) |
void |
DateColSubtractDateColumn.evaluate(VectorizedRowBatch batch) |
void |
DateColAddIntervalYearMonthScalar.evaluate(VectorizedRowBatch batch) |
void |
DateColAddIntervalYearMonthColumn.evaluate(VectorizedRowBatch batch) |
void |
DateColAddIntervalDayTimeScalar.evaluate(VectorizedRowBatch batch) |
void |
DateColAddIntervalDayTimeColumn.evaluate(VectorizedRowBatch batch) |
void |
CastTimestampToLongViaLongToLong.evaluate(VectorizedRowBatch batch) |
void |
CastTimestampToDoubleViaLongToDouble.evaluate(VectorizedRowBatch batch) |
void |
CastTimestampToBooleanViaLongToLong.evaluate(VectorizedRowBatch batch) |
void |
CastMillisecondsLongToTimestampViaLongToLong.evaluate(VectorizedRowBatch batch) |
void |
CastLongToTimestampViaLongToLong.evaluate(VectorizedRowBatch batch) |
void |
CastLongToDouble.evaluate(VectorizedRowBatch batch) |
void |
CastLongToBooleanViaLongToLong.evaluate(VectorizedRowBatch batch) |
void |
CastDoubleToTimestampViaDoubleToLong.evaluate(VectorizedRowBatch batch) |
void |
CastDoubleToLong.evaluate(VectorizedRowBatch batch) |
void |
CastDoubleToBooleanViaDoubleToLong.evaluate(VectorizedRowBatch batch) |
void |
CastDateToBooleanViaLongToLong.evaluate(VectorizedRowBatch batch) |
Modifier and Type | Field and Description |
---|---|
protected VectorizedRowBatch |
VectorMapJoinCommonOperator.overflowBatch |
protected VectorizedRowBatch |
VectorMapJoinCommonOperator.spillReplayBatch |
Modifier and Type | Method and Description |
---|---|
protected VectorizedRowBatch |
VectorMapJoinCommonOperator.setupOverflowBatch() |
Modifier and Type | Method and Description |
---|---|
protected void |
VectorMapJoinOuterGenerateResultOperator.commonSetup(VectorizedRowBatch batch) |
protected void |
VectorMapJoinLeftSemiGenerateResultOperator.commonSetup(VectorizedRowBatch batch) |
protected void |
VectorMapJoinInnerGenerateResultOperator.commonSetup(VectorizedRowBatch batch) |
protected void |
VectorMapJoinInnerBigOnlyGenerateResultOperator.commonSetup(VectorizedRowBatch batch) |
protected void |
VectorMapJoinGenerateResultOperator.commonSetup(VectorizedRowBatch batch) |
protected void |
VectorMapJoinCommonOperator.commonSetup(VectorizedRowBatch batch) |
protected void |
VectorMapJoinCommonOperator.displayBatchColumns(VectorizedRowBatch batch,
String batchName) |
protected void |
VectorMapJoinInnerGenerateResultOperator.finishInner(VectorizedRowBatch batch,
int allMatchCount,
int equalKeySeriesCount,
int spillCount,
int hashMapResultCount)
Generate the inner join output results for one vectorized row batch.
|
protected void |
VectorMapJoinInnerBigOnlyGenerateResultOperator.finishInnerBigOnly(VectorizedRowBatch batch,
int allMatchCount,
int equalKeySeriesCount,
int spillCount,
VectorMapJoinHashTableResult[] hashTableResults,
int hashMapResultCount)
Generate the inner big table only join output results for one vectorized row batch.
|
protected void |
VectorMapJoinInnerBigOnlyGenerateResultOperator.finishInnerBigOnlyRepeated(VectorizedRowBatch batch,
JoinUtil.JoinResult joinResult,
VectorMapJoinHashMultiSetResult hashMultiSetResult) |
protected void |
VectorMapJoinInnerGenerateResultOperator.finishInnerRepeated(VectorizedRowBatch batch,
JoinUtil.JoinResult joinResult,
VectorMapJoinHashTableResult hashMapResult) |
protected void |
VectorMapJoinLeftSemiGenerateResultOperator.finishLeftSemi(VectorizedRowBatch batch,
int allMatchCount,
int spillCount,
VectorMapJoinHashTableResult[] hashTableResults)
Generate the left semi join output results for one vectorized row batch.
|
protected void |
VectorMapJoinLeftSemiGenerateResultOperator.finishLeftSemiRepeated(VectorizedRowBatch batch,
JoinUtil.JoinResult joinResult,
VectorMapJoinHashTableResult hashSetResult) |
void |
VectorMapJoinOuterGenerateResultOperator.finishOuter(VectorizedRowBatch batch,
int allMatchCount,
int equalKeySeriesCount,
boolean atLeastOneNonMatch,
boolean inputSelectedInUse,
int inputLogicalSize,
int spillCount,
int hashMapResultCount)
Generate the outer join output results for one vectorized row batch.
|
void |
VectorMapJoinOuterGenerateResultOperator.finishOuterRepeated(VectorizedRowBatch batch,
JoinUtil.JoinResult joinResult,
VectorMapJoinHashMapResult hashMapResult,
boolean someRowsFilteredOut,
boolean inputSelectedInUse,
int inputLogicalSize)
Generate the outer join output results for one vectorized row batch with a repeated key.
|
void |
VectorMapJoinGenerateResultOperator.forwardBigTableBatch(VectorizedRowBatch batch)
Forward the big table batch to the children.
|
protected void |
VectorMapJoinGenerateResultOperator.generateHashMapResultMultiValue(VectorizedRowBatch batch,
VectorMapJoinHashMapResult hashMapResult,
int[] allMatchs,
int allMatchesIndex,
int duplicateCount)
Generate results for a N x M cross product.
|
protected void |
VectorMapJoinGenerateResultOperator.generateHashMapResultRepeatedAll(VectorizedRowBatch batch,
VectorMapJoinHashMapResult hashMapResult)
Generate optimized results when entire batch key is repeated and it matched the hash map.
|
protected int |
VectorMapJoinGenerateResultOperator.generateHashMapResultSingleValue(VectorizedRowBatch batch,
VectorMapJoinHashMapResult hashMapResult,
int[] allMatchs,
int allMatchesIndex,
int duplicateCount,
int numSel)
Generate join results for a single small table value match.
|
protected int |
VectorMapJoinInnerBigOnlyGenerateResultOperator.generateHashMultiSetResultRepeatedAll(VectorizedRowBatch batch,
VectorMapJoinHashMultiSetResult hashMultiSetResult)
Generate the inner big table only join output results for one vectorized row batch with
a repeated key.
|
protected int |
VectorMapJoinLeftSemiGenerateResultOperator.generateHashSetResultRepeatedAll(VectorizedRowBatch batch)
Generate the left semi join output results for one vectorized row batch with a repeated key.
|
protected void |
VectorMapJoinOuterGenerateResultOperator.generateOuterNulls(VectorizedRowBatch batch,
int[] noMatchs,
int noMatchSize)
Generate the non matching outer join output results for one vectorized row batch.
|
protected void |
VectorMapJoinOuterGenerateResultOperator.generateOuterNullsRepeatedAll(VectorizedRowBatch batch)
Generate the non-match outer join output results for the whole repeating vectorized
row batch.
|
protected void |
VectorMapJoinInnerGenerateResultOperator.innerPerBatchSetup(VectorizedRowBatch batch)
Do the per-batch setup for an inner join.
|
protected void |
VectorMapJoinOuterGenerateResultOperator.outerPerBatchSetup(VectorizedRowBatch batch)
Do the per-batch setup for an outer join.
|
protected void |
VectorMapJoinGenerateResultOperator.performValueExpressions(VectorizedRowBatch batch,
int[] allMatchs,
int allMatchCount) |
protected void |
VectorMapJoinGenerateResultOperator.spillBatchRepeated(VectorizedRowBatch batch,
VectorMapJoinHashTableResult hashTableResult) |
protected void |
VectorMapJoinGenerateResultOperator.spillHashMapBatch(VectorizedRowBatch batch,
VectorMapJoinHashTableResult[] hashTableResults,
int[] spills,
int[] spillHashTableResultIndices,
int spillCount) |
Modifier and Type | Method and Description |
---|---|
void |
VectorUDFAdaptor.evaluate(VectorizedRowBatch batch) |
GenericUDF.DeferredObject |
VectorUDFArgDesc.getDeferredJavaObject(int row,
VectorizedRowBatch b,
int argPosition,
VectorExpressionWriter[] writers) |
Modifier and Type | Method and Description |
---|---|
VectorizedRowBatch |
VectorizedRCFileRecordReader.createValue() |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,VectorizedRowBatch> |
VectorizedRCFileInputFormat.getRecordReader(org.apache.hadoop.mapred.InputSplit split,
org.apache.hadoop.mapred.JobConf job,
org.apache.hadoop.mapred.Reporter reporter) |
Modifier and Type | Method and Description |
---|---|
boolean |
VectorizedRCFileRecordReader.next(org.apache.hadoop.io.NullWritable key,
VectorizedRowBatch value) |
Modifier and Type | Method and Description |
---|---|
VectorizedRowBatch |
RecordReader.nextBatch(VectorizedRowBatch previousBatch)
Read the next row batch.
|
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,VectorizedRowBatch> |
VectorizedOrcInputFormat.getRecordReader(org.apache.hadoop.mapred.InputSplit inputSplit,
org.apache.hadoop.mapred.JobConf conf,
org.apache.hadoop.mapred.Reporter reporter) |
Modifier and Type | Method and Description |
---|---|
void |
OrcSerde.deserializeVector(Object rowBlob,
int rowsInBatch,
VectorizedRowBatch reuseBatch) |
VectorizedRowBatch |
RecordReader.nextBatch(VectorizedRowBatch previousBatch)
Read the next row batch.
|
org.apache.hadoop.io.Writable |
OrcSerde.serializeVector(VectorizedRowBatch vrg,
ObjectInspector objInspector) |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,VectorizedRowBatch> |
VectorizedParquetInputFormat.getRecordReader(org.apache.hadoop.mapred.InputSplit split,
org.apache.hadoop.mapred.JobConf conf,
org.apache.hadoop.mapred.Reporter reporter) |
Copyright © 2017 The Apache Software Foundation. All rights reserved.