Skip to content

Delta

Delta (delta)

Convenience wrapper that enables stream delta mode with a slim option set.

Transform json

Minimal example

actions:
- delta:
watch: ""
JSON
{
"actions": [
{
"delta": {
"watch": ""
}
}
]
}

Contents

Fields

FieldTypeRequiredDescription
watch Inputfield (string)Field whose numeric value should be differenced.
Examples: data_field
description GeneralstringDescribe this step.
condition Generallua-expression (string)Only run this action when the Lua condition evaluates to true.
Examples: 2 * count()
marker OutputstringOptional marker applied to emitted delta events.
group-by Inputfield (string)Group state independently per key.
Examples: data_field
input-time Inputfield (string)Field containing event time for elapsed calculations.
Examples: data_field
output-field Outputfield (string)Field name where the delta is written.
Examples: data_field
elapsed-field Outputfield (string)Field name where elapsed milliseconds are written.
Examples: data_field
only-changes Behaviourboolean (bool)Only emit deltas when the watched field changes.

General

Show fields
FieldTypeRequiredDescription
descriptionstringDescribe this step.
conditionlua-expression (string)Only run this action when the Lua condition evaluates to true.
Examples: 2 * count()

Input

Show fields
FieldTypeRequiredDescription
watchfield (string)Field whose numeric value should be differenced.
Examples: data_field
group-byfield (string)Group state independently per key.
Examples: data_field
input-timefield (string)Field containing event time for elapsed calculations.
Examples: data_field

Output

Show fields
FieldTypeRequiredDescription
markerstringOptional marker applied to emitted delta events.
output-fieldfield (string)Field name where the delta is written.
Examples: data_field
elapsed-fieldfield (string)Field name where elapsed milliseconds are written.
Examples: data_field

Behaviour

Show fields
FieldTypeRequiredDescription
only-changesboolean (bool)Only emit deltas when the watched field changes.