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

Class IncomingBuffers

java.lang.Object

org.apache.drill.exec.work.batch.IncomingBuffers

All Implemented Interfaces:

AutoCloseable

public class IncomingBuffers
extends Object
implements AutoCloseable

Determines when a particular fragment has enough data for each of its receiving exchanges to commence execution. Also monitors whether we've collected all incoming data.

Constructor Summary

Constructors

Constructor	Description
IncomingBuffers(BitControl.PlanFragment fragment, FragmentContext context)

Method Summary

Modifier and Type	Method	Description
boolean	batchArrived(IncomingDataBatch incomingBatch)
void	close()
DataCollector	getCollector(int senderMajorFragmentId)
int	getRemainingRequired()
boolean	isDone()

Methods inherited from class java.lang.Object

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

Constructor Details

IncomingBuffers

public IncomingBuffers(BitControl.PlanFragment fragment,
 FragmentContext context)

Method Details

batchArrived

public boolean batchArrived(IncomingDataBatch incomingBatch)
                     throws FragmentSetupException,
IOException

Throws:

FragmentSetupException

IOException

getRemainingRequired

public int getRemainingRequired()

getCollector

public DataCollector getCollector(int senderMajorFragmentId)

isDone

public boolean isDone()

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception