org.apache.drill.exec.work.batch

Class PartitionedCollector

java.lang.Object

org.apache.drill.exec.work.batch.AbstractDataCollector

org.apache.drill.exec.work.batch.PartitionedCollector

All Implemented Interfaces:

AutoCloseable, DataCollector

public class PartitionedCollector
extends AbstractDataCollector

Field Summary

Fields inherited from class org.apache.drill.exec.work.batch.AbstractDataCollector

buffers, fragmentMap, ownerAllocator

Fields inherited from interface org.apache.drill.exec.work.batch.DataCollector

logger

Constructor Summary

Constructors

Constructor and Description
PartitionedCollector(AtomicInteger parentAccounter, BitControl.Collector collector, FragmentContext context)

Method Summary

Modifier and Type	Method and Description
protected RawBatchBuffer	getBuffer(int minorFragmentId)

Methods inherited from class org.apache.drill.exec.work.batch.AbstractDataCollector

batchArrived, close, getAllocator, getBuffers, getOppositeMajorFragmentId, getTotalIncomingFragments, setAllocator

Methods inherited from class java.lang.Object

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

Constructor Detail

PartitionedCollector

public PartitionedCollector(AtomicInteger parentAccounter,
                            BitControl.Collector collector,
                            FragmentContext context)

Method Detail

getBuffer

protected RawBatchBuffer getBuffer(int minorFragmentId)

Specified by:

getBuffer in class AbstractDataCollector