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

Interface HashJoinProbe

All Known Implementing Classes:

HashJoinProbeTemplate

public interface HashJoinProbe

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	HashJoinProbe.ProbeState

Field Summary

Fields

Modifier and Type	Field and Description
static TemplateClassDefinition<HashJoinProbe>	TEMPLATE_DEFINITION

Method Summary

Modifier and Type	Method and Description
void	changeToFinalProbeState()
int	getOutputCount()
int	probeAndProject()
void	setTargetOutputCount(int targetOutputCount)
void	setupHashJoinProbe(RecordBatch probeBatch, HashJoinBatch outgoing, org.apache.calcite.rel.core.JoinRelType joinRelType, boolean semiJoin, RecordBatch.IterOutcome leftStartState, HashPartition[] partitions, int cycleNum, VectorContainer container, HashJoinBatch.HashJoinSpilledPartition[] spilledInners, boolean buildSideIsEmpty, int numPartitions, int rightHVColPosition)

Field Detail

TEMPLATE_DEFINITION

static final TemplateClassDefinition<HashJoinProbe> TEMPLATE_DEFINITION

Method Detail

setupHashJoinProbe

void setupHashJoinProbe(RecordBatch probeBatch,
                        HashJoinBatch outgoing,
                        org.apache.calcite.rel.core.JoinRelType joinRelType,
                        boolean semiJoin,
                        RecordBatch.IterOutcome leftStartState,
                        HashPartition[] partitions,
                        int cycleNum,
                        VectorContainer container,
                        HashJoinBatch.HashJoinSpilledPartition[] spilledInners,
                        boolean buildSideIsEmpty,
                        int numPartitions,
                        int rightHVColPosition)

probeAndProject

int probeAndProject()
             throws SchemaChangeException

Throws:

SchemaChangeException

changeToFinalProbeState

void changeToFinalProbeState()

setTargetOutputCount

void setTargetOutputCount(int targetOutputCount)

getOutputCount

int getOutputCount()