Package | Description |
---|---|
org.apache.tez.serviceplugins.api |
Modifier and Type | Method and Description |
---|---|
abstract void |
TaskScheduler.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)
A request to the source to allocate resources for a requesting task, based on a previously used
container
|
abstract void |
TaskScheduler.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)
A request to the source to allocate resources for a requesting task, with location information
optionally specified
|
abstract void |
TaskScheduler.blacklistNode(org.apache.hadoop.yarn.api.records.NodeId nodeId)
Indication to a source that a node has been blacklisted, and should not be used for subsequent
allocations.
|
abstract void |
TaskScheduler.dagComplete()
Indicates to the scheduler that the currently running dag has completed.
|
abstract Object |
TaskScheduler.deallocateContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId)
A request to de-allocate a previously allocated container.
|
abstract boolean |
TaskScheduler.deallocateTask(Object task,
boolean taskSucceeded,
TaskAttemptEndReason endReason,
String diagnostics)
A request to deallocate a task.
|
abstract org.apache.hadoop.yarn.api.records.Resource |
TaskScheduler.getAvailableResources()
Get the currently available resources from this source
|
abstract int |
TaskScheduler.getClusterNodeCount()
Get the number of nodes available from the source
|
abstract org.apache.hadoop.yarn.api.records.Resource |
TaskScheduler.getTotalResources()
Get the total available resources from this source
|
abstract boolean |
TaskScheduler.hasUnregistered()
Checks with the scheduler whether it has unregistered.
|
abstract void |
ContainerLauncher.launchContainer(ContainerLaunchRequest launchRequest)
Get the
ContainerLauncherContext associated with this instance of the container
launcher, which is used to communicate with the rest of the system |
abstract void |
TaskScheduler.setShouldUnregister()
Inform the scheduler that it should unregister.
|
abstract void |
ContainerLauncher.stopContainer(ContainerStopRequest stopRequest)
A request to stop a specific container
|
abstract void |
TaskScheduler.unblacklistNode(org.apache.hadoop.yarn.api.records.NodeId nodeId)
Indication to a source that a node has been un-blacklisted, and can be used from subsequent
allocations
|
Copyright © 2016 Apache Software Foundation. All rights reserved.