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

Interface DataCollector

All Superinterfaces:

AutoCloseable

All Known Implementing Classes:

AbstractDataCollector, MergingCollector, PartitionedCollector

public interface DataCollector
extends AutoCloseable

Field Summary

Fields

Modifier and Type	Field	Description
static final org.slf4j.Logger	logger

Method Summary

Modifier and Type	Method	Description
boolean	batchArrived(int minorFragmentId, RawFragmentBatch batch)
void	close()
BufferAllocator	getAllocator()
RawBatchBuffer[]	getBuffers()
int	getOppositeMajorFragmentId()
int	getTotalIncomingFragments()
void	setAllocator(BufferAllocator allocator)	Enables caller (e.g., receiver) to attach its buffer allocator to this Data Collector in order to claim ownership of incoming batches; by default, the fragment allocator owns these batches.

Field Details

logger

static final org.slf4j.Logger logger

Method Details

batchArrived

boolean batchArrived(int minorFragmentId,
 RawFragmentBatch batch)
              throws IOException

Throws:

IOException

getOppositeMajorFragmentId

int getOppositeMajorFragmentId()

getBuffers

RawBatchBuffer[] getBuffers()

getTotalIncomingFragments

int getTotalIncomingFragments()

close

void close()
    throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception

setAllocator

void setAllocator(BufferAllocator allocator)

Enables caller (e.g., receiver) to attach its buffer allocator to this Data Collector in order to claim ownership of incoming batches; by default, the fragment allocator owns these batches.

Parameters:

allocator - operator buffer allocator

getAllocator

BufferAllocator getAllocator()

Returns:

allocator