RerunTumblingWindowTrigger Class

public final class RerunTumblingWindowTrigger
extends Trigger

Trigger that schedules pipeline reruns for all fixed time interval windows from a requested start time to requested end time.

Constructor Summary

Constructor Description
RerunTumblingWindowTrigger()

Creates an instance of RerunTumblingWindowTrigger class.

Method Summary

Modifier and Type Method and Description
Object parentTrigger()

Get the parentTrigger property: The parent trigger reference.

OffsetDateTime requestedEndTime()

Get the requestedEndTime property: The end time for the time period for which restatement is initiated.

OffsetDateTime requestedStartTime()

Get the requestedStartTime property: The start time for the time period for which restatement is initiated.

int rerunConcurrency()

Get the rerunConcurrency property: The max number of parallel time windows (ready for execution) for which a rerun is triggered.

String type()

Get the type property: Trigger type.

void validate()

Validates the instance.

RerunTumblingWindowTrigger withAnnotations(List<Object> annotations)

Set the annotations property: List of tags that can be used for describing the trigger.

RerunTumblingWindowTrigger withDescription(String description)

Set the description property: Trigger description.

RerunTumblingWindowTrigger withParentTrigger(Object parentTrigger)

Set the parentTrigger property: The parent trigger reference.

RerunTumblingWindowTrigger withRequestedEndTime(OffsetDateTime requestedEndTime)

Set the requestedEndTime property: The end time for the time period for which restatement is initiated.

RerunTumblingWindowTrigger withRequestedStartTime(OffsetDateTime requestedStartTime)

Set the requestedStartTime property: The start time for the time period for which restatement is initiated.

RerunTumblingWindowTrigger withRerunConcurrency(int rerunConcurrency)

Set the rerunConcurrency property: The max number of parallel time windows (ready for execution) for which a rerun is triggered.

Methods inherited from Trigger

Methods inherited from java.lang.Object

Constructor Details

RerunTumblingWindowTrigger

public RerunTumblingWindowTrigger()

Creates an instance of RerunTumblingWindowTrigger class.

Method Details

parentTrigger

public Object parentTrigger()

Get the parentTrigger property: The parent trigger reference.

Returns:

the parentTrigger value.

requestedEndTime

public OffsetDateTime requestedEndTime()

Get the requestedEndTime property: The end time for the time period for which restatement is initiated. Only UTC time is currently supported.

Returns:

the requestedEndTime value.

requestedStartTime

public OffsetDateTime requestedStartTime()

Get the requestedStartTime property: The start time for the time period for which restatement is initiated. Only UTC time is currently supported.

Returns:

the requestedStartTime value.

rerunConcurrency

public int rerunConcurrency()

Get the rerunConcurrency property: The max number of parallel time windows (ready for execution) for which a rerun is triggered.

Returns:

the rerunConcurrency value.

type

public String type()

Get the type property: Trigger type.

Overrides:

RerunTumblingWindowTrigger.type()

Returns:

the type value.

validate

public void validate()

Validates the instance.

Overrides:

RerunTumblingWindowTrigger.validate()

withAnnotations

public RerunTumblingWindowTrigger withAnnotations(List annotations)

Set the annotations property: List of tags that can be used for describing the trigger.

Overrides:

RerunTumblingWindowTrigger.withAnnotations(List<Object> annotations)

Parameters:

annotations

withDescription

public RerunTumblingWindowTrigger withDescription(String description)

Set the description property: Trigger description.

Overrides:

RerunTumblingWindowTrigger.withDescription(String description)

Parameters:

description

withParentTrigger

public RerunTumblingWindowTrigger withParentTrigger(Object parentTrigger)

Set the parentTrigger property: The parent trigger reference.

Parameters:

parentTrigger - the parentTrigger value to set.

Returns:

the RerunTumblingWindowTrigger object itself.

withRequestedEndTime

public RerunTumblingWindowTrigger withRequestedEndTime(OffsetDateTime requestedEndTime)

Set the requestedEndTime property: The end time for the time period for which restatement is initiated. Only UTC time is currently supported.

Parameters:

requestedEndTime - the requestedEndTime value to set.

Returns:

the RerunTumblingWindowTrigger object itself.

withRequestedStartTime

public RerunTumblingWindowTrigger withRequestedStartTime(OffsetDateTime requestedStartTime)

Set the requestedStartTime property: The start time for the time period for which restatement is initiated. Only UTC time is currently supported.

Parameters:

requestedStartTime - the requestedStartTime value to set.

Returns:

the RerunTumblingWindowTrigger object itself.

withRerunConcurrency

public RerunTumblingWindowTrigger withRerunConcurrency(int rerunConcurrency)

Set the rerunConcurrency property: The max number of parallel time windows (ready for execution) for which a rerun is triggered.

Parameters:

rerunConcurrency - the rerunConcurrency value to set.

Returns:

the RerunTumblingWindowTrigger object itself.

Applies to