public class LlapTaskSchedulerService
extends org.apache.tez.serviceplugins.api.TaskScheduler
Constructor and Description |
---|
LlapTaskSchedulerService(org.apache.tez.serviceplugins.api.TaskSchedulerContext taskSchedulerContext) |
LlapTaskSchedulerService(org.apache.tez.serviceplugins.api.TaskSchedulerContext taskSchedulerContext,
org.apache.hadoop.yarn.util.Clock clock,
boolean initMetrics) |
Modifier and Type | Method and Description |
---|---|
void |
allocateTask(Object task,
org.apache.hadoop.yarn.api.records.Resource capability,
org.apache.hadoop.yarn.api.records.ContainerId containerId,
org.apache.hadoop.yarn.api.records.Priority priority,
Object containerSignature,
Object clientCookie) |
void |
allocateTask(Object task,
org.apache.hadoop.yarn.api.records.Resource capability,
String[] hosts,
String[] racks,
org.apache.hadoop.yarn.api.records.Priority priority,
Object containerSignature,
Object clientCookie) |
void |
blacklistNode(org.apache.hadoop.yarn.api.records.NodeId nodeId) |
void |
dagComplete() |
Object |
deallocateContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId) |
boolean |
deallocateTask(Object task,
boolean taskSucceeded,
org.apache.tez.serviceplugins.api.TaskAttemptEndReason endReason,
String diagnostics) |
org.apache.hadoop.yarn.api.records.Resource |
getAvailableResources()
The difference between this and getTotalResources() is that this only gives currently free
resource instances, while the other lists all the instances that may become available in a
while.
|
int |
getClusterNodeCount() |
org.apache.hadoop.yarn.api.records.Resource |
getTotalResources() |
boolean |
hasUnregistered() |
void |
initialize() |
protected void |
schedulePendingTasks() |
void |
setServiceInstanceSet(ServiceInstanceSet serviceInstanceSet) |
void |
setShouldUnregister() |
void |
shutdown() |
void |
start() |
void |
unblacklistNode(org.apache.hadoop.yarn.api.records.NodeId nodeId) |
public LlapTaskSchedulerService(org.apache.tez.serviceplugins.api.TaskSchedulerContext taskSchedulerContext)
public LlapTaskSchedulerService(org.apache.tez.serviceplugins.api.TaskSchedulerContext taskSchedulerContext, org.apache.hadoop.yarn.util.Clock clock, boolean initMetrics)
public void initialize()
initialize
in interface org.apache.tez.common.ServicePluginLifecycle
initialize
in class org.apache.tez.serviceplugins.api.TaskScheduler
public void start() throws IOException
start
in interface org.apache.tez.common.ServicePluginLifecycle
start
in class org.apache.tez.serviceplugins.api.TaskScheduler
IOException
public void setServiceInstanceSet(ServiceInstanceSet serviceInstanceSet)
public void shutdown()
shutdown
in interface org.apache.tez.common.ServicePluginLifecycle
shutdown
in class org.apache.tez.serviceplugins.api.TaskScheduler
public org.apache.hadoop.yarn.api.records.Resource getTotalResources()
getTotalResources
in class org.apache.tez.serviceplugins.api.TaskScheduler
public org.apache.hadoop.yarn.api.records.Resource getAvailableResources()
getAvailableResources
in class org.apache.tez.serviceplugins.api.TaskScheduler
public int getClusterNodeCount()
getClusterNodeCount
in class org.apache.tez.serviceplugins.api.TaskScheduler
public void dagComplete()
dagComplete
in class org.apache.tez.serviceplugins.api.TaskScheduler
public void blacklistNode(org.apache.hadoop.yarn.api.records.NodeId nodeId)
blacklistNode
in class org.apache.tez.serviceplugins.api.TaskScheduler
public void unblacklistNode(org.apache.hadoop.yarn.api.records.NodeId nodeId)
unblacklistNode
in class org.apache.tez.serviceplugins.api.TaskScheduler
public void allocateTask(Object task, org.apache.hadoop.yarn.api.records.Resource capability, String[] hosts, String[] racks, org.apache.hadoop.yarn.api.records.Priority priority, Object containerSignature, Object clientCookie)
allocateTask
in class org.apache.tez.serviceplugins.api.TaskScheduler
public void allocateTask(Object task, org.apache.hadoop.yarn.api.records.Resource capability, org.apache.hadoop.yarn.api.records.ContainerId containerId, org.apache.hadoop.yarn.api.records.Priority priority, Object containerSignature, Object clientCookie)
allocateTask
in class org.apache.tez.serviceplugins.api.TaskScheduler
public boolean deallocateTask(Object task, boolean taskSucceeded, org.apache.tez.serviceplugins.api.TaskAttemptEndReason endReason, String diagnostics)
deallocateTask
in class org.apache.tez.serviceplugins.api.TaskScheduler
public Object deallocateContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId)
deallocateContainer
in class org.apache.tez.serviceplugins.api.TaskScheduler
public void setShouldUnregister()
setShouldUnregister
in class org.apache.tez.serviceplugins.api.TaskScheduler
public boolean hasUnregistered()
hasUnregistered
in class org.apache.tez.serviceplugins.api.TaskScheduler
protected void schedulePendingTasks()
Copyright © 2021 The Apache Software Foundation. All rights reserved.