org.apache.drill.exec.physical.impl

Class SingleSenderCreator.SingleSenderRootExec

java.lang.Object

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

org.apache.drill.exec.physical.impl.SingleSenderCreator.SingleSenderRootExec

All Implemented Interfaces:

AutoCloseable, RootExec

Enclosing class:

SingleSenderCreator

public static class SingleSenderCreator.SingleSenderRootExec
extends BaseRootExec

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SingleSenderCreator.SingleSenderRootExec.Metric

Field Summary

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

ENABLE_BATCH_DUMP_CONFIG, fragmentContext, oContext, stats

Constructor Summary

Constructors

Constructor and Description
SingleSenderRootExec(RootFragmentContext context, RecordBatch batch, SingleSender config)

Method Summary

Modifier and Type	Method and Description
boolean	innerNext()
void	receivingFragmentFinished(ExecProtos.FragmentHandle handle) Inform sender that receiving fragment is finished and doesn't need any more data.
void	updateStats(FragmentWritableBatch writableBatch)

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

close, dumpBatches, findLeaf, next, next

Methods inherited from class java.lang.Object

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

Constructor Detail

SingleSenderRootExec

public SingleSenderRootExec(RootFragmentContext context,
                            RecordBatch batch,
                            SingleSender config)
                     throws OutOfMemoryException

Throws:

OutOfMemoryException

Method Detail

innerNext

public boolean innerNext()

Specified by:

innerNext in class BaseRootExec

updateStats

public void updateStats(FragmentWritableBatch writableBatch)

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.