TumblingWindowTriggerArgs

data class TumblingWindowTriggerArgs(val annotations: Output<List<Any>>? = null, val delay: Output<Any>? = null, val dependsOn: Output<List<Any>>? = null, val description: Output<String>? = null, val endTime: Output<String>? = null, val frequency: Output<Either<String, TumblingWindowFrequency>>, val interval: Output<Int>, val maxConcurrency: Output<Int>, val pipeline: Output<TriggerPipelineReferenceArgs>, val retryPolicy: Output<RetryPolicyArgs>? = null, val startTime: Output<String>, val type: Output<String>) : ConvertibleToJava<TumblingWindowTriggerArgs>

Trigger that schedules pipeline runs for all fixed time interval windows from a start time without gaps and also supports backfill scenarios (when start time is in the past).

Constructors

Link copied to clipboard
constructor(annotations: Output<List<Any>>? = null, delay: Output<Any>? = null, dependsOn: Output<List<Any>>? = null, description: Output<String>? = null, endTime: Output<String>? = null, frequency: Output<Either<String, TumblingWindowFrequency>>, interval: Output<Int>, maxConcurrency: Output<Int>, pipeline: Output<TriggerPipelineReferenceArgs>, retryPolicy: Output<RetryPolicyArgs>? = null, startTime: Output<String>, type: Output<String>)

Properties

Link copied to clipboard
val annotations: Output<List<Any>>? = null

List of tags that can be used for describing the trigger.

Link copied to clipboard
val delay: Output<Any>? = null

Specifies how long the trigger waits past due time before triggering new run. It doesn't alter window start and end time. The default is 0. Type: string (or Expression with resultType string), pattern: ((\d+)\.)?(\d\d):(60|(0-9)):(60|(0-9)).

Link copied to clipboard
val dependsOn: Output<List<Any>>? = null

Triggers that this trigger depends on. Only tumbling window triggers are supported.

Link copied to clipboard
val description: Output<String>? = null

Trigger description.

Link copied to clipboard
val endTime: Output<String>? = null

The end time for the time period for the trigger during which events are fired for windows that are ready. Only UTC time is currently supported.

Link copied to clipboard

The frequency of the time windows.

Link copied to clipboard
val interval: Output<Int>

The interval of the time windows. The minimum interval allowed is 15 Minutes.

Link copied to clipboard
val maxConcurrency: Output<Int>

The max number of parallel time windows (ready for execution) for which a new run is triggered.

Link copied to clipboard

Pipeline for which runs are created when an event is fired for trigger window that is ready.

Link copied to clipboard
val retryPolicy: Output<RetryPolicyArgs>? = null

Retry policy that will be applied for failed pipeline runs.

Link copied to clipboard
val startTime: Output<String>

The start time for the time period for the trigger during which events are fired for windows that are ready. Only UTC time is currently supported.

Link copied to clipboard
val type: Output<String>

Trigger type. Expected value is 'TumblingWindowTrigger'.

Functions

Link copied to clipboard
open override fun toJava(): TumblingWindowTriggerArgs