public class VectorMapJoinFastLongHashMap extends VectorMapJoinFastLongHashTable implements VectorMapJoinLongHashMap, MemoryEstimate
Modifier and Type | Field and Description |
---|---|
static org.slf4j.Logger |
LOG |
protected VectorMapJoinFastValueStore |
valueStore |
slotPairs
estimatedKeyCount, HIGHEST_INT_POWER_OF_2, keysAssigned, largestNumberOfSteps, loadFactor, logicalHashBucketCount, logicalHashBucketMask, metricExpands, metricPutConflict, ONE_QUARTER_LIMIT, ONE_SIXTH_LIMIT, resizeThreshold, writeBuffersSize
Constructor and Description |
---|
VectorMapJoinFastLongHashMap(boolean minMaxEnabled,
boolean isOuterJoin,
VectorMapJoinDesc.HashTableKeyType hashTableKeyType,
int initialCapacity,
float loadFactor,
int writeBuffersSize,
long estimatedKeyCount) |
Modifier and Type | Method and Description |
---|---|
void |
assignSlot(int slot,
long key,
boolean isNewKey,
org.apache.hadoop.io.BytesWritable currentValue) |
VectorMapJoinHashMapResult |
createHashMapResult() |
long |
getEstimatedMemorySize()
Returns estimated memory size based
JavaDataModel |
JoinUtil.JoinResult |
lookup(long key,
VectorMapJoinHashMapResult hashMapResult) |
void |
testPutRow(long currentKey,
byte[] currentValue) |
add, findReadSlot, max, min, putRow, useMinMax
size, throwExpandError
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, long estimatedKeyCount)
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
public long getEstimatedMemorySize()
MemoryEstimate
JavaDataModel
getEstimatedMemorySize
in interface MemoryEstimate
getEstimatedMemorySize
in class VectorMapJoinFastLongHashTable
Copyright © 2022 The Apache Software Foundation. All rights reserved.