org.apache.drill.exec.work.foreman

Class FragmentsRunner

java.lang.Object

org.apache.drill.exec.work.foreman.FragmentsRunner

public class FragmentsRunner
extends Object

Is responsible for submitting query fragments for running (locally and remotely).

Constructor Summary

Constructors

Constructor and Description
FragmentsRunner(WorkManager.WorkerBee bee, UserClientConnection initiatingClient, DrillbitContext drillbitContext, Foreman foreman)

Method Summary

Modifier and Type	Method and Description
WorkManager.WorkerBee	getBee()
void	setFragmentsInfo(List<BitControl.PlanFragment> planFragments, BitControl.PlanFragment rootPlanFragment, FragmentRoot rootOperator)
void	submit() Submits root and non-root fragments fragments for running.

Methods inherited from class java.lang.Object

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

Constructor Detail

FragmentsRunner

public FragmentsRunner(WorkManager.WorkerBee bee,
                       UserClientConnection initiatingClient,
                       DrillbitContext drillbitContext,
                       Foreman foreman)

Method Detail

getBee

public WorkManager.WorkerBee getBee()

setFragmentsInfo

public void setFragmentsInfo(List<BitControl.PlanFragment> planFragments,
                             BitControl.PlanFragment rootPlanFragment,
                             FragmentRoot rootOperator)

submit

public void submit()
            throws ExecutionSetupException

Submits root and non-root fragments fragments for running. In case of success move query to the running state.

Throws:

ExecutionSetupException