public class NMNullStateStoreService extends NMStateStoreService
NMStateStoreService.LocalResourceTrackerState, NMStateStoreService.RecoveredDeletionServiceState, NMStateStoreService.RecoveredLocalizationState, NMStateStoreService.RecoveredUserResources
Constructor and Description |
---|
NMNullStateStoreService() |
Modifier and Type | Method and Description |
---|---|
boolean |
canRecover() |
protected void |
closeStorage() |
void |
finishResourceLocalization(String user,
org.apache.hadoop.yarn.api.records.ApplicationId appId,
YarnServerNodemanagerRecoveryProtos.LocalizedResourceProto proto)
Record the completion of a resource localization
|
protected void |
initStorage(org.apache.hadoop.conf.Configuration conf) |
NMStateStoreService.RecoveredDeletionServiceState |
loadDeletionServiceState() |
NMStateStoreService.RecoveredLocalizationState |
loadLocalizationState()
Load the state of localized resources
|
void |
removeDeletionTask(int taskId) |
void |
removeLocalizedResource(String user,
org.apache.hadoop.yarn.api.records.ApplicationId appId,
org.apache.hadoop.fs.Path localPath)
Remove records related to a resource localization
|
void |
startResourceLocalization(String user,
org.apache.hadoop.yarn.api.records.ApplicationId appId,
org.apache.hadoop.yarn.proto.YarnProtos.LocalResourceProto proto,
org.apache.hadoop.fs.Path localPath)
Record the start of localization for a resource
|
protected void |
startStorage() |
void |
storeDeletionTask(int taskId,
YarnServerNodemanagerRecoveryProtos.DeletionServiceDeleteTaskProto taskProto) |
serviceInit, serviceStart, serviceStop
close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop
public boolean canRecover()
canRecover
in class NMStateStoreService
public NMStateStoreService.RecoveredLocalizationState loadLocalizationState() throws IOException
NMStateStoreService
loadLocalizationState
in class NMStateStoreService
IOException
public void startResourceLocalization(String user, org.apache.hadoop.yarn.api.records.ApplicationId appId, org.apache.hadoop.yarn.proto.YarnProtos.LocalResourceProto proto, org.apache.hadoop.fs.Path localPath) throws IOException
NMStateStoreService
startResourceLocalization
in class NMStateStoreService
user
- the username or null if the resource is publicappId
- the application ID if the resource is app-specific or nullproto
- the resource requestlocalPath
- local filesystem path where the resource will be storedIOException
public void finishResourceLocalization(String user, org.apache.hadoop.yarn.api.records.ApplicationId appId, YarnServerNodemanagerRecoveryProtos.LocalizedResourceProto proto) throws IOException
NMStateStoreService
finishResourceLocalization
in class NMStateStoreService
user
- the username or null if the resource is publicappId
- the application ID if the resource is app-specific or nullproto
- the serialized localized resourceIOException
public void removeLocalizedResource(String user, org.apache.hadoop.yarn.api.records.ApplicationId appId, org.apache.hadoop.fs.Path localPath) throws IOException
NMStateStoreService
removeLocalizedResource
in class NMStateStoreService
user
- the username or null if the resource is publicappId
- the application ID if the resource is app-specific or nulllocalPath
- local filesystem path where the resource will be storedIOException
public NMStateStoreService.RecoveredDeletionServiceState loadDeletionServiceState() throws IOException
loadDeletionServiceState
in class NMStateStoreService
IOException
public void storeDeletionTask(int taskId, YarnServerNodemanagerRecoveryProtos.DeletionServiceDeleteTaskProto taskProto) throws IOException
storeDeletionTask
in class NMStateStoreService
IOException
public void removeDeletionTask(int taskId) throws IOException
removeDeletionTask
in class NMStateStoreService
IOException
protected void initStorage(org.apache.hadoop.conf.Configuration conf) throws IOException
initStorage
in class NMStateStoreService
IOException
protected void startStorage() throws IOException
startStorage
in class NMStateStoreService
IOException
protected void closeStorage() throws IOException
closeStorage
in class NMStateStoreService
IOException
Copyright © 2015 Apache Software Foundation. All Rights Reserved.