public class VectorHashKeyWrapper extends KeyWrapper
VectorHashKeyWrapperBatch
to hash vectorized processing units (batches).Modifier and Type | Class and Description |
---|---|
static class |
VectorHashKeyWrapper.EmptyVectorHashKeyWrapper |
static class |
VectorHashKeyWrapper.HashContext |
Modifier and Type | Field and Description |
---|---|
static VectorHashKeyWrapper |
EMPTY_KEY_WRAPPER |
Modifier and Type | Method and Description |
---|---|
static VectorHashKeyWrapper |
allocate(VectorHashKeyWrapper.HashContext ctx,
int longValuesCount,
int doubleValuesCount,
int byteValuesCount,
int decimalValuesCount,
int timestampValuesCount,
int intervalDayTimeValuesCount,
int keyCount) |
void |
assignDecimal(int index,
org.apache.hadoop.hive.serde2.io.HiveDecimalWritable value) |
void |
assignDouble(int index,
double d) |
void |
assignIntervalDayTime(int index,
org.apache.hadoop.hive.common.type.HiveIntervalDayTime value) |
void |
assignIntervalDayTime(int index,
org.apache.hadoop.hive.ql.exec.vector.IntervalDayTimeColumnVector colVector,
int elementNum) |
void |
assignLong(int keyIndex,
int index,
long v) |
void |
assignLong(int index,
long v)
Deprecated.
|
void |
assignNullDecimal(int keyIndex,
int index) |
void |
assignNullDouble(int keyIndex,
int index) |
void |
assignNullIntervalDayTime(int keyIndex,
int index) |
void |
assignNullLong(int keyIndex,
int index) |
void |
assignNullString(int keyIndex,
int index) |
void |
assignNullTimestamp(int keyIndex,
int index) |
void |
assignString(int index,
byte[] bytes,
int start,
int length) |
void |
assignTimestamp(int index,
Timestamp value) |
void |
assignTimestamp(int index,
org.apache.hadoop.hive.ql.exec.vector.TimestampColumnVector colVector,
int elementNum) |
void |
clearIsNull() |
protected Object |
clone() |
KeyWrapper |
copyKey() |
void |
copyKey(KeyWrapper oldWrapper) |
void |
duplicateTo(VectorHashKeyWrapper clone) |
boolean |
equals(Object that) |
int |
getByteLength(int i) |
byte[] |
getBytes(int i) |
int |
getByteStart(int i) |
org.apache.hadoop.hive.serde2.io.HiveDecimalWritable |
getDecimal(int i) |
double |
getDoubleValue(int i) |
org.apache.hadoop.hive.common.type.HiveIntervalDayTime |
getIntervalDayTime(int i) |
Object[] |
getKeyArray() |
long |
getLongValue(int i) |
void |
getNewKey(Object row,
ObjectInspector rowInspector) |
Timestamp |
getTimestamp(int i) |
int |
getVariableSize() |
int |
hashCode() |
boolean |
isNull(int keyIndex) |
void |
setHashKey() |
void |
setNull() |
String |
stringifyKeys(VectorColumnSetInfo columnSetInfo) |
String |
toString() |
public static final VectorHashKeyWrapper EMPTY_KEY_WRAPPER
public static VectorHashKeyWrapper allocate(VectorHashKeyWrapper.HashContext ctx, int longValuesCount, int doubleValuesCount, int byteValuesCount, int decimalValuesCount, int timestampValuesCount, int intervalDayTimeValuesCount, int keyCount)
public void getNewKey(Object row, ObjectInspector rowInspector) throws HiveException
getNewKey
in class KeyWrapper
HiveException
public void setHashKey()
setHashKey
in class KeyWrapper
public void duplicateTo(VectorHashKeyWrapper clone)
public KeyWrapper copyKey()
copyKey
in class KeyWrapper
public void copyKey(KeyWrapper oldWrapper)
copyKey
in class KeyWrapper
public Object[] getKeyArray()
getKeyArray
in class KeyWrapper
public void assignLong(int keyIndex, int index, long v)
@Deprecated public void assignLong(int index, long v)
public void assignNullLong(int keyIndex, int index)
public void assignDouble(int index, double d)
public void assignNullDouble(int keyIndex, int index)
public void assignString(int index, byte[] bytes, int start, int length)
public void assignNullString(int keyIndex, int index)
public void assignDecimal(int index, org.apache.hadoop.hive.serde2.io.HiveDecimalWritable value)
public void assignNullDecimal(int keyIndex, int index)
public void assignTimestamp(int index, Timestamp value)
public void assignTimestamp(int index, org.apache.hadoop.hive.ql.exec.vector.TimestampColumnVector colVector, int elementNum)
public void assignNullTimestamp(int keyIndex, int index)
public void assignIntervalDayTime(int index, org.apache.hadoop.hive.common.type.HiveIntervalDayTime value)
public void assignIntervalDayTime(int index, org.apache.hadoop.hive.ql.exec.vector.IntervalDayTimeColumnVector colVector, int elementNum)
public void assignNullIntervalDayTime(int keyIndex, int index)
public String stringifyKeys(VectorColumnSetInfo columnSetInfo)
public long getLongValue(int i)
public double getDoubleValue(int i)
public byte[] getBytes(int i)
public int getByteStart(int i)
public int getByteLength(int i)
public int getVariableSize()
public org.apache.hadoop.hive.serde2.io.HiveDecimalWritable getDecimal(int i)
public Timestamp getTimestamp(int i)
public org.apache.hadoop.hive.common.type.HiveIntervalDayTime getIntervalDayTime(int i)
public void clearIsNull()
public void setNull()
public boolean isNull(int keyIndex)
Copyright © 2022 The Apache Software Foundation. All rights reserved.