TumblingWindowTrigger Class
- java.
lang. Object - com.
azure. resourcemanager. datafactory. models. Trigger - com.
azure. resourcemanager. datafactory. models. TumblingWindowTrigger
- com.
- com.
public final class TumblingWindowTrigger
extends Trigger
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).
Constructor Summary
| Constructor | Description |
|---|---|
| TumblingWindowTrigger() |
Creates an instance of Tumbling |
Method Summary
| Modifier and Type | Method and Description |
|---|---|
| Object |
delay()
Get the delay property: Specifies how long the trigger waits past due time before triggering new run. |
|
List<Dependency |
dependsOn()
Get the depends |
|
Offset |
endTime()
Get the end |
|
Tumbling |
frequency()
Get the frequency property: The frequency of the time windows. |
|
static
Tumbling |
fromJson(JsonReader jsonReader)
Reads an instance of Tumbling |
| int |
interval()
Get the interval property: The interval of the time windows. |
| int |
maxConcurrency()
Get the max |
|
Trigger |
pipeline()
Get the pipeline property: Pipeline for which runs are created when an event is fired for trigger window that is ready. |
|
Retry |
retryPolicy()
Get the retry |
|
Offset |
startTime()
Get the start |
|
Json |
toJson(JsonWriter jsonWriter) |
| String |
type()
Get the type property: Trigger type. |
| void |
validate()
Validates the instance. |
|
Tumbling |
withAnnotations(List<Object> annotations)
Set the annotations property: List of tags that can be used for describing the trigger. |
|
Tumbling |
withDelay(Object delay)
Set the delay property: Specifies how long the trigger waits past due time before triggering new run. |
|
Tumbling |
withDependsOn(List<DependencyReference> dependsOn)
Set the depends |
|
Tumbling |
withDescription(String description)
Set the description property: Trigger description. |
|
Tumbling |
withEndTime(OffsetDateTime endTime)
Set the end |
|
Tumbling |
withFrequency(TumblingWindowFrequency frequency)
Set the frequency property: The frequency of the time windows. |
|
Tumbling |
withInterval(int interval)
Set the interval property: The interval of the time windows. |
|
Tumbling |
withMaxConcurrency(int maxConcurrency)
Set the max |
|
Tumbling |
withPipeline(TriggerPipelineReference pipeline)
Set the pipeline property: Pipeline for which runs are created when an event is fired for trigger window that is ready. |
|
Tumbling |
withRetryPolicy(RetryPolicy retryPolicy)
Set the retry |
|
Tumbling |
withStartTime(OffsetDateTime startTime)
Set the start |
Methods inherited from Trigger
Methods inherited from java.lang.Object
Constructor Details
TumblingWindowTrigger
public TumblingWindowTrigger()
Creates an instance of TumblingWindowTrigger class.
Method Details
delay
public Object delay()
Get the delay property: 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-5][0-9])):(60|([0-5][0-9])).
Returns:
dependsOn
public List<DependencyReference> dependsOn()
Get the dependsOn property: Triggers that this trigger depends on. Only tumbling window triggers are supported.
Returns:
endTime
public OffsetDateTime endTime()
Get the endTime property: 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.
Returns:
frequency
public TumblingWindowFrequency frequency()
Get the frequency property: The frequency of the time windows.
Returns:
fromJson
public static TumblingWindowTrigger fromJson(JsonReader jsonReader)
Reads an instance of TumblingWindowTrigger from the JsonReader.
Parameters:
Returns:
Throws:
interval
public int interval()
Get the interval property: The interval of the time windows. The minimum interval allowed is 15 Minutes.
Returns:
maxConcurrency
public int maxConcurrency()
Get the maxConcurrency property: The max number of parallel time windows (ready for execution) for which a new run is triggered.
Returns:
pipeline
public TriggerPipelineReference pipeline()
Get the pipeline property: Pipeline for which runs are created when an event is fired for trigger window that is ready.
Returns:
retryPolicy
public RetryPolicy retryPolicy()
Get the retryPolicy property: Retry policy that will be applied for failed pipeline runs.
Returns:
startTime
public OffsetDateTime startTime()
Get the startTime property: 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.
Returns:
toJson
public JsonWriter toJson(JsonWriter jsonWriter)
Overrides:
TumblingWindowTrigger.toJson(JsonWriter jsonWriter)Parameters:
Throws:
type
public String type()
Get the type property: Trigger type.
Overrides:
TumblingWindowTrigger.type()Returns:
validate
public void validate()
Validates the instance.
Overrides:
TumblingWindowTrigger.validate()withAnnotations
public TumblingWindowTrigger withAnnotations(List<Object> annotations)
Set the annotations property: List of tags that can be used for describing the trigger.
Overrides:
TumblingWindowTrigger.withAnnotations(List<Object> annotations)Parameters:
withDelay
public TumblingWindowTrigger withDelay(Object delay)
Set the delay property: 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-5][0-9])):(60|([0-5][0-9])).
Parameters:
Returns:
withDependsOn
public TumblingWindowTrigger withDependsOn(List<DependencyReference> dependsOn)
Set the dependsOn property: Triggers that this trigger depends on. Only tumbling window triggers are supported.
Parameters:
Returns:
withDescription
public TumblingWindowTrigger withDescription(String description)
Set the description property: Trigger description.
Overrides:
TumblingWindowTrigger.withDescription(String description)Parameters:
withEndTime
public TumblingWindowTrigger withEndTime(OffsetDateTime endTime)
Set the endTime property: 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.
Parameters:
Returns:
withFrequency
public TumblingWindowTrigger withFrequency(TumblingWindowFrequency frequency)
Set the frequency property: The frequency of the time windows.
Parameters:
Returns:
withInterval
public TumblingWindowTrigger withInterval(int interval)
Set the interval property: The interval of the time windows. The minimum interval allowed is 15 Minutes.
Parameters:
Returns:
withMaxConcurrency
public TumblingWindowTrigger withMaxConcurrency(int maxConcurrency)
Set the maxConcurrency property: The max number of parallel time windows (ready for execution) for which a new run is triggered.
Parameters:
Returns:
withPipeline
public TumblingWindowTrigger withPipeline(TriggerPipelineReference pipeline)
Set the pipeline property: Pipeline for which runs are created when an event is fired for trigger window that is ready.
Parameters:
Returns:
withRetryPolicy
public TumblingWindowTrigger withRetryPolicy(RetryPolicy retryPolicy)
Set the retryPolicy property: Retry policy that will be applied for failed pipeline runs.
Parameters:
Returns:
withStartTime
public TumblingWindowTrigger withStartTime(OffsetDateTime startTime)
Set the startTime property: 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.
Parameters:
Returns:
