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

Class MetadataHashAggBatch

java.lang.Object

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

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

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

All Implemented Interfaces:

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

public class MetadataHashAggBatch
extends HashAggBatch

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.HashAggBatch

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	Description
MetadataHashAggBatch(MetadataHashAggPOP popConfig, RecordBatch incoming, FragmentContext context)

Method Summary

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

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

addComplexWriter, buildSchema, cancelIncoming, close, dump, getKeyExpressions, getOutgoingContainer, getOutputRowCount, getRecordBatchMemoryManager, getRecordCount, innerNext

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

cancel, checkContinue, 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 Details

MetadataHashAggBatch

public MetadataHashAggBatch(MetadataHashAggPOP popConfig,
 RecordBatch incoming,
 FragmentContext context)

Method Details

createAggregatorInternal

protected HashAggregator createAggregatorInternal()

Overrides:

createAggregatorInternal in class HashAggBatch

getValueExpressions

protected List<NamedExpression> getValueExpressions()

Overrides:

getValueExpressions in class HashAggBatch