public abstract class VectorMapJoinFastLongHashTable extends VectorMapJoinFastHashTable implements VectorMapJoinLongHashTable
Modifier and Type | Field and Description |
---|---|
static org.slf4j.Logger |
LOG |
protected long[] |
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 |
---|
VectorMapJoinFastLongHashTable(boolean minMaxEnabled,
boolean isOuterJoin,
VectorMapJoinDesc.HashTableKeyType hashTableKeyType,
int initialCapacity,
float loadFactor,
int writeBuffersSize,
long estimatedKeyCount) |
Modifier and Type | Method and Description |
---|---|
void |
add(long key,
org.apache.hadoop.io.BytesWritable currentValue) |
protected abstract void |
assignSlot(int slot,
long key,
boolean isNewKey,
org.apache.hadoop.io.BytesWritable currentValue) |
protected long |
findReadSlot(long key,
long hashCode) |
long |
getEstimatedMemorySize()
Returns estimated memory size based
JavaDataModel |
long |
max() |
long |
min() |
void |
putRow(org.apache.hadoop.io.BytesWritable currentKey,
org.apache.hadoop.io.BytesWritable currentValue) |
boolean |
useMinMax() |
size, throwExpandError
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
size
public VectorMapJoinFastLongHashTable(boolean minMaxEnabled, boolean isOuterJoin, VectorMapJoinDesc.HashTableKeyType hashTableKeyType, int initialCapacity, float loadFactor, int writeBuffersSize, long estimatedKeyCount)
public boolean useMinMax()
useMinMax
in interface VectorMapJoinLongHashTable
public long min()
min
in interface VectorMapJoinLongHashTable
public long max()
max
in interface VectorMapJoinLongHashTable
public void putRow(org.apache.hadoop.io.BytesWritable currentKey, org.apache.hadoop.io.BytesWritable currentValue) throws HiveException, IOException
putRow
in interface VectorMapJoinHashTable
HiveException
IOException
protected abstract void assignSlot(int slot, long key, boolean isNewKey, org.apache.hadoop.io.BytesWritable currentValue)
public void add(long key, org.apache.hadoop.io.BytesWritable currentValue)
protected long findReadSlot(long key, long hashCode)
public long getEstimatedMemorySize()
MemoryEstimate
JavaDataModel
getEstimatedMemorySize
in interface MemoryEstimate
getEstimatedMemorySize
in class VectorMapJoinFastHashTable
Copyright © 2022 The Apache Software Foundation. All rights reserved.