Package org.apache.hadoop.yarn.service.component

Class OnFailureRestartPolicy

java.lang.Object

org.apache.hadoop.yarn.service.component.OnFailureRestartPolicy

All Implemented Interfaces:

ComponentRestartPolicy

public final class OnFailureRestartPolicy
extends Object
implements ComponentRestartPolicy

Policy for components that require restarts for instances on failure.

Method Summary

Modifier and Type	Method	Description
boolean	allowContainerRetriesForInstance(ComponentInstance componentInstance)
boolean	allowUpgrades()
static OnFailureRestartPolicy	getInstance()
boolean	hasCompleted(Component component)
boolean	hasCompletedSuccessfully(Component component)
boolean	isLongLived()
boolean	isReadyForDownStream(Component dependentComponent)
boolean	shouldRelaunchInstance(ComponentInstance componentInstance, org.apache.hadoop.yarn.api.records.ContainerStatus containerStatus)
boolean	shouldTerminate(Component component)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

getInstance

public static OnFailureRestartPolicy getInstance()

isLongLived

public boolean isLongLived()

Specified by:

isLongLived in interface ComponentRestartPolicy

hasCompleted

public boolean hasCompleted(Component component)

Specified by:

hasCompleted in interface ComponentRestartPolicy

hasCompletedSuccessfully

public boolean hasCompletedSuccessfully(Component component)

Specified by:

hasCompletedSuccessfully in interface ComponentRestartPolicy

shouldRelaunchInstance

public boolean shouldRelaunchInstance(ComponentInstance componentInstance,
 org.apache.hadoop.yarn.api.records.ContainerStatus containerStatus)

Specified by:

shouldRelaunchInstance in interface ComponentRestartPolicy

isReadyForDownStream

public boolean isReadyForDownStream(Component dependentComponent)

Specified by:

isReadyForDownStream in interface ComponentRestartPolicy

allowUpgrades

public boolean allowUpgrades()

Specified by:

allowUpgrades in interface ComponentRestartPolicy

shouldTerminate

public boolean shouldTerminate(Component component)

Specified by:

shouldTerminate in interface ComponentRestartPolicy

allowContainerRetriesForInstance

public boolean allowContainerRetriesForInstance(ComponentInstance componentInstance)

Specified by:

allowContainerRetriesForInstance in interface ComponentRestartPolicy