Package org.apache.drill.exec.physical.impl.partitionsender

Class PartitionSenderRootExec

java.lang.Object

org.apache.drill.exec.physical.impl.BaseRootExec

org.apache.drill.exec.physical.impl.partitionsender.PartitionSenderRootExec

All Implemented Interfaces:

AutoCloseable, RootExec

public class PartitionSenderRootExec
extends BaseRootExec

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	PartitionSenderRootExec.Metric

Field Summary

Fields

Modifier and Type	Field	Description
protected final int	actualPartitions
protected final int	numberPartitions

Fields inherited from class org.apache.drill.exec.physical.impl.BaseRootExec

ENABLE_BATCH_DUMP_CONFIG, fragmentContext, oContext, stats

Constructor Summary

Constructors

Constructor	Description
PartitionSenderRootExec(RootFragmentContext context, RecordBatch incoming, HashPartitionSender operator)
PartitionSenderRootExec(RootFragmentContext context, RecordBatch incoming, HashPartitionSender operator, boolean closeIncoming)

Method Summary

Modifier and Type	Method	Description
void	close()
protected void	createPartitioner()
protected PartitionerDecorator	getPartitioner()
boolean	innerNext()
void	receivingFragmentFinished(ExecProtos.FragmentHandle handle)	Inform sender that receiving fragment is finished and doesn't need any more data.

Methods inherited from class org.apache.drill.exec.physical.impl.BaseRootExec

dumpBatches, findLeaf, next, next

Methods inherited from class java.lang.Object

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

Field Details

numberPartitions

protected final int numberPartitions

actualPartitions

protected final int actualPartitions

Constructor Details

PartitionSenderRootExec

public PartitionSenderRootExec(RootFragmentContext context,
 RecordBatch incoming,
 HashPartitionSender operator)
                        throws OutOfMemoryException

Throws:

OutOfMemoryException

PartitionSenderRootExec

public PartitionSenderRootExec(RootFragmentContext context,
 RecordBatch incoming,
 HashPartitionSender operator,
 boolean closeIncoming)
                        throws OutOfMemoryException

Throws:

OutOfMemoryException

Method Details

innerNext

public boolean innerNext()

Specified by:

innerNext in class BaseRootExec

createPartitioner

protected void createPartitioner()

receivingFragmentFinished

public void receivingFragmentFinished(ExecProtos.FragmentHandle handle)

Description copied from interface: RootExec

Inform sender that receiving fragment is finished and doesn't need any more data. This can be called multiple times (once for each downstream receiver). If all receivers are finished then a subsequent call to RootExec.next() will return false.

Specified by:

receivingFragmentFinished in interface RootExec

Overrides:

receivingFragmentFinished in class BaseRootExec

Parameters:

handle - The handle pointing to the downstream receiver that does not need anymore data.

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Overrides:

close in class BaseRootExec

Throws:

Exception

getPartitioner

protected PartitionerDecorator getPartitioner()