public class TaskExecutorService extends org.apache.hadoop.service.AbstractService implements Scheduler<TaskRunnerCallable>, SchedulerFragmentCompletingListener
Modifier and Type | Class and Description |
---|---|
static class |
TaskExecutorService.PreemptionQueueComparator |
static class |
TaskExecutorService.TaskWrapper |
Scheduler.SubmissionState
SchedulerFragmentCompletingListener.State
Constructor and Description |
---|
TaskExecutorService(int numExecutors,
int waitQueueSize,
String waitQueueComparatorClassName,
boolean enablePreemption,
ClassLoader classLoader,
LlapDaemonExecutorMetrics metrics,
org.apache.hadoop.yarn.util.Clock clock) |
Modifier and Type | Method and Description |
---|---|
QueryIdentifier |
findQueryByFragment(String fragmentId) |
void |
fragmentCompleting(String fragmentId,
SchedulerFragmentCompletingListener.State state)
Indicates that a fragment is about to complete.
|
Set<String> |
getExecutorsStatus() |
int |
getNumActive() |
void |
killFragment(String fragmentId)
Attempt to kill the fragment with the specified fragmentId
|
Scheduler.SubmissionState |
schedule(TaskRunnerCallable task)
Schedule the task or throw RejectedExecutionException if queues are full
|
void |
serviceStop() |
void |
shutDown(boolean awaitTermination) |
close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, serviceInit, serviceStart, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop
public TaskExecutorService(int numExecutors, int waitQueueSize, String waitQueueComparatorClassName, boolean enablePreemption, ClassLoader classLoader, LlapDaemonExecutorMetrics metrics, org.apache.hadoop.yarn.util.Clock clock)
public void serviceStop()
serviceStop
in class org.apache.hadoop.service.AbstractService
public int getNumActive()
getNumActive
in interface Scheduler<TaskRunnerCallable>
public Set<String> getExecutorsStatus()
getExecutorsStatus
in interface Scheduler<TaskRunnerCallable>
public Scheduler.SubmissionState schedule(TaskRunnerCallable task)
Scheduler
schedule
in interface Scheduler<TaskRunnerCallable>
task
- - task to schedulepublic QueryIdentifier findQueryByFragment(String fragmentId)
findQueryByFragment
in interface Scheduler<TaskRunnerCallable>
public void killFragment(String fragmentId)
Scheduler
killFragment
in interface Scheduler<TaskRunnerCallable>
public void fragmentCompleting(String fragmentId, SchedulerFragmentCompletingListener.State state)
SchedulerFragmentCompletingListener
fragmentCompleting
in interface SchedulerFragmentCompletingListener
public void shutDown(boolean awaitTermination)
Copyright © 2021 The Apache Software Foundation. All rights reserved.