org.apache.drill.exec.work.fragment

Class RootFragmentManager

java.lang.Object

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

org.apache.drill.exec.work.fragment.RootFragmentManager

All Implemented Interfaces:

FragmentManager

public class RootFragmentManager
extends AbstractFragmentManager

This managers determines when to run a 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
RootFragmentManager(BitControl.PlanFragment fragment, FragmentExecutor fragmentExecutor, FragmentStatusReporter statusReporter)

Method Summary

Modifier and Type	Method and Description
void	receivingFragmentFinished(ExecProtos.FragmentHandle handle)

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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

RootFragmentManager

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

Method Detail

receivingFragmentFinished

public void receivingFragmentFinished(ExecProtos.FragmentHandle handle)

Specified by:

receivingFragmentFinished in interface FragmentManager

Specified by:

receivingFragmentFinished in class AbstractFragmentManager