Package org.apache.drill.exec.work.batch

Class MergingCollector

java.lang.Object

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

org.apache.drill.exec.work.batch.MergingCollector

All Implemented Interfaces:

AutoCloseable, DataCollector

public class MergingCollector
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
MergingCollector(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

MergingCollector

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

Method Details

getBuffer

protected RawBatchBuffer getBuffer(int minorFragmentId)

Specified by:

getBuffer in class AbstractDataCollector