Modifier and Type | Method and Description |
---|---|
ContainerId |
AMStartedEvent.getContainerId() |
ContainerId |
TaskAttemptStartedEvent.getContainerId()
Get the ContainerId
|
ContainerId |
JobHistoryParser.TaskAttemptInfo.getContainerId() |
ContainerId |
JobHistoryParser.AMInfo.getContainerId() |
Constructor and Description |
---|
AMStartedEvent(ApplicationAttemptId appAttemptId,
long startTime,
ContainerId containerId,
String nodeManagerHost,
int nodeManagerPort,
int nodeManagerHttpPort)
Create an event to record the start of an MR AppMaster
|
JobHistoryParser.AMInfo(ApplicationAttemptId appAttemptId,
long startTime,
ContainerId containerId,
String nodeManagerHost,
int nodeManagerPort,
int nodeManagerHttpPort) |
TaskAttemptStartedEvent(TaskAttemptID attemptId,
TaskType taskType,
long startTime,
String trackerName,
int httpPort,
int shufflePort,
ContainerId containerId,
String locality,
String avataar)
Create an event to record the start of an attempt
|
Modifier and Type | Method and Description |
---|---|
ContainerId |
AMInfo.getContainerId() |
ContainerId |
TaskAttemptReport.getContainerId() |
Modifier and Type | Method and Description |
---|---|
void |
AMInfo.setContainerId(ContainerId containerId) |
void |
TaskAttemptReport.setContainerId(ContainerId containerId) |
Modifier and Type | Method and Description |
---|---|
ContainerId |
AMInfoPBImpl.getContainerId() |
ContainerId |
TaskAttemptReportPBImpl.getContainerId() |
Modifier and Type | Method and Description |
---|---|
void |
AMInfoPBImpl.setContainerId(ContainerId containerId) |
void |
TaskAttemptReportPBImpl.setContainerId(ContainerId containerId) |
Constructor and Description |
---|
MRAppMaster(ApplicationAttemptId applicationAttemptId,
ContainerId containerId,
String nmHost,
int nmPort,
int nmHttpPort,
Clock clock,
long appSubmitTime,
int maxAppAttempts) |
MRAppMaster(ApplicationAttemptId applicationAttemptId,
ContainerId containerId,
String nmHost,
int nmPort,
int nmHttpPort,
long appSubmitTime,
int maxAppAttempts) |
Modifier and Type | Method and Description |
---|---|
ContainerId |
TaskAttempt.getAssignedContainerID() |
Modifier and Type | Method and Description |
---|---|
ContainerId |
TaskAttemptImpl.getAssignedContainerID() |
Modifier and Type | Method and Description |
---|---|
ContainerId |
ContainerLauncherEvent.getContainerID() |
Modifier and Type | Method and Description |
---|---|
ContainerManagementProtocolProxy.ContainerManagementProtocolProxyData |
ContainerLauncherImpl.getCMProxy(String containerMgrBindAddr,
ContainerId containerId) |
Constructor and Description |
---|
ContainerLauncherEvent(TaskAttemptId taskAttemptID,
ContainerId containerID,
String containerMgrAddress,
Token containerToken,
ContainerLauncher.EventType type) |
Constructor and Description |
---|
LocalContainerAllocator(ClientService clientService,
AppContext context,
String nmHost,
int nmPort,
int nmHttpPort,
ContainerId cId) |
Modifier and Type | Method and Description |
---|---|
protected void |
RMContainerRequestor.release(ContainerId containerId) |
Modifier and Type | Field and Description |
---|---|
protected ContainerId |
TaskAttemptInfo.assignedContainer |
Modifier and Type | Method and Description |
---|---|
ContainerId |
TaskAttemptInfo.getAssignedContainerId() |
Modifier and Type | Method and Description |
---|---|
ContainerId |
CompletedTaskAttempt.getAssignedContainerID() |
Modifier and Type | Method and Description |
---|---|
static AMInfo |
MRBuilderUtils.newAMInfo(ApplicationAttemptId appAttemptId,
long startTime,
ContainerId containerId,
String nmHost,
int nmPort,
int nmHttpPort) |
Modifier and Type | Method and Description |
---|---|
abstract List<ContainerId> |
GetContainerStatusesRequest.getContainerIds()
Get the list of
ContainerId s of containers for which to obtain
the ContainerStatus . |
abstract List<ContainerId> |
StopContainersRequest.getContainerIds()
Get the
ContainerId s of the containers to be stopped. |
abstract Map<ContainerId,SerializedException> |
StopContainersResponse.getFailedRequests()
Get the containerId-to-exception map in which the exception indicates error
from per container for failed requests
|
abstract Map<ContainerId,SerializedException> |
StartContainersResponse.getFailedRequests()
Get the containerId-to-exception map in which the exception indicates error
from per container for failed requests
|
abstract Map<ContainerId,SerializedException> |
GetContainerStatusesResponse.getFailedRequests()
Get the containerId-to-exception map in which the exception indicates error
from per container for failed requests
|
abstract List<ContainerId> |
AllocateRequest.getReleaseList()
Get the list of
ContainerId of containers being
released by the ApplicationMaster . |
abstract List<ContainerId> |
StartContainersResponse.getSuccessfullyStartedContainers()
Get the list of
ContainerId s of the containers that are
started successfully. |
abstract List<ContainerId> |
StopContainersResponse.getSuccessfullyStoppedContainers()
Get the list of containerIds of successfully stopped containers.
|
Modifier and Type | Method and Description |
---|---|
static AllocateRequest |
AllocateRequest.newInstance(int responseID,
float appProgress,
List<ResourceRequest> resourceAsk,
List<ContainerId> containersToBeReleased,
ResourceBlacklistRequest resourceBlacklistRequest) |
static GetContainerStatusesRequest |
GetContainerStatusesRequest.newInstance(List<ContainerId> containerIds) |
static StopContainersRequest |
StopContainersRequest.newInstance(List<ContainerId> containerIds) |
static StopContainersResponse |
StopContainersResponse.newInstance(List<ContainerId> succeededRequests,
Map<ContainerId,SerializedException> failedRequests) |
static StopContainersResponse |
StopContainersResponse.newInstance(List<ContainerId> succeededRequests,
Map<ContainerId,SerializedException> failedRequests) |
static GetContainerStatusesResponse |
GetContainerStatusesResponse.newInstance(List<ContainerStatus> statuses,
Map<ContainerId,SerializedException> failedRequests) |
static StartContainersResponse |
StartContainersResponse.newInstance(Map<String,ByteBuffer> servicesMetaData,
List<ContainerId> succeededContainers,
Map<ContainerId,SerializedException> failedContainers) |
static StartContainersResponse |
StartContainersResponse.newInstance(Map<String,ByteBuffer> servicesMetaData,
List<ContainerId> succeededContainers,
Map<ContainerId,SerializedException> failedContainers) |
abstract void |
GetContainerStatusesRequest.setContainerIds(List<ContainerId> containerIds)
Set a list of
ContainerId s of containers for which to obtain
the ContainerStatus |
abstract void |
StopContainersRequest.setContainerIds(List<ContainerId> containerIds)
Set the
ContainerId s of the containers to be stopped. |
abstract void |
StopContainersResponse.setFailedRequests(Map<ContainerId,SerializedException> failedRequests)
Set the containerId-to-exception map in which the exception indicates error
from per container for failed requests
|
abstract void |
StartContainersResponse.setFailedRequests(Map<ContainerId,SerializedException> failedContainers)
Set the containerId-to-exception map in which the exception indicates error
from per container for failed requests
|
abstract void |
GetContainerStatusesResponse.setFailedRequests(Map<ContainerId,SerializedException> failedContainers)
Set the containerId-to-exception map in which the exception indicates error
from per container for failed requests
|
abstract void |
AllocateRequest.setReleaseList(List<ContainerId> releaseContainers)
Set the list of
ContainerId of containers being
released by the ApplicationMaster |
abstract void |
StartContainersResponse.setSuccessfullyStartedContainers(List<ContainerId> succeededContainers) |
abstract void |
StopContainersResponse.setSuccessfullyStoppedContainers(List<ContainerId> succeededRequests)
Set the list of containerIds of successfully stopped containers.
|
Modifier and Type | Method and Description |
---|---|
List<ContainerId> |
GetContainerStatusesRequestPBImpl.getContainerIds() |
List<ContainerId> |
StopContainersRequestPBImpl.getContainerIds() |
Map<ContainerId,SerializedException> |
StartContainersResponsePBImpl.getFailedRequests() |
Map<ContainerId,SerializedException> |
StopContainersResponsePBImpl.getFailedRequests() |
Map<ContainerId,SerializedException> |
GetContainerStatusesResponsePBImpl.getFailedRequests() |
List<ContainerId> |
AllocateRequestPBImpl.getReleaseList() |
List<ContainerId> |
StartContainersResponsePBImpl.getSuccessfullyStartedContainers() |
List<ContainerId> |
StopContainersResponsePBImpl.getSuccessfullyStoppedContainers() |
Modifier and Type | Method and Description |
---|---|
void |
GetContainerStatusesRequestPBImpl.setContainerIds(List<ContainerId> containerIds) |
void |
StopContainersRequestPBImpl.setContainerIds(List<ContainerId> containerIds) |
void |
StartContainersResponsePBImpl.setFailedRequests(Map<ContainerId,SerializedException> failedContainers) |
void |
StopContainersResponsePBImpl.setFailedRequests(Map<ContainerId,SerializedException> failedRequests) |
void |
GetContainerStatusesResponsePBImpl.setFailedRequests(Map<ContainerId,SerializedException> failedRequests) |
void |
AllocateRequestPBImpl.setReleaseList(List<ContainerId> releaseContainers) |
void |
StartContainersResponsePBImpl.setSuccessfullyStartedContainers(List<ContainerId> succeededContainers) |
void |
StopContainersResponsePBImpl.setSuccessfullyStoppedContainers(List<ContainerId> succeededRequests) |
Modifier and Type | Method and Description |
---|---|
abstract ContainerId |
ContainerStatus.getContainerId()
Get the
ContainerId of the container. |
abstract ContainerId |
Container.getId()
Get the globally unique identifier for the container.
|
abstract ContainerId |
PreemptionContainer.getId() |
static ContainerId |
ContainerId.newInstance(ApplicationAttemptId appAttemptId,
int containerId) |
Modifier and Type | Method and Description |
---|---|
int |
ContainerId.compareTo(ContainerId other) |
static PreemptionContainer |
PreemptionContainer.newInstance(ContainerId id) |
static ContainerStatus |
ContainerStatus.newInstance(ContainerId containerId,
ContainerState containerState,
String diagnostics,
int exitStatus) |
static Container |
Container.newInstance(ContainerId containerId,
NodeId nodeId,
String nodeHttpAddress,
Resource resource,
Priority priority,
Token containerToken) |
abstract void |
ContainerStatus.setContainerId(ContainerId containerId) |
abstract void |
Container.setId(ContainerId id) |
abstract void |
PreemptionContainer.setId(ContainerId id) |
Modifier and Type | Class and Description |
---|---|
class |
ContainerIdPBImpl |
Modifier and Type | Method and Description |
---|---|
ContainerId |
ContainerStatusPBImpl.getContainerId() |
ContainerId |
PreemptionContainerPBImpl.getId() |
ContainerId |
ContainerPBImpl.getId() |
Modifier and Type | Method and Description |
---|---|
void |
ContainerStatusPBImpl.setContainerId(ContainerId containerId) |
void |
PreemptionContainerPBImpl.setId(ContainerId id) |
void |
ContainerPBImpl.setId(ContainerId id) |
Modifier and Type | Method and Description |
---|---|
abstract ContainerStatus |
NMClient.getContainerStatus(ContainerId containerId,
NodeId nodeId)
Query the status of a container.
|
abstract void |
AMRMClient.releaseAssignedContainer(ContainerId containerId)
Release containers assigned by the Resource Manager.
|
abstract void |
NMClient.stopContainer(ContainerId containerId,
NodeId nodeId)
Stop an started container.
|
Modifier and Type | Method and Description |
---|---|
abstract void |
NMClientAsync.getContainerStatusAsync(ContainerId containerId,
NodeId nodeId) |
void |
NMClientAsync.CallbackHandler.onContainerStarted(ContainerId containerId,
Map<String,ByteBuffer> allServiceResponse)
The API is called when
NodeManager responds to indicate its
acceptance of the starting container request |
void |
NMClientAsync.CallbackHandler.onContainerStatusReceived(ContainerId containerId,
ContainerStatus containerStatus)
The API is called when
NodeManager responds with the status
of the container |
void |
NMClientAsync.CallbackHandler.onContainerStopped(ContainerId containerId)
The API is called when
NodeManager responds to indicate the
container is stopped. |
void |
NMClientAsync.CallbackHandler.onGetContainerStatusError(ContainerId containerId,
Throwable t)
The API is called when an exception is raised in the process of
querying the status of a container
|
void |
NMClientAsync.CallbackHandler.onStartContainerError(ContainerId containerId,
Throwable t)
The API is called when an exception is raised in the process of
starting a container
|
void |
NMClientAsync.CallbackHandler.onStopContainerError(ContainerId containerId,
Throwable t)
The API is called when an exception is raised in the process of
stopping a container
|
abstract void |
AMRMClientAsync.releaseAssignedContainer(ContainerId containerId)
Release containers assigned by the Resource Manager.
|
abstract void |
NMClientAsync.stopContainerAsync(ContainerId containerId,
NodeId nodeId) |
Modifier and Type | Field and Description |
---|---|
protected ConcurrentMap<ContainerId,NMClientAsyncImpl.StatefulContainer> |
NMClientAsyncImpl.containers |
Modifier and Type | Method and Description |
---|---|
ContainerId |
NMClientAsyncImpl.ContainerEvent.getContainerId() |
ContainerId |
NMClientAsyncImpl.StatefulContainer.getContainerId() |
Modifier and Type | Method and Description |
---|---|
void |
NMClientAsyncImpl.getContainerStatusAsync(ContainerId containerId,
NodeId nodeId) |
void |
AMRMClientAsyncImpl.releaseAssignedContainer(ContainerId containerId)
Release containers assigned by the Resource Manager.
|
void |
NMClientAsyncImpl.stopContainerAsync(ContainerId containerId,
NodeId nodeId) |
Constructor and Description |
---|
NMClientAsyncImpl.ContainerEvent(ContainerId containerId,
NodeId nodeId,
Token containerToken,
NMClientAsyncImpl.ContainerEventType type) |
NMClientAsyncImpl.StatefulContainer(NMClientAsync client,
ContainerId containerId) |
Modifier and Type | Field and Description |
---|---|
protected Set<ContainerId> |
AMRMClientImpl.release |
protected ConcurrentMap<ContainerId,NMClientImpl.StartedContainer> |
NMClientImpl.startedContainers |
Modifier and Type | Method and Description |
---|---|
ContainerId |
NMClientImpl.StartedContainer.getContainerId() |
Modifier and Type | Method and Description |
---|---|
ContainerStatus |
NMClientImpl.getContainerStatus(ContainerId containerId,
NodeId nodeId) |
ContainerManagementProtocolProxy.ContainerManagementProtocolProxyData |
ContainerManagementProtocolProxy.getProxy(String containerManagerBindAddr,
ContainerId containerId) |
protected NMClientImpl.StartedContainer |
NMClientImpl.getStartedContainer(ContainerId containerId) |
protected ContainerManagementProtocol |
ContainerManagementProtocolProxy.ContainerManagementProtocolProxyData.newProxy(YarnRPC rpc,
String containerManagerBindAddr,
ContainerId containerId,
Token token) |
void |
AMRMClientImpl.releaseAssignedContainer(ContainerId containerId) |
void |
NMClientImpl.stopContainer(ContainerId containerId,
NodeId nodeId) |
Constructor and Description |
---|
ContainerManagementProtocolProxy.ContainerManagementProtocolProxyData(YarnRPC rpc,
String containerManagerBindAddr,
ContainerId containerId,
Token token) |
NMClientImpl.StartedContainer(ContainerId containerId,
NodeId nodeId,
Token containerToken) |
Modifier and Type | Method and Description |
---|---|
AggregatedLogFormat.ContainerLogsReader |
AggregatedLogFormat.LogReader.getContainerLogsReader(ContainerId containerId)
Get a ContainerLogsReader to read the logs for
the specified container.
|
Constructor and Description |
---|
AggregatedLogFormat.LogKey(ContainerId containerId) |
AggregatedLogFormat.LogValue(List<String> rootLogDirs,
ContainerId containerId,
String user) |
Modifier and Type | Method and Description |
---|---|
ContainerId |
ContainerTokenIdentifier.getContainerID() |
Constructor and Description |
---|
ContainerTokenIdentifier(ContainerId containerID,
String hostName,
String appSubmitter,
Resource r,
long expiryTimeStamp,
int masterKeyId,
long rmIdentifier) |
Modifier and Type | Method and Description |
---|---|
ContainerId |
ContainerContext.getContainerId()
Get
ContainerId of the container being initialized or stopped. |
Constructor and Description |
---|
ContainerContext(String user,
ContainerId containerId,
Resource resource) |
ContainerInitializationContext(String user,
ContainerId containerId,
Resource resource) |
ContainerTerminationContext(String user,
ContainerId containerId,
Resource resource) |
Modifier and Type | Method and Description |
---|---|
List<ContainerId> |
NodeHeartbeatResponse.getContainersToCleanup() |
Modifier and Type | Method and Description |
---|---|
void |
NodeHeartbeatResponse.addAllContainersToCleanup(List<ContainerId> containers) |
Modifier and Type | Method and Description |
---|---|
List<ContainerId> |
NodeHeartbeatResponsePBImpl.getContainersToCleanup() |
Modifier and Type | Method and Description |
---|---|
void |
NodeHeartbeatResponsePBImpl.addAllContainersToCleanup(List<ContainerId> containersToCleanup) |
Modifier and Type | Method and Description |
---|---|
ConcurrentMap<ContainerId,Container> |
NodeManager.NMContext.getContainers() |
ConcurrentMap<ContainerId,Container> |
Context.getContainers() |
List<ContainerId> |
CMgrCompletedContainersEvent.getContainersToCleanup() |
Modifier and Type | Method and Description |
---|---|
void |
ContainerExecutor.activateContainer(ContainerId containerId,
Path pidFilePath)
Mark the container as active
|
void |
NodeStatusUpdaterImpl.addStoppedContainersToCache(ContainerId containerId) |
void |
ContainerExecutor.deactivateContainer(ContainerId containerId)
Mark the container as inactive.
|
protected Path |
ContainerExecutor.getPidFilePath(ContainerId containerId)
Get the pidFile of the container.
|
String |
ContainerExecutor.getProcessId(ContainerId containerID)
Get the process-identifier for the container
|
protected boolean |
ContainerExecutor.isContainerActive(ContainerId containerId)
Is the container still active?
|
boolean |
NodeStatusUpdater.isContainerRecentlyStopped(ContainerId containerId) |
boolean |
NodeStatusUpdaterImpl.isContainerRecentlyStopped(ContainerId containerId) |
static void |
NMAuditLogger.logFailure(String user,
String operation,
String target,
String description,
ApplicationId appId,
ContainerId containerId)
Create a readable and parseable audit log string for a failed event.
|
static void |
NMAuditLogger.logSuccess(String user,
String operation,
String target,
ApplicationId appId,
ContainerId containerId)
Create a readable and parseable audit log string for a successful event.
|
Constructor and Description |
---|
CMgrCompletedContainersEvent(List<ContainerId> containersToCleanup,
CMgrCompletedContainersEvent.Reason reason) |
Modifier and Type | Method and Description |
---|---|
protected void |
ContainerManagerImpl.authorizeGetAndStopContainerRequest(ContainerId containerId,
Container container,
boolean stopRequest,
NMTokenIdentifier identifier) |
Modifier and Type | Method and Description |
---|---|
ContainerId |
ApplicationContainerFinishedEvent.getContainerID() |
Modifier and Type | Method and Description |
---|---|
Map<ContainerId,Container> |
ApplicationImpl.getContainers() |
Map<ContainerId,Container> |
Application.getContainers() |
Constructor and Description |
---|
ApplicationContainerFinishedEvent(ContainerId containerID) |
Modifier and Type | Method and Description |
---|---|
ContainerId |
ContainerImpl.getContainerId() |
ContainerId |
Container.getContainerId() |
ContainerId |
ContainerEvent.getContainerID() |
Constructor and Description |
---|
ContainerDiagnosticsUpdateEvent(ContainerId cID,
String update) |
ContainerEvent(ContainerId cID,
ContainerEventType eventType) |
ContainerExitEvent(ContainerId cID,
ContainerEventType eventType,
int exitCode,
String diagnosticInfo) |
ContainerInitEvent(ContainerId c) |
ContainerKillEvent(ContainerId cID,
String diagnostic) |
ContainerResourceEvent(ContainerId container,
ContainerEventType type,
LocalResourceRequest rsrc) |
ContainerResourceFailedEvent(ContainerId container,
LocalResourceRequest rsrc,
String diagnosticMesage) |
ContainerResourceLocalizedEvent(ContainerId container,
LocalResourceRequest rsrc,
Path loc) |
Modifier and Type | Field and Description |
---|---|
Map<ContainerId,ContainerLaunch> |
ContainersLauncher.running |
Modifier and Type | Method and Description |
---|---|
ContainerId |
LocalizerContext.getContainerId() |
Constructor and Description |
---|
LocalizerContext(String user,
ContainerId containerId,
Credentials credentials) |
Modifier and Type | Method and Description |
---|---|
ContainerId |
ResourceReleaseEvent.getContainer() |
Constructor and Description |
---|
ResourceReleaseEvent(LocalResourceRequest rsrc,
ContainerId container) |
Modifier and Type | Method and Description |
---|---|
void |
AppLogAggregator.startContainerLogAggregation(ContainerId containerId,
boolean wasContainerSuccessful) |
void |
AppLogAggregatorImpl.startContainerLogAggregation(ContainerId containerId,
boolean wasContainerSuccessful) |
Modifier and Type | Method and Description |
---|---|
ContainerId |
LogHandlerContainerFinishedEvent.getContainerId() |
Constructor and Description |
---|
LogHandlerContainerFinishedEvent(ContainerId containerId,
int exitCode) |
Modifier and Type | Method and Description |
---|---|
ContainerId |
ContainersMonitorEvent.getContainerId() |
Constructor and Description |
---|
ContainersMonitorEvent(ContainerId containerId,
ContainersMonitorEventType eventType) |
ContainerStartMonitoringEvent(ContainerId containerId,
long vmemLimit,
long pmemLimit) |
ContainerStopMonitoringEvent(ContainerId containerId) |
Modifier and Type | Method and Description |
---|---|
String |
DefaultLCEResourcesHandler.getResourcesOption(ContainerId containerId) |
String |
CgroupsLCEResourcesHandler.getResourcesOption(ContainerId containerId) |
String |
LCEResourcesHandler.getResourcesOption(ContainerId containerId) |
void |
DefaultLCEResourcesHandler.postExecute(ContainerId containerId) |
void |
CgroupsLCEResourcesHandler.postExecute(ContainerId containerId) |
void |
LCEResourcesHandler.postExecute(ContainerId containerId)
Called by the LinuxContainerExecutor after the executable inside the
container has exited (successfully or not).
|
void |
DefaultLCEResourcesHandler.preExecute(ContainerId containerId,
Resource containerResource) |
void |
CgroupsLCEResourcesHandler.preExecute(ContainerId containerId,
Resource containerResource) |
void |
LCEResourcesHandler.preExecute(ContainerId containerId,
Resource containerResource)
Called by the LinuxContainerExecutor before launching the executable
inside the container.
|
Modifier and Type | Method and Description |
---|---|
static void |
RMAuditLogger.logFailure(String user,
String operation,
String perm,
String target,
String description,
ApplicationId appId,
ContainerId containerId)
Create a readable and parseable audit log string for a failed event.
|
static void |
RMAuditLogger.logSuccess(String user,
String operation,
String target,
ApplicationId appId,
ContainerId containerId)
Create a readable and parseable audit log string for a successful event.
|
Modifier and Type | Method and Description |
---|---|
static void |
RMServerUtils.validateContainerReleaseRequest(List<ContainerId> containerReleaseList,
ApplicationAttemptId appAttemptId)
It will validate to make sure all the containers belong to correct
application attempt id.
|
Modifier and Type | Method and Description |
---|---|
protected ContainerManagementProtocol |
AMLauncher.getContainerMgrProxy(ContainerId containerId) |
Modifier and Type | Method and Description |
---|---|
ContainerId |
RMContainerImpl.getContainerId() |
ContainerId |
RMContainerEvent.getContainerId() |
ContainerId |
RMContainer.getContainerId() |
Modifier and Type | Method and Description |
---|---|
protected void |
ContainerAllocationExpirer.expire(ContainerId containerId) |
Constructor and Description |
---|
RMContainerEvent(ContainerId containerId,
RMContainerEventType type) |
RMContainerFinishedEvent(ContainerId containerId,
ContainerStatus containerStatus,
RMContainerEventType event) |
RMContainerReservedEvent(ContainerId containerId,
Resource reservedResource,
NodeId reservedNode,
Priority reservedPriority) |
Modifier and Type | Method and Description |
---|---|
ContainerId |
RMNodeCleanContainerEvent.getContainerId() |
Modifier and Type | Method and Description |
---|---|
List<ContainerId> |
RMNodeImpl.getContainersToCleanUp() |
List<ContainerId> |
RMNode.getContainersToCleanUp() |
Constructor and Description |
---|
RMNodeCleanContainerEvent(NodeId nodeId,
ContainerId contId) |
Modifier and Type | Method and Description |
---|---|
Set<ContainerId> |
Allocation.getContainerPreemptions() |
Set<ContainerId> |
Allocation.getStrictContainerPreemptions() |
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 |
---|---|
Allocation |
YarnScheduler.allocate(ApplicationAttemptId appAttemptId,
List<ResourceRequest> ask,
List<ContainerId> release,
List<String> blacklistAdditions,
List<String> blacklistRemovals)
The main api between the ApplicationMaster and the Scheduler.
|
Constructor and Description |
---|
Allocation(List<Container> containers,
Resource resourceLimit,
Set<ContainerId> strictContainers) |
Allocation(List<Container> containers,
Resource resourceLimit,
Set<ContainerId> strictContainers,
Set<ContainerId> fungibleContainers,
List<ResourceRequest> fungibleResources) |
Allocation(List<Container> containers,
Resource resourceLimit,
Set<ContainerId> strictContainers,
Set<ContainerId> fungibleContainers,
List<ResourceRequest> fungibleResources) |
Modifier and Type | Method and Description |
---|---|
Allocation |
CapacityScheduler.allocate(ApplicationAttemptId applicationAttemptId,
List<ResourceRequest> ask,
List<ContainerId> release,
List<String> blacklistAdditions,
List<String> blacklistRemovals) |
Modifier and Type | Method and Description |
---|---|
void |
FiCaSchedulerApp.addPreemptContainer(ContainerId cont) |
void |
FiCaSchedulerApp.containerLaunchedOnNode(ContainerId containerId,
NodeId nodeId) |
RMContainer |
FiCaSchedulerApp.getRMContainer(ContainerId id) |
Modifier and Type | Method and Description |
---|---|
ContainerId |
ContainerExpiredSchedulerEvent.getContainerId() |
Constructor and Description |
---|
ContainerExpiredSchedulerEvent(ContainerId containerId) |
Modifier and Type | Method and Description |
---|---|
void |
FSSchedulerApp.containerLaunchedOnNode(ContainerId containerId,
NodeId nodeId) |
RMContainer |
FSSchedulerApp.getRMContainer(ContainerId id) |
Modifier and Type | Method and Description |
---|---|
Allocation |
FairScheduler.allocate(ApplicationAttemptId appAttemptId,
List<ResourceRequest> ask,
List<ContainerId> release,
List<String> blacklistAdditions,
List<String> blacklistRemovals) |
Modifier and Type | Method and Description |
---|---|
Allocation |
FifoScheduler.allocate(ApplicationAttemptId applicationAttemptId,
List<ResourceRequest> ask,
List<ContainerId> release,
List<String> blacklistAdditions,
List<String> blacklistRemovals) |
Modifier and Type | Method and Description |
---|---|
Token |
RMContainerTokenSecretManager.createContainerToken(ContainerId containerId,
NodeId nodeId,
String appSubmitter,
Resource capability)
Helper function for creating ContainerTokens
|
Modifier and Type | Method and Description |
---|---|
static ContainerId |
BuilderUtils.newContainerId(ApplicationAttemptId appAttemptId,
int containerId) |
static ContainerId |
BuilderUtils.newContainerId(int appId,
int appAttemptId,
long timestamp,
int id) |
static ContainerId |
BuilderUtils.newContainerId(RecordFactory recordFactory,
ApplicationId appId,
ApplicationAttemptId appAttemptId,
int containerId) |
Modifier and Type | Method and Description |
---|---|
int |
BuilderUtils.ContainerIdComparator.compare(ContainerId c1,
ContainerId c2) |
static Container |
BuilderUtils.newContainer(ContainerId containerId,
NodeId nodeId,
String nodeHttpAddress,
Resource resource,
Priority priority,
Token containerToken) |
static ContainerStatus |
BuilderUtils.newContainerStatus(ContainerId containerId,
ContainerState containerState,
String diagnostics,
int exitStatus) |
static Token |
BuilderUtils.newContainerToken(ContainerId cId,
String host,
int port,
String user,
Resource r,
long expiryTime,
int masterKeyId,
byte[] password,
long rmIdentifier) |
Modifier and Type | Method and Description |
---|---|
static NodeHeartbeatResponse |
YarnServerBuilderUtils.newNodeHeartbeatResponse(int responseId,
NodeAction action,
List<ContainerId> containersToCleanUp,
List<ApplicationId> applicationsToCleanUp,
MasterKey containerTokenMasterKey,
MasterKey nmTokenMasterKey,
long nextHeartbeatInterval) |
Modifier and Type | Method and Description |
---|---|
static ContainerId |
ConverterUtils.toContainerId(String containerIdStr) |
Modifier and Type | Method and Description |
---|---|
static String |
ConverterUtils.toString(ContainerId cId) |
Copyright © 2013 Apache Software Foundation. All rights reserved.