Heartbeat detection

Supported in: Streaming

Detects when a record hasn't been seen for a configurable amount of time for a set of keys.

Transform categories: Other

Declared arguments

  • Dataset - Input dataset.
    Table
  • Heartbeat time unit - Unit for amount of time to wait for data for a particular key.
    Enum<Days, Hours, Milliseconds, Minutes, Seconds, Weeks>
  • Heartbeat time value - Value for the amount of time to wait for data from a particular key.
    Literal<Long>
  • Partition by columns - Set of columns to use as keys for detecting heartbeats.
    Set<Column<AnyType>>