Uses of Class
org.apache.drill.exec.record.RawFragmentBatch
Package
Description
-
Uses of RawFragmentBatch in org.apache.drill.exec.record
-
Uses of RawFragmentBatch in org.apache.drill.exec.rpc.data
Modifier and TypeMethodDescriptionIncomingDataBatch.newRawFragmentBatch
(BufferAllocator allocator) Create a new RawFragmentBatch based on this incoming data batch that is transferred into the provided allocator. -
Uses of RawFragmentBatch in org.apache.drill.exec.work.batch
Modifier and TypeMethodDescriptionBaseRawBatchBuffer.getNext()
BaseRawBatchBuffer.BufferQueue.poll()
BaseRawBatchBuffer.BufferQueue.take()
Modifier and TypeMethodDescriptionvoid
BaseRawBatchBuffer.BufferQueue.addOomBatch
(RawFragmentBatch batch) boolean
AbstractDataCollector.batchArrived
(int minorFragmentId, RawFragmentBatch batch) boolean
DataCollector.batchArrived
(int minorFragmentId, RawFragmentBatch batch) void
BaseRawBatchBuffer.enqueue
(RawFragmentBatch batch) void
RawBatchBuffer.enqueue
(RawFragmentBatch batch) Add the next new raw fragment batch to the buffer.protected abstract void
BaseRawBatchBuffer.enqueueInner
(RawFragmentBatch batch) implementation specific method to enqueue batchprotected void
SpoolingRawBatchBuffer.enqueueInner
(RawFragmentBatch batch) protected void
UnlimitedRawBatchBuffer.enqueueInner
(RawFragmentBatch batch) protected abstract void
BaseRawBatchBuffer.upkeep
(RawFragmentBatch batch) Handle miscellaneous tasks after batch retrievalprotected void
SpoolingRawBatchBuffer.upkeep
(RawFragmentBatch batch) protected void
UnlimitedRawBatchBuffer.upkeep
(RawFragmentBatch batch)