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

Class HashSetOpProbeTemplate

java.lang.Object

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

org.apache.drill.exec.physical.impl.setop.HashSetOpProbeTemplate

All Implemented Interfaces:

Probe

public class HashSetOpProbeTemplate
extends ProbeTemplate<SetOp>

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
HashSetOpProbeTemplate()

Method Summary

Modifier and Type	Method	Description
void	changeToFinalProbeState()
protected void	handleProbeResult(int probeIndex)
void	setup(RecordBatch probeBatch, HashSetOpRecordBatch outgoing, org.apache.calcite.sql.SqlKind opType, boolean isAll, RecordBatch.IterOutcome leftStartState, HashPartition[] partitions, int cycleNum, VectorContainer container, AbstractHashBinaryRecordBatch.SpilledPartition[] spilledInners, boolean buildSideIsEmpty, int numPartitions)	Setup the Hash Set Op 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

HashSetOpProbeTemplate

public HashSetOpProbeTemplate()

Method Details

setup

public void setup(RecordBatch probeBatch,
 HashSetOpRecordBatch outgoing,
 org.apache.calcite.sql.SqlKind opType,
 boolean isAll,
 RecordBatch.IterOutcome leftStartState,
 HashPartition[] partitions,
 int cycleNum,
 VectorContainer container,
 AbstractHashBinaryRecordBatch.SpilledPartition[] spilledInners,
 boolean buildSideIsEmpty,
 int numPartitions)
           throws SchemaChangeException

Setup the Hash Set Op Probe object

Throws:

SchemaChangeException

handleProbeResult

protected void handleProbeResult(int probeIndex)

Specified by:

handleProbeResult in class ProbeTemplate<SetOp>

changeToFinalProbeState

public void changeToFinalProbeState()

toString

public String toString()

Overrides:

toString in class Object