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

Interface RowKeyJoin

All Known Implementing Classes:

HashJoinBatch, RowKeyJoinBatch

public interface RowKeyJoin

Interface for a row key join

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	RowKeyJoin.RowKeyJoinState Enum for RowKeyJoin internal state.

Method Summary

Modifier and Type	Method and Description
AbstractRecordBatch.BatchState	getBatchState() Get the current BatchState (this is useful when performing row key join)
RowKeyJoin.RowKeyJoinState	getRowKeyJoinState() Get the current RowKeyJoinState.
boolean	hasRowKeyBatch() Is the next batch of row keys ready to be returned
org.apache.commons.lang3.tuple.Pair<ValueVector,Integer>	nextRowKeyBatch() Get the next batch of row keys
void	setBatchState(AbstractRecordBatch.BatchState newState) Set the BatchState (this is useful when performing row key join)
void	setRowKeyJoinState(RowKeyJoin.RowKeyJoinState newState) Set the RowKeyJoinState (this is useful for maintaining state for row key join algorithm)

Method Detail

hasRowKeyBatch

boolean hasRowKeyBatch()

Is the next batch of row keys ready to be returned

Returns:

True if ready, false if not

nextRowKeyBatch

org.apache.commons.lang3.tuple.Pair<ValueVector,Integer> nextRowKeyBatch()

Get the next batch of row keys

Returns:

a Pair whose left element is the ValueVector containing the row keys, right element is the number of row keys in this batch

getBatchState

AbstractRecordBatch.BatchState getBatchState()

Get the current BatchState (this is useful when performing row key join)

setBatchState

void setBatchState(AbstractRecordBatch.BatchState newState)

Set the BatchState (this is useful when performing row key join)

Parameters:

newState -

setRowKeyJoinState

void setRowKeyJoinState(RowKeyJoin.RowKeyJoinState newState)

Set the RowKeyJoinState (this is useful for maintaining state for row key join algorithm)

Parameters:

newState -

getRowKeyJoinState

RowKeyJoin.RowKeyJoinState getRowKeyJoinState()

Get the current RowKeyJoinState.