Skip to content

Delta

Delta (delta)

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

Stateful Transform json

Minimal example

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

Contents

Behaviour

Behaviour
FieldTypeRequiredDescription
only-changesboolean (bool)Only emit deltas when the watched field changes.
Default: false

General

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

Input

Input
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

Output
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