org.apache.drill.exec.work.fragment

Class NonRootFragmentManager

java.lang.Object

org.apache.drill.exec.work.fragment.AbstractFragmentManager

org.apache.drill.exec.work.fragment.NonRootFragmentManager

All Implemented Interfaces:

FragmentManager

public class NonRootFragmentManager
extends AbstractFragmentManager

This managers determines when to run a non-root fragment node.

Field Summary

Fields inherited from class org.apache.drill.exec.work.fragment.AbstractFragmentManager

buffers, cancel, fragmentContext, fragmentExecutor, fragmentHandle

Constructor Summary

Constructors

Constructor and Description
NonRootFragmentManager(BitControl.PlanFragment fragment, FragmentExecutor fragmentExecutor, FragmentStatusReporter statusReporter)

Method Summary

Modifier and Type	Method and Description
FragmentExecutor	getRunnable() Get the fragment runner for this incoming fragment.
void	receivingFragmentFinished(ExecProtos.FragmentHandle handle)

Methods inherited from class org.apache.drill.exec.work.fragment.AbstractFragmentManager

cancel, getFragmentContext, getHandle, handle, isCancelled, isWaiting, unpause

Methods inherited from class java.lang.Object

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

Constructor Detail

NonRootFragmentManager

public NonRootFragmentManager(BitControl.PlanFragment fragment,
                              FragmentExecutor fragmentExecutor,
                              FragmentStatusReporter statusReporter)

Method Detail

getRunnable

public FragmentExecutor getRunnable()

Description copied from interface: FragmentManager

Get the fragment runner for this incoming fragment. Note, this can only be requested once.

Specified by:

getRunnable in interface FragmentManager

Overrides:

getRunnable in class AbstractFragmentManager

Returns:

receivingFragmentFinished

public void receivingFragmentFinished(ExecProtos.FragmentHandle handle)

Specified by:

receivingFragmentFinished in interface FragmentManager

Specified by:

receivingFragmentFinished in class AbstractFragmentManager