Package org.apache.drill.exec.physical.impl.join

Class HashJoinHelper

java.lang.Object

org.apache.drill.exec.physical.impl.join.HashJoinHelper

public class HashJoinHelper
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	HashJoinHelper.BuildInfo

Field Summary

Fields

Modifier and Type	Field	Description
static final int	LEFT_INPUT
static final int	RIGHT_INPUT

Constructor Summary

Constructors

Constructor	Description
HashJoinHelper(FragmentContext context, BufferAllocator allocator)

Method Summary

Modifier and Type	Method	Description
void	addNewBatch(int recordCount)
void	addStartIndexBatch()
void	clear()
SelectionVector4	getNewSV4(int recordCount)
int	getNextIndex(int currentIdx)	Takes a composite index for a key produced by getStartIndex(int), and returns the composite index for the next record in the list of records that match a key.
com.carrotsearch.hppc.IntArrayList	getNextUnmatchedIndex()
int	getStartIndex(int keyIndex)	Takes a composite index for a key produced by HashTable.probeForKey(int, int), and uses it to look up the index of the first original key in the original data.
void	setCurrentIndex(int keyIndex, int batchIndex, int recordIndex)
boolean	setRecordMatched(int index)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

LEFT_INPUT

public static final int LEFT_INPUT

See Also:

• Constant Field Values

RIGHT_INPUT

public static final int RIGHT_INPUT

See Also:

• Constant Field Values

Constructor Details

HashJoinHelper

public HashJoinHelper(FragmentContext context,
 BufferAllocator allocator)

Method Details

addStartIndexBatch

public void addStartIndexBatch()
                        throws SchemaChangeException

Throws:

SchemaChangeException

getNewSV4

public SelectionVector4 getNewSV4(int recordCount)
                           throws SchemaChangeException

Throws:

SchemaChangeException

addNewBatch

public void addNewBatch(int recordCount)
                 throws SchemaChangeException

Throws:

SchemaChangeException

getStartIndex

public int getStartIndex(int keyIndex)

Takes a composite index for a key produced by HashTable.probeForKey(int, int), and uses it to look up the index of the first original key in the original data.

Parameters:

keyIndex - A composite index for a key produced by HashTable.probeForKey(int, int)

Returns:

The composite index for the first added key record in the original data.

getNextIndex

public int getNextIndex(int currentIdx)

Takes a composite index for a key produced by getStartIndex(int), and returns the composite index for the next record in the list of records that match a key. The result is a composite index for a record within the original data set.

Parameters:

currentIdx - A composite index for a key produced by getStartIndex(int).

Returns:

The composite index for the next record in the list of records that match a key. The result is a composite index for a record within the original data set.

getNextUnmatchedIndex

public com.carrotsearch.hppc.IntArrayList getNextUnmatchedIndex()

setRecordMatched

public boolean setRecordMatched(int index)

setCurrentIndex

public void setCurrentIndex(int keyIndex,
 int batchIndex,
 int recordIndex)
                     throws SchemaChangeException

Throws:

SchemaChangeException

clear

public void clear()