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

Interface Probe

All Known Implementing Classes:

HashJoinProbeTemplate, HashSetOpProbeTemplate, ProbeTemplate

public interface Probe

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static enum	Probe.ProbeState

Method Summary

Modifier and Type	Method	Description
void	changeToFinalProbeState()
int	getOutputCount()
int	probeAndProject()
void	setTargetOutputCount(int targetOutputCount)
default 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)
default 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)

Method Details

setup

default 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

Throws:

SchemaChangeException

setup

default 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

Throws:

SchemaChangeException

probeAndProject

int probeAndProject()
             throws SchemaChangeException

Throws:

SchemaChangeException

changeToFinalProbeState

void changeToFinalProbeState()

setTargetOutputCount

void setTargetOutputCount(int targetOutputCount)

getOutputCount

int getOutputCount()