public class VectorMapJoinFastLongHashSet extends VectorMapJoinFastLongHashTable implements VectorMapJoinLongHashSet
Modifier and Type | Field and Description |
---|---|
static org.slf4j.Logger |
LOG |
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 |
---|
VectorMapJoinFastLongHashSet(boolean minMaxEnabled,
boolean isOuterJoin,
VectorMapJoinDesc.HashTableKeyType hashTableKeyType,
int initialCapacity,
float loadFactor,
int writeBuffersSize,
long estimatedKeyCount) |
Modifier and Type | Method and Description |
---|---|
void |
assignSlot(int slot,
long key,
boolean isNewKey,
org.apache.hadoop.io.BytesWritable currentValue) |
JoinUtil.JoinResult |
contains(long key,
VectorMapJoinHashSetResult hashSetResult) |
VectorMapJoinHashSetResult |
createHashSetResult() |
void |
testPutRow(long currentKey) |
add, findReadSlot, max, min, putRow, useMinMax
size, throwExpandError
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
max, min, useMinMax
putRow, size
public VectorMapJoinFastLongHashSet(boolean minMaxEnabled, boolean isOuterJoin, VectorMapJoinDesc.HashTableKeyType hashTableKeyType, int initialCapacity, float loadFactor, int writeBuffersSize, long estimatedKeyCount)
public VectorMapJoinHashSetResult createHashSetResult()
createHashSetResult
in interface VectorMapJoinHashSet
public void testPutRow(long currentKey) throws HiveException, IOException
HiveException
IOException
public void assignSlot(int slot, long key, boolean isNewKey, org.apache.hadoop.io.BytesWritable currentValue)
assignSlot
in class VectorMapJoinFastLongHashTable
public JoinUtil.JoinResult contains(long key, VectorMapJoinHashSetResult hashSetResult)
contains
in interface VectorMapJoinLongHashSet
Copyright © 2017 The Apache Software Foundation. All rights reserved.