public class TaskExecutorService extends org.apache.hadoop.service.AbstractService implements Scheduler<TaskRunnerCallable>
Modifier and Type | Class and Description |
---|---|
static class |
TaskExecutorService.PreemptionQueueComparator |
static class |
TaskExecutorService.TaskWrapper |
Scheduler.SubmissionState
Constructor and Description |
---|
TaskExecutorService(int numExecutors,
int waitQueueSize,
String waitQueueComparatorClassName,
boolean enablePreemption,
ClassLoader classLoader,
LlapDaemonExecutorMetrics metrics) |
Modifier and Type | Method and Description |
---|---|
QueryIdentifier |
findQueryByFragment(String fragmentId) |
Set<String> |
getExecutorsStatus() |
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)
public void serviceStop()
serviceStop
in class org.apache.hadoop.service.AbstractService
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 shutDown(boolean awaitTermination)
Copyright © 2016 The Apache Software Foundation. All rights reserved.