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

Class UnlimitedRawBatchBuffer

java.lang.Object

org.apache.drill.exec.work.batch.BaseRawBatchBuffer<RawFragmentBatch>

org.apache.drill.exec.work.batch.UnlimitedRawBatchBuffer

All Implemented Interfaces:

AutoCloseable, RawFragmentBatchProvider, RawBatchBuffer

public class UnlimitedRawBatchBuffer
extends BaseRawBatchBuffer<RawFragmentBatch>

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.drill.exec.work.batch.BaseRawBatchBuffer

BaseRawBatchBuffer.BufferQueue<T>

Field Summary

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

bufferQueue, bufferSizePerSocket, context, enableDynamicFC, outOfMemory

Constructor Summary

Constructors

Constructor	Description
UnlimitedRawBatchBuffer(FragmentContext context, int fragmentCount, boolean enableDynamicFC)

Method Summary

Modifier and Type	Method	Description
protected void	enqueueInner(RawFragmentBatch batch)	implementation specific method to enqueue batch
protected void	upkeep(RawFragmentBatch batch)	Handle miscellaneous tasks after batch retrieval

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

close, enqueue, getFragmentCount, getNext, isTerminated, kill

Methods inherited from class java.lang.Object

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

Constructor Details

UnlimitedRawBatchBuffer

public UnlimitedRawBatchBuffer(FragmentContext context,
 int fragmentCount,
 boolean enableDynamicFC)

Method Details

enqueueInner

protected void enqueueInner(RawFragmentBatch batch)
                     throws IOException

Description copied from class: BaseRawBatchBuffer

implementation specific method to enqueue batch

Specified by:

enqueueInner in class BaseRawBatchBuffer<RawFragmentBatch>

Throws:

IOException

upkeep

protected void upkeep(RawFragmentBatch batch)

Description copied from class: BaseRawBatchBuffer

Handle miscellaneous tasks after batch retrieval

Specified by:

upkeep in class BaseRawBatchBuffer<RawFragmentBatch>