org.apache.hadoop.hive.ql.exec.vector

Class VectorHashKeyWrapper

java.lang.Object

org.apache.hadoop.hive.ql.exec.KeyWrapper

org.apache.hadoop.hive.ql.exec.vector.VectorHashKeyWrapper

public class VectorHashKeyWrapper
extends KeyWrapper

A hash map key wrapper for vectorized processing. It stores the key values as primitives in arrays for each supported primitive type. This works in conjunction with VectorHashKeyWrapperBatch to hash vectorized processing units (batches).

Constructor Summary

Constructors

Constructor and Description
VectorHashKeyWrapper(int longValuesCount, int doubleValuesCount, int byteValuesCount, int decimalValuesCount)

Method Summary

Methods

Modifier and Type	Method and Description
void	assignDecimal(int index, HiveDecimalWritable value)
void	assignDouble(int index, double d)
void	assignLong(int index, long v)
void	assignNullDecimal(int index)
void	assignNullDouble(int index)
void	assignNullLong(int index)
void	assignNullString(int index)
void	assignString(int index, byte[] bytes, int start, int length)
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)
HiveDecimalWritable	getDecimal(int i)
double	getDoubleValue(int i)
boolean	getIsBytesNull(int i)
boolean	getIsDecimalNull(int i)
boolean	getIsDoubleNull(int i)
boolean	getIsLongNull(int i)
Object[]	getKeyArray()
long	getLongValue(int i)
void	getNewKey(Object row, ObjectInspector rowInspector)
int	getVariableSize()
int	hashCode()
void	setHashKey()
String	toString()

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

VectorHashKeyWrapper

public VectorHashKeyWrapper(int longValuesCount,
                    int doubleValuesCount,
                    int byteValuesCount,
                    int decimalValuesCount)

Method Detail

getNewKey

public void getNewKey(Object row,
             ObjectInspector rowInspector)
               throws HiveException

Specified by:

getNewKey in class KeyWrapper

Throws:

HiveException

setHashKey

public void setHashKey()

Specified by:

setHashKey in class KeyWrapper

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object that)

Overrides:

equals in class Object

clone

protected Object clone()

Overrides:

clone in class Object

duplicateTo

public void duplicateTo(VectorHashKeyWrapper clone)

copyKey

public KeyWrapper copyKey()

Specified by:

copyKey in class KeyWrapper

copyKey

public void copyKey(KeyWrapper oldWrapper)

Specified by:

copyKey in class KeyWrapper

getKeyArray

public Object[] getKeyArray()

Specified by:

getKeyArray in class KeyWrapper

assignDouble

public void assignDouble(int index,
                double d)

assignNullDouble

public void assignNullDouble(int index)

assignLong

public void assignLong(int index,
              long v)

assignNullLong

public void assignNullLong(int index)

assignString

public void assignString(int index,
                byte[] bytes,
                int start,
                int length)

assignNullString

public void assignNullString(int index)

assignDecimal

public void assignDecimal(int index,
                 HiveDecimalWritable value)

assignNullDecimal

public void assignNullDecimal(int index)

toString

public String toString()

Overrides:

toString in class Object

getIsLongNull

public boolean getIsLongNull(int i)

getIsDoubleNull

public boolean getIsDoubleNull(int i)

getIsBytesNull

public boolean getIsBytesNull(int i)

getLongValue

public long getLongValue(int i)

getDoubleValue

public double getDoubleValue(int i)

getBytes

public byte[] getBytes(int i)

getByteStart

public int getByteStart(int i)

getByteLength

public int getByteLength(int i)

getVariableSize

public int getVariableSize()

getIsDecimalNull

public boolean getIsDecimalNull(int i)

getDecimal

public HiveDecimalWritable getDecimal(int i)