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

Interface NestedLoopJoin

All Known Implementing Classes:

NestedLoopJoinTemplate

public interface NestedLoopJoin

Interface for the nested loop join operator.

Field Summary

Fields

Modifier and Type	Field	Description
static final TemplateClassDefinition<NestedLoopJoin>	TEMPLATE_DEFINITION

Method Summary

Modifier and Type	Method	Description
void	doSetup(FragmentContext context, VectorContainer rightContainer, RecordBatch leftBatch, RecordBatch outgoing)
void	emitLeft(int leftIndex, int outIndex)
void	emitRight(int batchIndex, int recordIndexWithinBatch, int outIndex)
int	outputRecords(org.apache.calcite.rel.core.JoinRelType joinType)
void	setTargetOutputCount(int targetOutputCount)
void	setupNestedLoopJoin(FragmentContext context, RecordBatch left, RecordBatch.IterOutcome leftOutcome, ExpandableHyperContainer rightContainer, LinkedList<Integer> rightCounts, NestedLoopJoinBatch outgoing)

Field Details

TEMPLATE_DEFINITION

static final TemplateClassDefinition<NestedLoopJoin> TEMPLATE_DEFINITION

Method Details

setupNestedLoopJoin

void setupNestedLoopJoin(FragmentContext context,
 RecordBatch left,
 RecordBatch.IterOutcome leftOutcome,
 ExpandableHyperContainer rightContainer,
 LinkedList<Integer> rightCounts,
 NestedLoopJoinBatch outgoing)

setTargetOutputCount

void setTargetOutputCount(int targetOutputCount)

outputRecords

int outputRecords(org.apache.calcite.rel.core.JoinRelType joinType)
           throws SchemaChangeException

Throws:

SchemaChangeException

emitLeft

void emitLeft(int leftIndex,
 int outIndex)

emitRight

void emitRight(int batchIndex,
 int recordIndexWithinBatch,
 int outIndex)

doSetup

void doSetup(FragmentContext context,
 VectorContainer rightContainer,
 RecordBatch leftBatch,
 RecordBatch outgoing)