Tumbling Window Trigger Args
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
List of tags that can be used for describing the trigger.
Link copied to clipboard
Link copied to clipboard
Trigger description.
Link copied to clipboard
The frequency of the time windows.
Link copied to clipboard
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
Retry policy that will be applied for failed pipeline runs.