public abstract class VectorMapJoinFastBytesHashTable extends VectorMapJoinFastHashTable implements VectorMapJoinBytesHashTable
Modifier and Type | Field and Description |
---|---|
protected VectorMapJoinFastKeyStore |
keyStore |
protected long[] |
slotTriples |
protected org.apache.hadoop.io.BytesWritable |
testKeyBytesWritable |
estimatedKeyCount, HIGHEST_INT_POWER_OF_2, keysAssigned, largestNumberOfSteps, loadFactor, logicalHashBucketCount, logicalHashBucketMask, metricExpands, metricPutConflict, ONE_QUARTER_LIMIT, ONE_SIXTH_LIMIT, resizeThreshold, writeBuffersSize
Constructor and Description |
---|
VectorMapJoinFastBytesHashTable(int initialCapacity,
float loadFactor,
int writeBuffersSize,
long estimatedKeyCount) |
Modifier and Type | Method and Description |
---|---|
void |
add(byte[] keyBytes,
int keyStart,
int keyLength,
org.apache.hadoop.io.BytesWritable currentValue) |
protected abstract void |
assignSlot(int slot,
byte[] keyBytes,
int keyStart,
int keyLength,
long hashCode,
boolean isNewKey,
org.apache.hadoop.io.BytesWritable currentValue) |
protected long |
findReadSlot(byte[] keyBytes,
int keyStart,
int keyLength,
long hashCode,
WriteBuffers.Position readPos) |
long |
getEstimatedMemorySize()
Returns estimated memory size based
JavaDataModel |
void |
putRow(org.apache.hadoop.io.BytesWritable currentKey,
org.apache.hadoop.io.BytesWritable currentValue) |
size, throwExpandError
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
size
protected VectorMapJoinFastKeyStore keyStore
protected org.apache.hadoop.io.BytesWritable testKeyBytesWritable
protected long[] slotTriples
public VectorMapJoinFastBytesHashTable(int initialCapacity, float loadFactor, int writeBuffersSize, long estimatedKeyCount)
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, byte[] keyBytes, int keyStart, int keyLength, long hashCode, boolean isNewKey, org.apache.hadoop.io.BytesWritable currentValue)
public void add(byte[] keyBytes, int keyStart, int keyLength, org.apache.hadoop.io.BytesWritable currentValue)
protected final long findReadSlot(byte[] keyBytes, int keyStart, int keyLength, long hashCode, WriteBuffers.Position readPos)
public long getEstimatedMemorySize()
MemoryEstimate
JavaDataModel
getEstimatedMemorySize
in interface MemoryEstimate
getEstimatedMemorySize
in class VectorMapJoinFastHashTable
Copyright © 2022 The Apache Software Foundation. All rights reserved.