org.apache.drill.exec.physical.impl

Interface RootExec

All Superinterfaces:

AutoCloseable

All Known Implementing Classes:

BaseRootExec, BroadcastSenderRootExec, PartitionSenderRootExec, ScreenCreator.ScreenRoot, SingleSenderCreator.SingleSenderRootExec

public interface RootExec
extends AutoCloseable

Node which is the last processing node in a query plan. FragmentTerminals include Exchange output nodes and storage nodes. They are there driving force behind the completion of a query.

Assumes that all implementations of RootExec assume that all their methods are called by the same thread.

Method Summary

Modifier and Type	Method and Description
void	dumpBatches(Throwable t) Dump failed batches' state preceded by its parent's state to logs.
boolean	next() Do the next batch of work.
void	receivingFragmentFinished(ExecProtos.FragmentHandle handle) Inform sender that receiving fragment is finished and doesn't need any more data.

Methods inherited from interface java.lang.AutoCloseable

close

Method Detail

next

boolean next()

Do the next batch of work.

Returns:

Whether or not additional batches of work are necessary. False means that this fragment is done.

receivingFragmentFinished

void receivingFragmentFinished(ExecProtos.FragmentHandle handle)

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 next() will return false.

Parameters:

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

dumpBatches

void dumpBatches(Throwable t)

Dump failed batches' state preceded by its parent's state to logs. Invoked when there is a failure during fragment execution.

Parameters:

t - the exception thrown by an operator and which therefore records, in its stack trace, which operators were active on the stack