Class StreamingAggBatch
java.lang.Object
org.apache.drill.exec.record.AbstractRecordBatch<StreamingAggregate>
org.apache.drill.exec.physical.impl.aggregate.StreamingAggBatch
- All Implemented Interfaces:
AutoCloseable
,Iterable<VectorWrapper<?>>
,CloseableRecordBatch
,RecordBatch
,VectorAccessible
- Direct Known Subclasses:
MetadataStreamAggBatch
,StatisticsAggBatch
-
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.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
ConstructorDescriptionStreamingAggBatch
(StreamingAggregate popConfig, RecordBatch incoming, FragmentContext context) -
Method Summary
Modifier and TypeMethodDescriptionvoid
protected void
addRecordValues
(ClassGenerator<StreamingAggregator> cg, LogicalExpression[] valueExprs) void
protected void
protected StreamingAggregator
void
dump()
Perform dump of this batch's state to logs.protected void
protected List<NamedExpression>
int
Get the number of records.protected List<NamedExpression>
protected void
outputRecordKeys
(ClassGenerator<StreamingAggregator> cg, TypedFieldId[] keyOutputIds, LogicalExpression[] keyExprs) protected void
outputRecordKeysPrev
(ClassGenerator<StreamingAggregator> cg, TypedFieldId[] keyOutputIds, LogicalExpression[] keyExprs) void
setMaxOutputRowCount
(int maxOutputRowCount) protected void
setupIsSame
(ClassGenerator<StreamingAggregator> cg, LogicalExpression[] keyExprs) protected void
setupIsSameApart
(ClassGenerator<StreamingAggregator> cg, LogicalExpression[] keyExprs) 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
-
Field Details
-
aggregator
-
incoming
-
-
Constructor Details
-
StreamingAggBatch
public StreamingAggBatch(StreamingAggregate popConfig, RecordBatch incoming, FragmentContext context) throws OutOfMemoryException - Throws:
OutOfMemoryException
-
-
Method Details
-
getRecordCount
public int getRecordCount()Description copied from interface:VectorAccessible
Get the number of records.- Returns:
- number of records
-
getOutgoingContainer
- Specified by:
getOutgoingContainer
in interfaceRecordBatch
- Overrides:
getOutgoingContainer
in classAbstractRecordBatch<StreamingAggregate>
-
buildSchema
public void buildSchema()- Overrides:
buildSchema
in classAbstractRecordBatch<StreamingAggregate>
-
innerNext
- Specified by:
innerNext
in classAbstractRecordBatch<StreamingAggregate>
-
addComplexWriter
-
createAggregatorInternal
-
getValueExpressions
-
getKeyExpressions
-
setupIsSame
-
setupIsSameApart
protected void setupIsSameApart(ClassGenerator<StreamingAggregator> cg, LogicalExpression[] keyExprs) -
addRecordValues
protected void addRecordValues(ClassGenerator<StreamingAggregator> cg, LogicalExpression[] valueExprs) -
outputRecordKeys
protected void outputRecordKeys(ClassGenerator<StreamingAggregator> cg, TypedFieldId[] keyOutputIds, LogicalExpression[] keyExprs) -
outputRecordKeysPrev
protected void outputRecordKeysPrev(ClassGenerator<StreamingAggregator> cg, TypedFieldId[] keyOutputIds, LogicalExpression[] keyExprs) -
getIndex
-
cancelIncoming
protected void cancelIncoming()- Specified by:
cancelIncoming
in classAbstractRecordBatch<StreamingAggregate>
-
dump
public void dump()Description copied from interface:RecordBatch
Perform dump of this batch's state to logs. -
setMaxOutputRowCount
public void setMaxOutputRowCount(int maxOutputRowCount)
-