Uses of Class
org.apache.drill.exec.record.RawFragmentBatch

Packages that use RawFragmentBatch

Package	Description
org.apache.drill.exec.record
org.apache.drill.exec.rpc.data
org.apache.drill.exec.work.batch

Uses of RawFragmentBatch in org.apache.drill.exec.record

Methods in org.apache.drill.exec.record that return RawFragmentBatch

Modifier and Type	Method	Description
RawFragmentBatch	RawFragmentBatchProvider.getNext()

Uses of RawFragmentBatch in org.apache.drill.exec.rpc.data

Methods in org.apache.drill.exec.rpc.data that return RawFragmentBatch

Modifier and Type	Method	Description
RawFragmentBatch	IncomingDataBatch.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

Methods in org.apache.drill.exec.work.batch that return RawFragmentBatch

Modifier and Type	Method	Description
RawFragmentBatch	BaseRawBatchBuffer.getNext()
RawFragmentBatch	BaseRawBatchBuffer.BufferQueue.poll()
RawFragmentBatch	BaseRawBatchBuffer.BufferQueue.poll(long timeout, TimeUnit timeUnit)
RawFragmentBatch	BaseRawBatchBuffer.BufferQueue.take()

Methods in org.apache.drill.exec.work.batch with parameters of type RawFragmentBatch

Modifier and Type	Method	Description
void	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 batch
protected void	SpoolingRawBatchBuffer.enqueueInner(RawFragmentBatch batch)
protected void	UnlimitedRawBatchBuffer.enqueueInner(RawFragmentBatch batch)
protected abstract void	BaseRawBatchBuffer.upkeep(RawFragmentBatch batch)	Handle miscellaneous tasks after batch retrieval
protected void	SpoolingRawBatchBuffer.upkeep(RawFragmentBatch batch)
protected void	UnlimitedRawBatchBuffer.upkeep(RawFragmentBatch batch)