Uses of Class
org.apache.drill.exec.record.RecordBatch.IterOutcome

Packages that use RecordBatch.IterOutcome

Package	Description
org.apache.drill.exec.physical.base
org.apache.drill.exec.physical.impl
org.apache.drill.exec.physical.impl.aggregate
org.apache.drill.exec.physical.impl.filter
org.apache.drill.exec.physical.impl.flatten
org.apache.drill.exec.physical.impl.join
org.apache.drill.exec.physical.impl.limit
org.apache.drill.exec.physical.impl.mergereceiver
org.apache.drill.exec.physical.impl.metadata
org.apache.drill.exec.physical.impl.orderedpartitioner
org.apache.drill.exec.physical.impl.producer
org.apache.drill.exec.physical.impl.project
org.apache.drill.exec.physical.impl.protocol	Defines a revised implementation of the Drill RecordBatch protocol.
org.apache.drill.exec.physical.impl.rangepartitioner
org.apache.drill.exec.physical.impl.sort
org.apache.drill.exec.physical.impl.statistics
org.apache.drill.exec.physical.impl.svremover
org.apache.drill.exec.physical.impl.TopN
org.apache.drill.exec.physical.impl.trace
org.apache.drill.exec.physical.impl.union
org.apache.drill.exec.physical.impl.unnest
org.apache.drill.exec.physical.impl.unorderedreceiver
org.apache.drill.exec.physical.impl.unpivot
org.apache.drill.exec.physical.impl.validate
org.apache.drill.exec.physical.impl.window
org.apache.drill.exec.physical.impl.xsort
org.apache.drill.exec.record

Uses of RecordBatch.IterOutcome in org.apache.drill.exec.physical.base

Methods in org.apache.drill.exec.physical.base that return RecordBatch.IterOutcome

Modifier and Type	Method and Description
RecordBatch.IterOutcome	LateralContract.getLeftOutcome() Get the current outcome of left incoming batch.

Uses of RecordBatch.IterOutcome in org.apache.drill.exec.physical.impl

Methods in org.apache.drill.exec.physical.impl that return RecordBatch.IterOutcome

Modifier and Type	Method and Description
RecordBatch.IterOutcome	StatisticsWriterRecordBatch.innerNext()
RecordBatch.IterOutcome	WriterRecordBatch.innerNext()
RecordBatch.IterOutcome	ScanBatch.next()
RecordBatch.IterOutcome	BaseRootExec.next(RecordBatch b)

Uses of RecordBatch.IterOutcome in org.apache.drill.exec.physical.impl.aggregate

Methods in org.apache.drill.exec.physical.impl.aggregate that return RecordBatch.IterOutcome

Modifier and Type	Method and Description
RecordBatch.IterOutcome	SpilledRecordBatch.getInitialOutcome() Return the initial outcome (from the first next() call )
RecordBatch.IterOutcome	HashAggregator.getOutcome()
RecordBatch.IterOutcome	HashAggTemplate.getOutcome()
RecordBatch.IterOutcome	StreamingAggregator.getOutcome()
RecordBatch.IterOutcome	StreamingAggTemplate.getOutcome()
RecordBatch.IterOutcome	HashAggBatch.innerNext()
RecordBatch.IterOutcome	StreamingAggBatch.innerNext()
RecordBatch.IterOutcome	BatchIterator.next()
RecordBatch.IterOutcome	SpilledRecordBatch.next() Read the next batch from the spill file

Methods in org.apache.drill.exec.physical.impl.aggregate with parameters of type RecordBatch.IterOutcome

Modifier and Type	Method and Description
StreamingAggregator.AggOutcome	StreamingAggregator.doWork(RecordBatch.IterOutcome outerOutcome)
StreamingAggregator.AggOutcome	StreamingAggTemplate.doWork(RecordBatch.IterOutcome outerOutcome)

Uses of RecordBatch.IterOutcome in org.apache.drill.exec.physical.impl.filter

Methods in org.apache.drill.exec.physical.impl.filter that return RecordBatch.IterOutcome

Modifier and Type	Method and Description
protected RecordBatch.IterOutcome	FilterRecordBatch.doWork()
protected RecordBatch.IterOutcome	RuntimeFilterRecordBatch.doWork()

Uses of RecordBatch.IterOutcome in org.apache.drill.exec.physical.impl.flatten

Methods in org.apache.drill.exec.physical.impl.flatten that return RecordBatch.IterOutcome

Modifier and Type	Method and Description
protected RecordBatch.IterOutcome	FlattenRecordBatch.doWork()
RecordBatch.IterOutcome	FlattenRecordBatch.innerNext()

Uses of RecordBatch.IterOutcome in org.apache.drill.exec.physical.impl.join

Methods in org.apache.drill.exec.physical.impl.join that return RecordBatch.IterOutcome

Modifier and Type	Method and Description
RecordBatch.IterOutcome	HashJoinBatch.executeBuildPhase() Execute the BUILD phase; first read incoming and split rows into partitions; may decide to spill some of the partitions
RecordBatch.IterOutcome	LateralJoinBatch.getLeftOutcome() Returns the current RecordBatch.IterOutcome for the left incoming batch
RecordBatch.IterOutcome	JoinStatus.getLeftStatus()
RecordBatch.IterOutcome	JoinStatus.getRightStatus()
RecordBatch.IterOutcome	LateralJoinBatch.innerNext() Gets the left and right incoming batch and produce the output batch.
RecordBatch.IterOutcome	NestedLoopJoinBatch.innerNext() Method drains the right side input of the NLJ and accumulates the data in a hyper container.
RecordBatch.IterOutcome	RowKeyJoinBatch.innerNext()
RecordBatch.IterOutcome	HashJoinBatch.innerNext()
RecordBatch.IterOutcome	MergeJoinBatch.innerNext()

Methods in org.apache.drill.exec.physical.impl.join with parameters of type RecordBatch.IterOutcome

Modifier and Type	Method and Description
void	HashJoinProbe.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)
void	HashJoinProbeTemplate.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

Uses of RecordBatch.IterOutcome in org.apache.drill.exec.physical.impl.limit

Methods in org.apache.drill.exec.physical.impl.limit that return RecordBatch.IterOutcome

Modifier and Type	Method and Description
protected RecordBatch.IterOutcome	LimitRecordBatch.doWork()
protected RecordBatch.IterOutcome	PartitionLimitRecordBatch.doWork()
protected RecordBatch.IterOutcome	LimitRecordBatch.getFinalOutcome(boolean hasRemainder) Gets the outcome to return from super implementation and then in case of EMIT outcome it refreshes the state of operator.
protected RecordBatch.IterOutcome	PartitionLimitRecordBatch.getFinalOutcome(boolean hasRemainder) Gets the outcome to return from super implementation and then in case of EMIT outcome it refreshes the state of operator.
RecordBatch.IterOutcome	LimitRecordBatch.innerNext()

Uses of RecordBatch.IterOutcome in org.apache.drill.exec.physical.impl.mergereceiver

Methods in org.apache.drill.exec.physical.impl.mergereceiver that return RecordBatch.IterOutcome

Modifier and Type	Method and Description
RecordBatch.IterOutcome	MergingRecordBatch.innerNext()

Uses of RecordBatch.IterOutcome in org.apache.drill.exec.physical.impl.metadata

Methods in org.apache.drill.exec.physical.impl.metadata that return RecordBatch.IterOutcome

Modifier and Type	Method and Description
RecordBatch.IterOutcome	MetadataHandlerBatch.doWork()
RecordBatch.IterOutcome	MetadataControllerBatch.innerNext()
RecordBatch.IterOutcome	MetadataHandlerBatch.innerNext()

Uses of RecordBatch.IterOutcome in org.apache.drill.exec.physical.impl.orderedpartitioner

Methods in org.apache.drill.exec.physical.impl.orderedpartitioner that return RecordBatch.IterOutcome

Modifier and Type	Method and Description
RecordBatch.IterOutcome	OrderedPartitionRecordBatch.innerNext()

Uses of RecordBatch.IterOutcome in org.apache.drill.exec.physical.impl.producer

Methods in org.apache.drill.exec.physical.impl.producer that return RecordBatch.IterOutcome

Modifier and Type	Method and Description
RecordBatch.IterOutcome	ProducerConsumerBatch.innerNext()

Uses of RecordBatch.IterOutcome in org.apache.drill.exec.physical.impl.project

Methods in org.apache.drill.exec.physical.impl.project that return RecordBatch.IterOutcome

Modifier and Type	Method and Description
protected RecordBatch.IterOutcome	ProjectRecordBatch.doWork()
protected RecordBatch.IterOutcome	ProjectRecordBatch.getFinalOutcome(boolean hasMoreRecordInBoundary)
protected RecordBatch.IterOutcome	ProjectRecordBatch.handleNullInput() Handle Null input specially when Project operator is for query output.
RecordBatch.IterOutcome	ProjectRecordBatch.innerNext()

Uses of RecordBatch.IterOutcome in org.apache.drill.exec.physical.impl.protocol

Methods in org.apache.drill.exec.physical.impl.protocol that return RecordBatch.IterOutcome

Modifier and Type	Method and Description
RecordBatch.IterOutcome	OperatorDriver.next() Get the next batch.
RecordBatch.IterOutcome	OperatorRecordBatch.next()

Uses of RecordBatch.IterOutcome in org.apache.drill.exec.physical.impl.rangepartitioner

Methods in org.apache.drill.exec.physical.impl.rangepartitioner that return RecordBatch.IterOutcome

Modifier and Type	Method and Description
protected RecordBatch.IterOutcome	RangePartitionRecordBatch.doWork()

Uses of RecordBatch.IterOutcome in org.apache.drill.exec.physical.impl.sort

Methods in org.apache.drill.exec.physical.impl.sort that return RecordBatch.IterOutcome

Modifier and Type	Method and Description
RecordBatch.IterOutcome	SortBatch.innerNext()

Uses of RecordBatch.IterOutcome in org.apache.drill.exec.physical.impl.statistics

Methods in org.apache.drill.exec.physical.impl.statistics that return RecordBatch.IterOutcome

Modifier and Type	Method and Description
protected RecordBatch.IterOutcome	StatisticsMergeBatch.doWork()
RecordBatch.IterOutcome	StatisticsMergeBatch.innerNext()

Uses of RecordBatch.IterOutcome in org.apache.drill.exec.physical.impl.svremover

Methods in org.apache.drill.exec.physical.impl.svremover that return RecordBatch.IterOutcome

Modifier and Type	Method and Description
protected RecordBatch.IterOutcome	RemovingRecordBatch.doWork()

Uses of RecordBatch.IterOutcome in org.apache.drill.exec.physical.impl.TopN

Methods in org.apache.drill.exec.physical.impl.TopN that return RecordBatch.IterOutcome

Modifier and Type	Method and Description
RecordBatch.IterOutcome	TopNBatch.innerNext()

Uses of RecordBatch.IterOutcome in org.apache.drill.exec.physical.impl.trace

Methods in org.apache.drill.exec.physical.impl.trace that return RecordBatch.IterOutcome

Modifier and Type	Method and Description
protected RecordBatch.IterOutcome	TraceRecordBatch.doWork() Invoked for every record batch and it simply dumps the buffers associated with all the value vectors in this record batch to a log file.

Uses of RecordBatch.IterOutcome in org.apache.drill.exec.physical.impl.union

Methods in org.apache.drill.exec.physical.impl.union that return RecordBatch.IterOutcome

Modifier and Type	Method and Description
RecordBatch.IterOutcome	UnionAllRecordBatch.innerNext()

Uses of RecordBatch.IterOutcome in org.apache.drill.exec.physical.impl.unnest

Methods in org.apache.drill.exec.physical.impl.unnest that return RecordBatch.IterOutcome

Modifier and Type	Method and Description
protected RecordBatch.IterOutcome	UnnestRecordBatch.doWork()
RecordBatch.IterOutcome	UnnestRecordBatch.innerNext()

Uses of RecordBatch.IterOutcome in org.apache.drill.exec.physical.impl.unorderedreceiver

Methods in org.apache.drill.exec.physical.impl.unorderedreceiver that return RecordBatch.IterOutcome

Modifier and Type	Method and Description
RecordBatch.IterOutcome	UnorderedReceiverBatch.next()

Uses of RecordBatch.IterOutcome in org.apache.drill.exec.physical.impl.unpivot

Methods in org.apache.drill.exec.physical.impl.unpivot that return RecordBatch.IterOutcome

Modifier and Type	Method and Description
protected RecordBatch.IterOutcome	UnpivotMapsRecordBatch.doWork()
RecordBatch.IterOutcome	UnpivotMapsRecordBatch.innerNext()

Uses of RecordBatch.IterOutcome in org.apache.drill.exec.physical.impl.validate

Methods in org.apache.drill.exec.physical.impl.validate that return RecordBatch.IterOutcome

Modifier and Type	Method and Description
RecordBatch.IterOutcome	IteratorValidatorBatchIterator.next()

Uses of RecordBatch.IterOutcome in org.apache.drill.exec.physical.impl.window

Methods in org.apache.drill.exec.physical.impl.window that return RecordBatch.IterOutcome

Modifier and Type	Method and Description
RecordBatch.IterOutcome	WindowFrameRecordBatch.innerNext() Hold incoming batches in memory until all window functions are ready to process the batch on top of the queue

Uses of RecordBatch.IterOutcome in org.apache.drill.exec.physical.impl.xsort

Methods in org.apache.drill.exec.physical.impl.xsort that return RecordBatch.IterOutcome

Modifier and Type	Method and Description
RecordBatch.IterOutcome	ExternalSortBatch.innerNext() Process each request for a batch.

Methods in org.apache.drill.exec.physical.impl.xsort with parameters of type RecordBatch.IterOutcome

Modifier and Type	Method and Description
void	MergeSortWrapper.updateOutputContainer(VectorContainer container, SelectionVector4 sv4, RecordBatch.IterOutcome outcome, BatchSchema schema)
void	PriorityQueueCopierWrapper.BatchMerger.updateOutputContainer(VectorContainer container, SelectionVector4 sv4, RecordBatch.IterOutcome outcome, BatchSchema schema)
void	SortImpl.SortResults.updateOutputContainer(VectorContainer container, SelectionVector4 sv4, RecordBatch.IterOutcome outcome, BatchSchema schema)
void	SortImpl.EmptyResults.updateOutputContainer(VectorContainer container, SelectionVector4 sv4, RecordBatch.IterOutcome outcome, BatchSchema schema)
void	SortImpl.SingleBatchResults.updateOutputContainer(VectorContainer container, SelectionVector4 sv4, RecordBatch.IterOutcome outcome, BatchSchema schema)

Uses of RecordBatch.IterOutcome in org.apache.drill.exec.record

Fields in org.apache.drill.exec.record declared as RecordBatch.IterOutcome

Modifier and Type	Field and Description
protected RecordBatch.IterOutcome	AbstractBinaryRecordBatch.leftUpstream
protected RecordBatch.IterOutcome	AbstractBinaryRecordBatch.rightUpstream

Methods in org.apache.drill.exec.record that return RecordBatch.IterOutcome

Modifier and Type	Method and Description
protected abstract RecordBatch.IterOutcome	AbstractUnaryRecordBatch.doWork()
protected RecordBatch.IterOutcome	AbstractSingleRecordBatch.getFinalOutcome(boolean hasMoreRecordInBoundary) Based on lastKnownOutcome and if there are more records to be output for current record boundary detected by EMIT outcome, this method returns EMIT or OK outcome.
protected RecordBatch.IterOutcome	AbstractUnaryRecordBatch.getLastKnownOutcome()
RecordBatch.IterOutcome	RecordIterator.getLastOutcome()
protected RecordBatch.IterOutcome	AbstractUnaryRecordBatch.handleNullInput() Default behavior to handle NULL input (aka FAST NONE): incoming return NONE before return a OK_NEW_SCHEMA: This could happen when the underneath Scan operators do not produce any batch with schema.
RecordBatch.IterOutcome	AbstractUnaryRecordBatch.innerNext()
abstract RecordBatch.IterOutcome	AbstractRecordBatch.innerNext()
RecordBatch.IterOutcome	RecordBatch.next() Updates the data in each Field reading interface for the next range of records.
RecordBatch.IterOutcome	RecordIterator.next() Move iterator to next record.
RecordBatch.IterOutcome	SchemalessBatch.next()
RecordBatch.IterOutcome	SimpleRecordBatch.next()
RecordBatch.IterOutcome	AbstractRecordBatch.next()
RecordBatch.IterOutcome	AbstractRecordBatch.next(int inputIndex, RecordBatch b)
RecordBatch.IterOutcome	AbstractRecordBatch.next(RecordBatch b)
static RecordBatch.IterOutcome	RecordBatch.IterOutcome.valueOf(String name) Returns the enum constant of this type with the specified name.
static RecordBatch.IterOutcome[]	RecordBatch.IterOutcome.values() Returns an array containing the constants of this enum type, in the order they are declared.

Methods in org.apache.drill.exec.record with parameters of type RecordBatch.IterOutcome

Modifier and Type	Method and Description
protected boolean	AbstractBinaryRecordBatch.checkForEarlyFinish(RecordBatch.IterOutcome leftOutcome, RecordBatch.IterOutcome rightOutcome) Checks for the operator specific early terminal condition.
protected void	AbstractUnaryRecordBatch.setLastKnownOutcome(RecordBatch.IterOutcome outcome) Set's the outcome received with current input batch in processing
protected boolean	AbstractBinaryRecordBatch.verifyOutcomeToSetBatchState(RecordBatch.IterOutcome leftOutcome, RecordBatch.IterOutcome rightOutcome)