Modifier and Type | Method and Description |
---|---|
Container |
TaskAttemptContainerAssignedEvent.getContainer() |
Constructor and Description |
---|
TaskAttemptContainerAssignedEvent(TaskAttemptId id,
Container container,
Map<ApplicationAccessType,String> applicationACLs) |
Modifier and Type | Field and Description |
---|---|
Container |
TaskAttemptImpl.container |
Modifier and Type | Method and Description |
---|---|
Container |
ContainerRemoteLaunchEvent.getAllocatedContainer() |
Constructor and Description |
---|
ContainerRemoteLaunchEvent(TaskAttemptId taskAttemptID,
ContainerLaunchContext containerLaunchContext,
Container allocatedContainer,
Task remoteTask) |
Modifier and Type | Method and Description |
---|---|
abstract List<Container> |
AllocateResponse.getAllocatedContainers()
Get the list of newly allocated
Container by the
ResourceManager . |
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) |
abstract void |
AllocateResponse.setAllocatedContainers(List<Container> containers)
Set the list of newly allocated
Container by the
ResourceManager . |
Modifier and Type | Method and Description |
---|---|
List<Container> |
AllocateResponsePBImpl.getAllocatedContainers() |
Modifier and Type | Method and Description |
---|---|
void |
AllocateResponsePBImpl.setAllocatedContainers(List<Container> containers) |
Modifier and Type | Method and Description |
---|---|
static Container |
Container.newInstance(ContainerId containerId,
NodeId nodeId,
String nodeHttpAddress,
Resource resource,
Priority priority,
Token containerToken) |
Modifier and Type | Class and Description |
---|---|
class |
ContainerPBImpl |
Modifier and Type | Method and Description |
---|---|
int |
ContainerPBImpl.compareTo(Container other) |
Modifier and Type | Method and Description |
---|---|
abstract Map<String,ByteBuffer> |
NMClient.startContainer(Container container,
ContainerLaunchContext containerLaunchContext)
Start an allocated container.
|
Modifier and Type | Method and Description |
---|---|
abstract void |
NMClientAsync.startContainerAsync(Container container,
ContainerLaunchContext containerLaunchContext) |
Modifier and Type | Method and Description |
---|---|
void |
AMRMClientAsync.CallbackHandler.onContainersAllocated(List<Container> containers)
Called when the ResourceManager responds to a heartbeat with allocated
containers.
|
Modifier and Type | Method and Description |
---|---|
Container |
NMClientAsyncImpl.StartContainerEvent.getContainer() |
Modifier and Type | Method and Description |
---|---|
void |
NMClientAsyncImpl.startContainerAsync(Container container,
ContainerLaunchContext containerLaunchContext) |
Constructor and Description |
---|
NMClientAsyncImpl.StartContainerEvent(Container container,
ContainerLaunchContext containerLaunchContext) |
Modifier and Type | Method and Description |
---|---|
protected NMClientImpl.StartedContainer |
NMClientImpl.createStartedContainer(Container container) |
Map<String,ByteBuffer> |
NMClientImpl.startContainer(Container container,
ContainerLaunchContext containerLaunchContext) |
Modifier and Type | Method and Description |
---|---|
Container |
RMStateStore.ApplicationAttemptState.getMasterContainer() |
Constructor and Description |
---|
RMStateStore.ApplicationAttemptState(ApplicationAttemptId attemptId,
Container masterContainer,
Credentials appAttemptCredentials) |
Modifier and Type | Method and Description |
---|---|
Container |
ApplicationAttemptStateData.getMasterContainer() |
Modifier and Type | Method and Description |
---|---|
void |
ApplicationAttemptStateData.setMasterContainer(Container container) |
Modifier and Type | Method and Description |
---|---|
Container |
ApplicationAttemptStateDataPBImpl.getMasterContainer() |
Modifier and Type | Method and Description |
---|---|
static ApplicationAttemptStateData |
ApplicationAttemptStateDataPBImpl.newApplicationAttemptStateData(ApplicationAttemptId attemptId,
Container container,
ByteBuffer attemptTokens) |
void |
ApplicationAttemptStateDataPBImpl.setMasterContainer(Container container) |
Modifier and Type | Method and Description |
---|---|
Container |
RMAppAttempt.getMasterContainer()
The container on which the Application Master is running.
|
Container |
RMAppAttemptImpl.getMasterContainer() |
Modifier and Type | Method and Description |
---|---|
Container |
RMAppAttemptContainerAcquiredEvent.getContainer() |
Container |
RMAppAttemptContainerAllocatedEvent.getContainer() |
Constructor and Description |
---|
RMAppAttemptContainerAcquiredEvent(ApplicationAttemptId appAttemptId,
Container container) |
RMAppAttemptContainerAllocatedEvent(ApplicationAttemptId appAttemptId,
Container container) |
Modifier and Type | Method and Description |
---|---|
Container |
RMContainerImpl.getContainer() |
Container |
RMContainer.getContainer() |
Constructor and Description |
---|
RMContainerImpl(Container container,
ApplicationAttemptId appAttemptId,
NodeId nodeId,
EventHandler handler,
ContainerAllocationExpirer containerAllocationExpirer) |
Modifier and Type | Method and Description |
---|---|
List<Container> |
NodeResponse.getCompletedContainers() |
List<Container> |
Allocation.getContainers() |
List<Container> |
NodeResponse.getContainersToCleanUp() |
Modifier and Type | Method and Description |
---|---|
void |
AppSchedulingInfo.allocate(NodeType type,
SchedulerNode node,
Priority priority,
ResourceRequest request,
Container container)
Resources have been allocated to this application by the resource
scheduler.
|
Constructor and Description |
---|
Allocation(List<Container> containers,
Resource resourceLimit) |
Allocation(List<Container> containers,
Resource resourceLimit,
Set<ContainerId> strictContainers) |
Allocation(List<Container> containers,
Resource resourceLimit,
Set<ContainerId> strictContainers,
Set<ContainerId> fungibleContainers,
List<ResourceRequest> fungibleResources) |
NodeResponse(List<ApplicationId> finishedApplications,
List<Container> completed,
List<Container> toKill) |
NodeResponse(List<ApplicationId> finishedApplications,
List<Container> completed,
List<Container> toKill) |
Modifier and Type | Method and Description |
---|---|
void |
ParentQueue.recoverContainer(Resource clusterResource,
FiCaSchedulerApp application,
Container container) |
void |
CSQueue.recoverContainer(Resource clusterResource,
FiCaSchedulerApp application,
Container container)
Recover the state of the queue
|
void |
LeafQueue.recoverContainer(Resource clusterResource,
FiCaSchedulerApp application,
Container container) |
Modifier and Type | Method and Description |
---|---|
List<Container> |
FiCaSchedulerApp.pullNewlyAllocatedContainers() |
Modifier and Type | Method and Description |
---|---|
RMContainer |
FiCaSchedulerApp.allocate(NodeType type,
FiCaSchedulerNode node,
Priority priority,
ResourceRequest request,
Container container) |
void |
FiCaSchedulerNode.releaseContainer(Container container)
Release an allocated container on this node.
|
RMContainer |
FiCaSchedulerApp.reserve(FiCaSchedulerNode node,
Priority priority,
RMContainer rmContainer,
Container container) |
Modifier and Type | Method and Description |
---|---|
Container |
AppSchedulable.createContainer(FSSchedulerApp application,
FSSchedulerNode node,
Resource capability,
Priority priority)
Create and return a container object reflecting an allocation for the
given appliction on the given node with the given capability and
priority.
|
Modifier and Type | Method and Description |
---|---|
List<Container> |
FSSchedulerApp.pullNewlyAllocatedContainers() |
Modifier and Type | Method and Description |
---|---|
RMContainer |
FSSchedulerApp.allocate(NodeType type,
FSSchedulerNode node,
Priority priority,
ResourceRequest request,
Container container) |
void |
FSSchedulerNode.releaseContainer(Container container)
Release an allocated container on this node.
|
RMContainer |
FSSchedulerApp.reserve(FSSchedulerNode node,
Priority priority,
RMContainer rmContainer,
Container container) |
Modifier and Type | Method and Description |
---|---|
List<NMToken> |
NMTokenSecretManagerInRM.createAndGetNMTokens(String applicationSubmitter,
ApplicationAttemptId appAttemptId,
List<Container> containers) |
Modifier and Type | Method and Description |
---|---|
static Container |
BuilderUtils.newContainer(ContainerId containerId,
NodeId nodeId,
String nodeHttpAddress,
Resource resource,
Priority priority,
Token containerToken) |
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.