public class VectorMapJoinFastLongHashMultiSet extends VectorMapJoinFastLongHashTable implements VectorMapJoinLongHashMultiSet
Modifier and Type | Field and Description |
---|---|
static org.slf4j.Logger |
LOG |
slotPairs
keysAssigned, largestNumberOfSteps, loadFactor, logicalHashBucketCount, logicalHashBucketMask, metricExpands, metricPutConflict, resizeThreshold, writeBuffersSize
Constructor and Description |
---|
VectorMapJoinFastLongHashMultiSet(boolean minMaxEnabled,
boolean isOuterJoin,
VectorMapJoinDesc.HashTableKeyType hashTableKeyType,
int initialCapacity,
float loadFactor,
int writeBuffersSize) |
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,
VectorMapJoinHashMultiSetResult hashMultiSetResult) |
VectorMapJoinHashMultiSetResult |
createHashMultiSetResult() |
void |
testPutRow(long currentKey) |
add, findReadSlot, max, min, putRow, useMinMax
size
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
max, min, useMinMax
putRow, size
public VectorMapJoinFastLongHashMultiSet(boolean minMaxEnabled, boolean isOuterJoin, VectorMapJoinDesc.HashTableKeyType hashTableKeyType, int initialCapacity, float loadFactor, int writeBuffersSize)
public VectorMapJoinHashMultiSetResult createHashMultiSetResult()
createHashMultiSetResult
in interface VectorMapJoinHashMultiSet
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, VectorMapJoinHashMultiSetResult hashMultiSetResult)
contains
in interface VectorMapJoinLongHashMultiSet
Copyright © 2016 The Apache Software Foundation. All rights reserved.