Modifier and Type | Method and Description |
---|---|
TaskAttemptEvent |
RMContainerAllocator.createContainerFinishedEvent(ContainerStatus cont,
TaskAttemptId attemptID) |
Modifier and Type | Method and Description |
---|---|
abstract List<ContainerStatus> |
AllocateResponse.getCompletedContainersStatuses()
Get the list of completed containers' statuses.
|
abstract List<ContainerStatus> |
GetContainerStatusesResponse.getContainerStatuses()
Get the
ContainerStatus es of the requested containers. |
Modifier and Type | Method and Description |
---|---|
static AllocateResponse |
AllocateResponse.newInstance(int responseId,
List<ContainerStatus> completedContainers,
List<Container> allocatedContainers,
List<NodeReport> updatedNodes,
Resource availResources,
AMCommand command,
int numClusterNodes,
PreemptionMessage preempt,
List<NMToken> nmTokens) |
static GetContainerStatusesResponse |
GetContainerStatusesResponse.newInstance(List<ContainerStatus> statuses,
Map<ContainerId,SerializedException> failedRequests) |
abstract void |
AllocateResponse.setCompletedContainersStatuses(List<ContainerStatus> containers) |
abstract void |
GetContainerStatusesResponse.setContainerStatuses(List<ContainerStatus> statuses)
Set the
ContainerStatus es of the requested containers. |
Modifier and Type | Method and Description |
---|---|
List<ContainerStatus> |
AllocateResponsePBImpl.getCompletedContainersStatuses() |
List<ContainerStatus> |
GetContainerStatusesResponsePBImpl.getContainerStatuses() |
Modifier and Type | Method and Description |
---|---|
void |
AllocateResponsePBImpl.setCompletedContainersStatuses(List<ContainerStatus> containers) |
void |
GetContainerStatusesResponsePBImpl.setContainerStatuses(List<ContainerStatus> statuses) |
Modifier and Type | Method and Description |
---|---|
static ContainerStatus |
ContainerStatus.newInstance(ContainerId containerId,
ContainerState containerState,
String diagnostics,
int exitStatus) |
Modifier and Type | Class and Description |
---|---|
class |
ContainerStatusPBImpl |
Modifier and Type | Method and Description |
---|---|
abstract ContainerStatus |
NMClient.getContainerStatus(ContainerId containerId,
NodeId nodeId)
Query the status of a container.
|
Modifier and Type | Method and Description |
---|---|
void |
NMClientAsync.CallbackHandler.onContainerStatusReceived(ContainerId containerId,
ContainerStatus containerStatus)
The API is called when
NodeManager responds with the status
of the container |
Modifier and Type | Method and Description |
---|---|
void |
AMRMClientAsync.CallbackHandler.onContainersCompleted(List<ContainerStatus> statuses)
Called when the ResourceManager responds to a heartbeat with completed
containers.
|
Modifier and Type | Method and Description |
---|---|
ContainerStatus |
NMClientImpl.getContainerStatus(ContainerId containerId,
NodeId nodeId) |
Modifier and Type | Method and Description |
---|---|
List<ContainerStatus> |
NodeStatus.getContainersStatuses() |
Modifier and Type | Method and Description |
---|---|
void |
NodeStatus.setContainersStatuses(List<ContainerStatus> containersStatuses) |
Modifier and Type | Method and Description |
---|---|
List<ContainerStatus> |
NodeStatusPBImpl.getContainersStatuses() |
Modifier and Type | Method and Description |
---|---|
void |
NodeStatusPBImpl.setContainersStatuses(List<ContainerStatus> containers) |
Modifier and Type | Method and Description |
---|---|
ContainerStatus |
ContainerImpl.cloneAndGetContainerStatus() |
ContainerStatus |
Container.cloneAndGetContainerStatus() |
Modifier and Type | Method and Description |
---|---|
List<ContainerStatus> |
RMAppAttempt.getJustFinishedContainers()
Return the list of last set of finished containers.
|
List<ContainerStatus> |
RMAppAttemptImpl.getJustFinishedContainers() |
List<ContainerStatus> |
RMAppAttempt.pullJustFinishedContainers()
Return a list of the last set of finished containers, resetting the
finished containers to empty.
|
List<ContainerStatus> |
RMAppAttemptImpl.pullJustFinishedContainers() |
Modifier and Type | Method and Description |
---|---|
ContainerStatus |
RMAppAttemptContainerFinishedEvent.getContainerStatus() |
Constructor and Description |
---|
RMAppAttemptContainerFinishedEvent(ApplicationAttemptId appAttemptId,
ContainerStatus containerStatus) |
Modifier and Type | Method and Description |
---|---|
ContainerStatus |
RMContainerFinishedEvent.getRemoteContainerStatus() |
Constructor and Description |
---|
RMContainerFinishedEvent(ContainerId containerId,
ContainerStatus containerStatus,
RMContainerEventType event) |
Modifier and Type | Method and Description |
---|---|
List<ContainerStatus> |
UpdatedContainerInfo.getCompletedContainers() |
List<ContainerStatus> |
RMNodeStatusEvent.getContainers() |
List<ContainerStatus> |
UpdatedContainerInfo.getNewlyLaunchedContainers() |
Constructor and Description |
---|
RMNodeStatusEvent(NodeId nodeId,
NodeHealthStatus nodeHealthStatus,
List<ContainerStatus> collection,
List<ApplicationId> keepAliveAppIds,
NodeHeartbeatResponse latestResponse) |
UpdatedContainerInfo(List<ContainerStatus> newlyLaunchedContainers,
List<ContainerStatus> completedContainers) |
UpdatedContainerInfo(List<ContainerStatus> newlyLaunchedContainers,
List<ContainerStatus> completedContainers) |
Modifier and Type | Method and Description |
---|---|
static ContainerStatus |
SchedulerUtils.createAbnormalContainerStatus(ContainerId containerId,
String diagnostics)
Utility to create a
ContainerStatus during exceptional
circumstances. |
static ContainerStatus |
SchedulerUtils.createPreemptedContainerStatus(ContainerId containerId,
String diagnostics)
Utility to create a
ContainerStatus during exceptional
circumstances. |
Modifier and Type | Method and Description |
---|---|
void |
ParentQueue.completedContainer(Resource clusterResource,
FiCaSchedulerApp application,
FiCaSchedulerNode node,
RMContainer rmContainer,
ContainerStatus containerStatus,
RMContainerEventType event,
CSQueue completedChildQueue) |
void |
CSQueue.completedContainer(Resource clusterResource,
FiCaSchedulerApp application,
FiCaSchedulerNode node,
RMContainer container,
ContainerStatus containerStatus,
RMContainerEventType event,
CSQueue childQueue)
A container assigned to the queue has completed.
|
void |
LeafQueue.completedContainer(Resource clusterResource,
FiCaSchedulerApp application,
FiCaSchedulerNode node,
RMContainer rmContainer,
ContainerStatus containerStatus,
RMContainerEventType event,
CSQueue childQueue) |
Modifier and Type | Method and Description |
---|---|
boolean |
FiCaSchedulerApp.containerCompleted(RMContainer rmContainer,
ContainerStatus containerStatus,
RMContainerEventType event) |
Modifier and Type | Method and Description |
---|---|
void |
FSSchedulerApp.containerCompleted(RMContainer rmContainer,
ContainerStatus containerStatus,
RMContainerEventType event) |
Modifier and Type | Method and Description |
---|---|
static ContainerStatus |
BuilderUtils.newContainerStatus(ContainerId containerId,
ContainerState containerState,
String diagnostics,
int exitStatus) |
Modifier and Type | Method and Description |
---|---|
static AllocateResponse |
BuilderUtils.newAllocateResponse(int responseId,
List<ContainerStatus> completedContainers,
List<Container> allocatedContainers,
List<NodeReport> updatedNodes,
Resource availResources,
AMCommand command,
int numClusterNodes,
PreemptionMessage preempt) |
Copyright © 2013 Apache Software Foundation. All rights reserved.