When processing incoming events there are three modalities:
Processing a stream of events grouped by some arbitrary key (e.g. factory, state, etc), and performing time-window aggregates and delta functions over that subset of data
Processing a stream of events grouped by a device, and performing time-window aggregates and delta functions over that subset of data.
Processing a sequence of events group by a device, where each event triggers a potentially long-running business activity. May often require or involve per-device ordering semantics.
These then set the stage for implementation choices. For (3) call out the data pipeline code (and the docs). For (1) and (2), call out ASA.
When processing incoming events there are three modalities:
These then set the stage for implementation choices. For (3) call out the data pipeline code (and the docs). For (1) and (2), call out ASA.