Package 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	Description
protected final 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	Description
AbstractSingleRecordBatch(T popConfig, FragmentContext context, RecordBatch incoming)

Method Summary

Modifier and Type	Method	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 java.lang.Iterable

forEach, spliterator

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

dump

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

getRecordCount

Field Details

incoming

protected final RecordBatch incoming

Constructor Details

AbstractSingleRecordBatch

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

Throws:

OutOfMemoryException

Method Details

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