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

Class HashJoinProbeTemplate

java.lang.Object

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

All Implemented Interfaces:

HashJoinProbe

public class HashJoinProbeTemplate
extends Object
implements HashJoinProbe

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.drill.exec.physical.impl.join.HashJoinProbe

HashJoinProbe.ProbeState

Field Summary

Fields inherited from interface org.apache.drill.exec.physical.impl.join.HashJoinProbe

TEMPLATE_DEFINITION

Constructor Summary

Constructors

Constructor and Description
HashJoinProbeTemplate()

Method Summary

Modifier and Type	Method and Description
void	changeToFinalProbeState()
int	getOutputCount()
int	probeAndProject() Perform the probe, till the outgoing is full, or no more rows to probe.
void	setTargetOutputCount(int targetOutputRecords)
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) Setup the Hash Join Probe object
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

HashJoinProbeTemplate

public HashJoinProbeTemplate()

Method Detail

setTargetOutputCount

public void setTargetOutputCount(int targetOutputRecords)

Specified by:

setTargetOutputCount in interface HashJoinProbe

getOutputCount

public int getOutputCount()

Specified by:

getOutputCount in interface HashJoinProbe

setupHashJoinProbe

public 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)

Setup the Hash Join Probe object

Specified by:

setupHashJoinProbe in interface HashJoinProbe

Parameters:

probeBatch -

outgoing -

joinRelType -

semiJoin -

leftStartState -

partitions -

cycleNum -

container -

spilledInners -

buildSideIsEmpty -

numPartitions -

rightHVColPosition -

probeAndProject

public int probeAndProject()
                    throws SchemaChangeException

Perform the probe, till the outgoing is full, or no more rows to probe. Performs the inner or left-outer join while there are left rows, when done, continue with right-outer, if appropriate.

Specified by:

probeAndProject in interface HashJoinProbe

Returns:

Num of output records

Throws:

SchemaChangeException

changeToFinalProbeState

public void changeToFinalProbeState()

Specified by:

changeToFinalProbeState in interface HashJoinProbe

toString

public String toString()

Overrides:

toString in class Object