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

Interface BaseRawBatchBuffer.BufferQueue<T>

Enclosing class:

BaseRawBatchBuffer<T>

protected static interface BaseRawBatchBuffer.BufferQueue<T>

Method Summary

Modifier and Type	Method	Description
void	add(T obj)
void	addOomBatch(RawFragmentBatch batch)
boolean	checkForOutOfMemory()
boolean	isEmpty()
RawFragmentBatch	poll()
RawFragmentBatch	poll(long timeout, TimeUnit timeUnit)
int	size()
RawFragmentBatch	take()

Method Details

addOomBatch

void addOomBatch(RawFragmentBatch batch)

poll

RawFragmentBatch poll()
               throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

take

RawFragmentBatch take()
               throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

poll

RawFragmentBatch poll(long timeout,
 TimeUnit timeUnit)
               throws InterruptedException,
IOException

Throws:

InterruptedException

IOException

checkForOutOfMemory

boolean checkForOutOfMemory()

size

int size()

isEmpty

boolean isEmpty()

add

void add(T obj)