public class VectorMapJoinFastLongHashMap extends VectorMapJoinFastLongHashTable implements VectorMapJoinLongHashMap
Modifier and Type | Field and Description |
---|---|
static org.slf4j.Logger |
LOG |
protected VectorMapJoinFastValueStore |
valueStore |
slotPairs
keysAssigned, largestNumberOfSteps, loadFactor, logicalHashBucketCount, logicalHashBucketMask, metricExpands, metricPutConflict, resizeThreshold, writeBuffersSize
Constructor and Description |
---|
VectorMapJoinFastLongHashMap(boolean minMaxEnabled,
boolean isOuterJoin,
VectorMapJoinDesc.HashTableKeyType hashTableKeyType,
int initialCapacity,
float loadFactor,
int writeBuffersSize) |
Modifier and Type | Method and Description |
---|---|
void |
assignSlot(int slot,
long key,
boolean isNewKey,
org.apache.hadoop.io.BytesWritable currentValue) |
VectorMapJoinHashMapResult |
createHashMapResult() |
JoinUtil.JoinResult |
lookup(long key,
VectorMapJoinHashMapResult hashMapResult) |
void |
testPutRow(long currentKey,
byte[] currentValue) |
add, findReadSlot, max, min, putRow, useMinMax
size
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
max, min, useMinMax
putRow, size
public static final org.slf4j.Logger LOG
protected VectorMapJoinFastValueStore valueStore
public VectorMapJoinFastLongHashMap(boolean minMaxEnabled, boolean isOuterJoin, VectorMapJoinDesc.HashTableKeyType hashTableKeyType, int initialCapacity, float loadFactor, int writeBuffersSize)
public VectorMapJoinHashMapResult createHashMapResult()
createHashMapResult
in interface VectorMapJoinHashMap
public void testPutRow(long currentKey, byte[] currentValue) throws HiveException, IOException
HiveException
IOException
public void assignSlot(int slot, long key, boolean isNewKey, org.apache.hadoop.io.BytesWritable currentValue)
assignSlot
in class VectorMapJoinFastLongHashTable
public JoinUtil.JoinResult lookup(long key, VectorMapJoinHashMapResult hashMapResult)
lookup
in interface VectorMapJoinLongHashMap
Copyright © 2016 The Apache Software Foundation. All rights reserved.