public class VectorMapJoinFastLongHashSetContainer extends VectorMapJoinFastHashTableContainerBase implements VectorMapJoinLongHashSet
Modifier and Type | Field and Description |
---|---|
static org.slf4j.Logger |
LOG |
Constructor and Description |
---|
VectorMapJoinFastLongHashSetContainer(boolean isFullOuter,
boolean minMaxEnabled,
VectorMapJoinDesc.HashTableKeyType hashTableKeyType,
int initialCapacity,
float loadFactor,
int writeBuffersSize,
long estimatedKeyCount,
TableDesc tableDesc,
int numHTs) |
Modifier and Type | Method and Description |
---|---|
JoinUtil.JoinResult |
contains(long key,
VectorMapJoinHashSetResult hashSetResult) |
VectorMapJoinHashSetResult |
createHashSetResult() |
MatchTracker |
createMatchTracker() |
VectorMapJoinNonMatchedIterator |
createNonMatchedIterator(MatchTracker matchTracker) |
long |
getEstimatedMemorySize()
Returns estimated memory size based
JavaDataModel |
long |
getHashCode(org.apache.hadoop.io.BytesWritable currentKey) |
long |
max() |
long |
min() |
void |
putRow(long hashCode,
org.apache.hadoop.io.BytesWritable currentKey,
org.apache.hadoop.io.BytesWritable currentValue) |
int |
size()
Get hash table size
|
int |
spillPartitionId() |
boolean |
useMinMax() |
containsLongKey
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
containsLongKey
public VectorMapJoinFastLongHashSetContainer(boolean isFullOuter, boolean minMaxEnabled, VectorMapJoinDesc.HashTableKeyType hashTableKeyType, int initialCapacity, float loadFactor, int writeBuffersSize, long estimatedKeyCount, TableDesc tableDesc, int numHTs)
public VectorMapJoinHashSetResult createHashSetResult()
createHashSetResult
in interface VectorMapJoinHashSet
public long getHashCode(org.apache.hadoop.io.BytesWritable currentKey) throws HiveException, IOException
getHashCode
in class VectorMapJoinFastHashTableContainerBase
HiveException
IOException
public void putRow(long hashCode, org.apache.hadoop.io.BytesWritable currentKey, org.apache.hadoop.io.BytesWritable currentValue) throws HiveException, IOException
putRow
in interface VectorMapJoinHashTable
putRow
in class VectorMapJoinFastHashTableContainerBase
hashCode
- current HashCode to avoid re-computationcurrentKey
- The current Key in bytescurrentValue
- The current Value in bytesHiveException
IOException
public JoinUtil.JoinResult contains(long key, VectorMapJoinHashSetResult hashSetResult)
contains
in interface VectorMapJoinLongHashSet
public long getEstimatedMemorySize()
MemoryEstimate
JavaDataModel
getEstimatedMemorySize
in interface MemoryEstimate
getEstimatedMemorySize
in class VectorMapJoinFastHashTableContainerBase
public int size()
VectorMapJoinHashTable
size
in interface VectorMapJoinHashTable
size
in class VectorMapJoinFastHashTableContainerBase
public MatchTracker createMatchTracker()
createMatchTracker
in interface VectorMapJoinHashTable
public VectorMapJoinNonMatchedIterator createNonMatchedIterator(MatchTracker matchTracker)
createNonMatchedIterator
in interface VectorMapJoinHashTable
public int spillPartitionId()
spillPartitionId
in interface VectorMapJoinHashTable
public boolean useMinMax()
useMinMax
in interface VectorMapJoinLongHashTable
public long min()
min
in interface VectorMapJoinLongHashTable
public long max()
max
in interface VectorMapJoinLongHashTable
Copyright © 2022 The Apache Software Foundation. All rights reserved.