Package 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	Description
NonRootFragmentManager(BitControl.PlanFragment fragment, FragmentExecutor fragmentExecutor, FragmentStatusReporter statusReporter)

Method Summary

Modifier and Type	Method	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 Details

NonRootFragmentManager

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

Method Details

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