Class ResubmissionDestination

java.lang.Object

co.yellowdog.platform.model.ResubmissionDestination

All Implemented Interfaces:

Serializable

public class ResubmissionDestination
extends Object
implements Serializable

A destination to which TaskStatus.FAILED tasks can be resubmitted.

See Also:

• FailurePolicy
• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ResubmissionDestination.Builder

Constructor Summary

Constructors

Constructor	Description
ResubmissionDestination(String destinationTaskGroup, Selection<TaskErrorSelector> resubmitErrors)	Creates a new ResubmissionDestination instance.

Method Summary

Modifier and Type	Method	Description
static ResubmissionDestination.Builder	builder()
static ResubmissionDestination	destination(String destinationTaskGroup)	Create a ResubmissionDestination that will resubmit all TaskStatus.FAILED Tasks to the destination TaskGroup.
static ResubmissionDestination	destination(String destinationTaskGroup, Selection<TaskErrorSelector> resubmitErrors)	Create a ResubmissionDestination that will resubmit TaskStatus.FAILED Tasks that match the Selection to the destination TaskGroup.
String	getDestinationTaskGroup()	Name of the TaskGroup to which any matching TaskStatus.FAILED tasks should be resubmitted.
Selection<TaskErrorSelector>	getResubmitErrors()	Optional Selection to determine which Tasks are eligible to be resubmitted to the to destination TaskGroup.

Methods inherited from class Object

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

Constructor Details

ResubmissionDestination

public ResubmissionDestination(String destinationTaskGroup,
 Selection<TaskErrorSelector> resubmitErrors)

Creates a new ResubmissionDestination instance.

Parameters:

destinationTaskGroup - Name of the TaskGroup to which any matching TaskStatus.FAILED tasks should be resubmitted.

resubmitErrors - Optional Selection to determine which Tasks are eligible to be resubmitted to the to destination TaskGroup. If no Selection is specified, all errors will match. Make sure to only omit resubmitErrors if this is the last ResubmissionDestination in the FailurePolicy, otherwise and proceeding ResubmissionDestinations will be unreachable.

The TaskErrorSelector will be applied to the last seen error.

Method Details

destination

public static ResubmissionDestination destination(String destinationTaskGroup)

Create a ResubmissionDestination that will resubmit all TaskStatus.FAILED Tasks to the destination TaskGroup.

Parameters:

destinationTaskGroup - Name of the TaskGroup to which to resubmit the TaskStatus.FAILED Tasks

Returns:

The ResubmissionDestination

See Also:

• destination(String, Selection)

destination

public static ResubmissionDestination destination(String destinationTaskGroup,
 Selection<TaskErrorSelector> resubmitErrors)

Create a ResubmissionDestination that will resubmit TaskStatus.FAILED Tasks that match the Selection to the destination TaskGroup.

Parameters:

destinationTaskGroup - Name of the TaskGroup to which to resubmit the TaskStatus.FAILED Tasks

resubmitErrors - Optional Selection to determine which Tasks are eligible to be resubmitted to the to destination TaskGroup

Returns:

The ResubmissionDestination

See Also:

• destination(String)

builder

public static ResubmissionDestination.Builder builder()

getDestinationTaskGroup

public String getDestinationTaskGroup()

Name of the TaskGroup to which any matching TaskStatus.FAILED tasks should be resubmitted.

getResubmitErrors

public Selection<TaskErrorSelector> getResubmitErrors()

Optional Selection to determine which Tasks are eligible to be resubmitted to the to destination TaskGroup. If no Selection is specified, all errors will match. Make sure to only omit resubmitErrors if this is the last ResubmissionDestination in the FailurePolicy, otherwise and proceeding ResubmissionDestinations will be unreachable.

The TaskErrorSelector will be applied to the last seen error.