org.apache.drill.exec.physical.impl.metadata

Class MetadataStreamAggBatch

java.lang.Object

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

org.apache.drill.exec.physical.impl.aggregate.StreamingAggBatch

org.apache.drill.exec.physical.impl.metadata.MetadataStreamAggBatch

All Implemented Interfaces:

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

public class MetadataStreamAggBatch
extends StreamingAggBatch

Operator which adds aggregate calls for all incoming columns to calculate required metadata and produces aggregations. If aggregation is performed on top of another aggregation, required aggregate calls for merging metadata will be added.

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 inherited from class org.apache.drill.exec.physical.impl.aggregate.StreamingAggBatch

aggregator, incoming

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
MetadataStreamAggBatch(MetadataStreamAggPOP popConfig, RecordBatch incoming, FragmentContext context)

Method Summary

Modifier and Type	Method and Description
protected StreamingAggregator	createAggregatorInternal()
protected List<NamedExpression>	getValueExpressions()

Methods inherited from class org.apache.drill.exec.physical.impl.aggregate.StreamingAggBatch

addComplexWriter, addRecordValues, buildSchema, cancelIncoming, dump, getIndex, getKeyExpressions, getOutgoingContainer, getRecordCount, innerNext, outputRecordKeys, outputRecordKeysPrev, setMaxOutputRowCount, setupIsSame, setupIsSameApart

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

cancel, checkContinue, close, getContainer, getContext, 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

Constructor Detail

MetadataStreamAggBatch

public MetadataStreamAggBatch(MetadataStreamAggPOP popConfig,
                              RecordBatch incoming,
                              FragmentContext context)
                       throws OutOfMemoryException

Throws:

OutOfMemoryException

Method Detail

createAggregatorInternal

protected StreamingAggregator createAggregatorInternal()

Overrides:

createAggregatorInternal in class StreamingAggBatch

getValueExpressions

protected List<NamedExpression> getValueExpressions()

Overrides:

getValueExpressions in class StreamingAggBatch