public abstract class VectorMapJoinFastBytesHashMap extends VectorMapJoinFastBytesHashTable implements VectorMapJoinBytesHashMap
Modifier and Type | Field and Description |
---|---|
protected org.apache.hadoop.io.BytesWritable |
testValueBytesWritable |
keyStore, slotTriples, 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 |
---|
VectorMapJoinFastBytesHashMap(int initialCapacity,
float loadFactor,
int writeBuffersSize,
long estimatedKeyCount) |
Modifier and Type | Method and Description |
---|---|
void |
assignSlot(int slot,
byte[] keyBytes,
int keyStart,
int keyLength,
long hashCode,
boolean isNewKey,
org.apache.hadoop.io.BytesWritable currentValue) |
VectorMapJoinHashMapResult |
createHashMapResult() |
JoinUtil.JoinResult |
lookup(byte[] keyBytes,
int keyStart,
int keyLength,
VectorMapJoinHashMapResult hashMapResult) |
add, findReadSlot, putRow
size, throwExpandError
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
putRow, size
protected org.apache.hadoop.io.BytesWritable testValueBytesWritable
public VectorMapJoinFastBytesHashMap(int initialCapacity, float loadFactor, int writeBuffersSize, long estimatedKeyCount)
public VectorMapJoinHashMapResult createHashMapResult()
createHashMapResult
in interface VectorMapJoinHashMap
public void assignSlot(int slot, byte[] keyBytes, int keyStart, int keyLength, long hashCode, boolean isNewKey, org.apache.hadoop.io.BytesWritable currentValue)
assignSlot
in class VectorMapJoinFastBytesHashTable
public JoinUtil.JoinResult lookup(byte[] keyBytes, int keyStart, int keyLength, VectorMapJoinHashMapResult hashMapResult)
lookup
in interface VectorMapJoinBytesHashMap
Copyright © 2021 The Apache Software Foundation. All rights reserved.