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 and Description
StreamingAggBatchCreator()

Method Summary

Modifier and Type	Method and 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 Detail

StreamingAggBatchCreator

public StreamingAggBatchCreator()

Method Detail

getBatch

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

Specified by:

getBatch in interface BatchCreator<StreamingAggregate>

Throws:

ExecutionSetupException