org.apache.drill.exec.record

Class AbstractSingleRecordBatch<T extends PhysicalOperator>

java.lang.Object

org.apache.drill.exec.record.AbstractRecordBatch<T>

org.apache.drill.exec.record.AbstractUnaryRecordBatch<T>

org.apache.drill.exec.record.AbstractSingleRecordBatch<T>

Type Parameters:

T - the plan definition of the operator

All Implemented Interfaces:

AutoCloseable, Iterable<VectorWrapper<?>>, CloseableRecordBatch, RecordBatch, VectorAccessible

Direct Known Subclasses:

FilterRecordBatch, FlattenRecordBatch, LimitRecordBatch, MetadataHandlerBatch, PartitionLimitRecordBatch, ProjectRecordBatch, RangePartitionRecordBatch, RemovingRecordBatch, RuntimeFilterRecordBatch, StatisticsMergeBatch, TraceRecordBatch, UnpivotMapsRecordBatch

public abstract class AbstractSingleRecordBatch<T extends PhysicalOperator>
extends AbstractUnaryRecordBatch<T>

Implements an AbstractUnaryRecordBatch where the incoming record batch is known at the time of creation

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.drill.exec.record.AbstractRecordBatch

AbstractRecordBatch.BatchState

Nested classes/interfaces inherited from interface org.apache.drill.exec.record.RecordBatch

RecordBatch.IterOutcome

Field Summary

Fields

Modifier and Type	Field and Description
protected RecordBatch	incoming

Fields inherited from class org.apache.drill.exec.record.AbstractUnaryRecordBatch

callBack

Fields inherited from class org.apache.drill.exec.record.AbstractRecordBatch

batchStatsContext, container, context, oContext, popConfig, state, stats, unionTypeEnabled

Fields inherited from interface org.apache.drill.exec.record.RecordBatch

MAX_BATCH_ROW_COUNT

Constructor Summary

Constructors

Constructor and Description
AbstractSingleRecordBatch(T popConfig, FragmentContext context, RecordBatch incoming)

Method Summary

Modifier and Type	Method and Description
protected RecordBatch.IterOutcome	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	getIncoming()

Methods inherited from class org.apache.drill.exec.record.AbstractUnaryRecordBatch

cancelIncoming, doWork, getLastKnownOutcome, handleNullInput, innerNext, setLastKnownOutcome, setupNewSchema

Methods inherited from class org.apache.drill.exec.record.AbstractRecordBatch

buildSchema, cancel, checkContinue, close, getContainer, getContext, getOutgoingContainer, getPopConfig, getRecordBatchStatsContext, getSchema, getSelectionVector2, getSelectionVector4, getValueAccessorById, getValueVectorId, getWritableBatch, isRecordBatchStatsLoggingEnabled, iterator, next, next, next, schemaChangeException, schemaChangeException

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.drill.exec.record.RecordBatch

dump

Methods inherited from interface org.apache.drill.exec.record.VectorAccessible

getRecordCount

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Field Detail

incoming

protected final RecordBatch incoming

Constructor Detail

AbstractSingleRecordBatch

public AbstractSingleRecordBatch(T popConfig,
                                 FragmentContext context,
                                 RecordBatch incoming)
                          throws OutOfMemoryException

Throws:

OutOfMemoryException

Method Detail

getIncoming

protected RecordBatch getIncoming()

Specified by:

getIncoming in class AbstractUnaryRecordBatch<T extends PhysicalOperator>

getFinalOutcome

protected RecordBatch.IterOutcome 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.

Parameters:

hasMoreRecordInBoundary -

Returns:

EMIT - If the lastknownOutcome was EMIT and output records corresponding to all the incoming records in current record boundary is already produced. OK - otherwise