Package 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	Description
PartitionedCollector(AtomicInteger parentAccounter, BitControl.Collector collector, FragmentContext context)

Method Summary

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

PartitionedCollector

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

Method Details

getBuffer

protected RawBatchBuffer getBuffer(int minorFragmentId)

Specified by:

getBuffer in class AbstractDataCollector