Modifier and Type | Method and Description |
---|---|
ApplicationAttemptStateData |
RMStateUpdateAppAttemptEvent.getAppAttemptState() |
ApplicationAttemptStateData |
RMStateStoreAppAttemptEvent.getAppAttemptState() |
Modifier and Type | Method and Description |
---|---|
void |
ZKRMStateStore.storeApplicationAttemptStateInternal(org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId,
ApplicationAttemptStateData attemptStateDataPB) |
protected abstract void |
RMStateStore.storeApplicationAttemptStateInternal(org.apache.hadoop.yarn.api.records.ApplicationAttemptId attemptId,
ApplicationAttemptStateData attemptStateData)
Blocking API
Derived classes must implement this method to store the state of an
application attempt
|
protected void |
NullRMStateStore.storeApplicationAttemptStateInternal(org.apache.hadoop.yarn.api.records.ApplicationAttemptId attemptId,
ApplicationAttemptStateData attemptStateData) |
void |
MemoryRMStateStore.storeApplicationAttemptStateInternal(org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId,
ApplicationAttemptStateData attemptState) |
protected void |
LeveldbRMStateStore.storeApplicationAttemptStateInternal(org.apache.hadoop.yarn.api.records.ApplicationAttemptId attemptId,
ApplicationAttemptStateData attemptStateData) |
void |
FileSystemRMStateStore.storeApplicationAttemptStateInternal(org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId,
ApplicationAttemptStateData attemptStateDataPB) |
void |
RMStateStore.updateApplicationAttemptState(ApplicationAttemptStateData attemptState) |
void |
ZKRMStateStore.updateApplicationAttemptStateInternal(org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId,
ApplicationAttemptStateData attemptStateDataPB) |
protected abstract void |
RMStateStore.updateApplicationAttemptStateInternal(org.apache.hadoop.yarn.api.records.ApplicationAttemptId attemptId,
ApplicationAttemptStateData attemptStateData) |
protected void |
NullRMStateStore.updateApplicationAttemptStateInternal(org.apache.hadoop.yarn.api.records.ApplicationAttemptId attemptId,
ApplicationAttemptStateData attemptStateData) |
void |
MemoryRMStateStore.updateApplicationAttemptStateInternal(org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId,
ApplicationAttemptStateData attemptState) |
protected void |
LeveldbRMStateStore.updateApplicationAttemptStateInternal(org.apache.hadoop.yarn.api.records.ApplicationAttemptId attemptId,
ApplicationAttemptStateData attemptStateData) |
void |
FileSystemRMStateStore.updateApplicationAttemptStateInternal(org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId,
ApplicationAttemptStateData attemptStateDataPB) |
Constructor and Description |
---|
RMStateStoreAppAttemptEvent(ApplicationAttemptStateData attemptState) |
RMStateUpdateAppAttemptEvent(ApplicationAttemptStateData attemptState) |
Modifier and Type | Field and Description |
---|---|
Map<org.apache.hadoop.yarn.api.records.ApplicationAttemptId,ApplicationAttemptStateData> |
ApplicationStateData.attempts |
Modifier and Type | Method and Description |
---|---|
ApplicationAttemptStateData |
ApplicationStateData.getAttempt(org.apache.hadoop.yarn.api.records.ApplicationAttemptId attemptId) |
static ApplicationAttemptStateData |
ApplicationAttemptStateData.newInstance(org.apache.hadoop.yarn.api.records.ApplicationAttemptId attemptId,
org.apache.hadoop.yarn.api.records.Container masterContainer,
org.apache.hadoop.security.Credentials attemptTokens,
long startTime,
long memorySeconds,
long vcoreSeconds,
long preemptedMemorySeconds,
long preemptedVcoreSeconds) |
static ApplicationAttemptStateData |
ApplicationAttemptStateData.newInstance(org.apache.hadoop.yarn.api.records.ApplicationAttemptId attemptId,
org.apache.hadoop.yarn.api.records.Container container,
org.apache.hadoop.security.Credentials attemptTokens,
long startTime,
RMAppAttemptState finalState,
String finalTrackingUrl,
String diagnostics,
org.apache.hadoop.yarn.api.records.FinalApplicationStatus amUnregisteredFinalStatus,
int exitStatus,
long finishTime,
long memorySeconds,
long vcoreSeconds,
long preemptedMemorySeconds,
long preemptedVcoreSeconds) |
Modifier and Type | Class and Description |
---|---|
class |
ApplicationAttemptStateDataPBImpl |
Copyright © 2017 Apache Software Foundation. All Rights Reserved.