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

Class StreamingAggBatchCreator

java.lang.Object

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

All Implemented Interfaces:

BatchCreator<StreamingAggregate>

public class StreamingAggBatchCreator
extends Object
implements BatchCreator<StreamingAggregate>

Constructor Summary

Constructors

Constructor	Description
StreamingAggBatchCreator()

Method Summary

Modifier and Type	Method	Description
StreamingAggBatch	getBatch(ExecutorFragmentContext context, StreamingAggregate config, List<RecordBatch> children)

Methods inherited from class java.lang.Object

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

Constructor Details

StreamingAggBatchCreator

public StreamingAggBatchCreator()

Method Details

getBatch

public StreamingAggBatch getBatch(ExecutorFragmentContext context,
 StreamingAggregate config,
 List<RecordBatch> children)
                           throws ExecutionSetupException

Specified by:

getBatch in interface BatchCreator<StreamingAggregate>

Throws:

ExecutionSetupException