| Package | Description |
|---|---|
| org.apache.drill.exec.rpc.data | |
| org.apache.drill.exec.work | |
| org.apache.drill.exec.work.fragment |
| Modifier and Type | Method and Description |
|---|---|
FragmentExecutor |
TestBitRpc.MockFragmentManager.getRunnable() |
FragmentExecutor |
TestBitRpc.MockFragmentManagerWithDynamicCredit.getRunnable() |
FragmentExecutor |
TestBitBitKerberos.MockFragmentManager.getRunnable() |
| Modifier and Type | Method and Description |
|---|---|
FragmentExecutor |
WorkManager.WorkerBee.getFragmentRunner(ExecProtos.FragmentHandle handle) |
| Modifier and Type | Method and Description |
|---|---|
void |
WorkManager.WorkerBee.addFragmentRunner(FragmentExecutor fragmentExecutor)
Currently used to start a root fragment that is not blocked on data, and leaf fragments.
|
| Modifier and Type | Field and Description |
|---|---|
protected FragmentExecutor |
AbstractFragmentManager.fragmentExecutor |
| Modifier and Type | Method and Description |
|---|---|
FragmentExecutor |
FragmentManager.getRunnable()
Get the fragment runner for this incoming fragment.
|
FragmentExecutor |
NonRootFragmentManager.getRunnable() |
FragmentExecutor |
AbstractFragmentManager.getRunnable() |
| Constructor and Description |
|---|
AbstractFragmentManager(BitControl.PlanFragment fragment,
FragmentExecutor executor,
FragmentStatusReporter statusReporter) |
AbstractFragmentManager(BitControl.PlanFragment fragment,
FragmentExecutor executor,
FragmentStatusReporter statusReporter,
FragmentRoot rootOperator) |
NonRootFragmentManager(BitControl.PlanFragment fragment,
FragmentExecutor fragmentExecutor,
FragmentStatusReporter statusReporter) |
RootFragmentManager(BitControl.PlanFragment fragment,
FragmentExecutor fragmentExecutor,
FragmentStatusReporter statusReporter) |
Copyright © 2021 The Apache Software Foundation. All rights reserved.