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

Class AlwaysRestartPolicy

java.lang.Object

org.apache.hadoop.yarn.service.component.AlwaysRestartPolicy

All Implemented Interfaces:

ComponentRestartPolicy

public final class AlwaysRestartPolicy
extends Object
implements ComponentRestartPolicy

Always restart policy allows for restarts for long live components which never terminate.

Method Summary

Modifier and Type	Method	Description
boolean	allowContainerRetriesForInstance(ComponentInstance componentInstance)
boolean	allowUpgrades()
static AlwaysRestartPolicy	getInstance()
boolean	hasCompleted(Component component)	This is always false since these components never terminate
boolean	hasCompletedSuccessfully(Component component)	This is always false since these components never terminate
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 AlwaysRestartPolicy getInstance()

isLongLived

public boolean isLongLived()

Specified by:

isLongLived in interface ComponentRestartPolicy

hasCompleted

public boolean hasCompleted(Component component)

This is always false since these components never terminate

Specified by:

hasCompleted in interface ComponentRestartPolicy

Parameters:

component -

Returns:

hasCompletedSuccessfully

public boolean hasCompletedSuccessfully(Component component)

This is always false since these components never terminate

Specified by:

hasCompletedSuccessfully in interface ComponentRestartPolicy

Parameters:

component -

Returns:

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