public class LocalContainerAllocator extends RMCommunicator implements ContainerAllocator
RMCommunicator.AllocatorRunnable
ContainerAllocator.EventType
Modifier and Type | Field and Description |
---|---|
protected int |
lastResponseID |
allocatorThread, applicationACLs, applicationId, isSignalled, scheduler
Constructor and Description |
---|
LocalContainerAllocator(ClientService clientService,
AppContext context,
String nmHost,
int nmPort,
int nmHttpPort,
org.apache.hadoop.yarn.api.records.ContainerId cId) |
Modifier and Type | Method and Description |
---|---|
void |
handle(ContainerAllocatorEvent event) |
protected void |
heartbeat() |
protected void |
serviceInit(org.apache.hadoop.conf.Configuration conf) |
createSchedulerProxy, doUnregistration, getApplicationProgress, getContext, getJob, getLastHeartbeatTime, getMaxContainerCapability, getSchedulerResourceTypes, isApplicationMasterRegistered, register, runOnNextHeartbeat, serviceStart, serviceStop, setShouldUnregister, setSignalled, startAllocatorThread, unregister
close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop
public LocalContainerAllocator(ClientService clientService, AppContext context, String nmHost, int nmPort, int nmHttpPort, org.apache.hadoop.yarn.api.records.ContainerId cId)
protected void serviceInit(org.apache.hadoop.conf.Configuration conf) throws Exception
serviceInit
in class RMCommunicator
Exception
protected void heartbeat() throws Exception
heartbeat
in class RMCommunicator
Exception
public void handle(ContainerAllocatorEvent event)
handle
in interface org.apache.hadoop.yarn.event.EventHandler<ContainerAllocatorEvent>
Copyright © 2008–2024 Apache Software Foundation. All rights reserved.