Package 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	Description
FragmentsRunner(WorkManager.WorkerBee bee, UserClientConnection initiatingClient, DrillbitContext drillbitContext, Foreman foreman)

Method Summary

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

FragmentsRunner

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

Method Details

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