joocer / cronicl

cronicl: data pipelines.
Apache License 2.0
0 stars 0 forks source link

Create a Collector Stage pattern #24

Closed joocer closed 4 years ago

joocer commented 4 years ago

Collectors will collate information across multiple messages (for example to calculate the maximum) and then emit the result on an EMIT message.

Collectors should reset their counters on a RESET message.