public abstract class VectorMapJoinFastBytesHashSet extends VectorMapJoinFastBytesHashTable implements VectorMapJoinBytesHashSet
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 |
---|
VectorMapJoinFastBytesHashSet(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) |
JoinUtil.JoinResult |
contains(byte[] keyBytes,
int keyStart,
int keyLength,
VectorMapJoinHashSetResult hashSetResult) |
VectorMapJoinHashSetResult |
createHashSetResult() |
long |
getEstimatedMemorySize()
Returns estimated memory size based
JavaDataModel |
add, findReadSlot, putRow
size, throwExpandError
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
putRow, size
public VectorMapJoinFastBytesHashSet(int initialCapacity, float loadFactor, int writeBuffersSize, long estimatedKeyCount)
public VectorMapJoinHashSetResult createHashSetResult()
createHashSetResult
in interface VectorMapJoinHashSet
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 contains(byte[] keyBytes, int keyStart, int keyLength, VectorMapJoinHashSetResult hashSetResult)
contains
in interface VectorMapJoinBytesHashSet
public long getEstimatedMemorySize()
MemoryEstimate
JavaDataModel
getEstimatedMemorySize
in interface MemoryEstimate
getEstimatedMemorySize
in class VectorMapJoinFastBytesHashTable
Copyright © 2022 The Apache Software Foundation. All rights reserved.