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

Class HashJoinProbeTemplate

java.lang.Object

org.apache.drill.exec.physical.impl.join.ProbeTemplate<HashJoinPOP>

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

All Implemented Interfaces:

Probe

public class HashJoinProbeTemplate
extends ProbeTemplate<HashJoinPOP>

Nested Class Summary

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

Probe.ProbeState

Field Summary

Fields inherited from class org.apache.drill.exec.physical.impl.join.ProbeTemplate

bitsInMask, buildSideIsEmpty, container, currentCompositeIdx, currPartition, currRightPartition, cycleNum, getNextRecord, numberOfBuildSideColumns, numPartitions, outgoingBatch, outputRecords, partitionMask, partitions, probeBatch, probeSchema, probeState, recordsProcessed, recordsToProcess, spilledInners, targetOutputRecords, unmatchedBuildIndexes

Constructor Summary

Constructors

Constructor	Description
HashJoinProbeTemplate()

Method Summary

Modifier and Type	Method	Description
void	changeToFinalProbeState()
protected void	handleProbeResult(int probeIndex)
void	setup(RecordBatch probeBatch, HashJoinBatch outgoing, org.apache.calcite.rel.core.JoinRelType joinRelType, boolean semiJoin, RecordBatch.IterOutcome leftStartState, HashPartition[] partitions, int cycleNum, VectorContainer container, AbstractHashBinaryRecordBatch.SpilledPartition[] spilledInners, boolean buildSideIsEmpty, int numPartitions, int rightHVColPosition)	Setup the Hash Join Probe object
String	toString()

Methods inherited from class org.apache.drill.exec.physical.impl.join.ProbeTemplate

executeProjectRightPhase, getOutputCount, outputRow, probeAndProject, setTargetOutputCount, setup

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.drill.exec.physical.impl.join.Probe

setup

Constructor Details

HashJoinProbeTemplate

public HashJoinProbeTemplate()

Method Details

setup

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

Setup the Hash Join Probe object

Throws:

SchemaChangeException

handleProbeResult

protected void handleProbeResult(int probeIndex)

Specified by:

handleProbeResult in class ProbeTemplate<HashJoinPOP>

changeToFinalProbeState

public void changeToFinalProbeState()

toString

public String toString()

Overrides:

toString in class Object