Delayed Response Operator

Delayed response operators help to collect data for a certain period of time or a specified number of messages until it processes all received input at once generating its output: single or multiple messages. Possible operator types are: aggregate or merge operators.

No matter what the concrete implementation provides, all operators of this type are executed from within an unique runtime environment. It receives all incoming messages, forwards them to the operator and keep track of running wait strategy which signals when to collect and forward computation results (zero or n messages).

To provide custom operators, each implementation must comply with the DelayedResponseOperator interface.

To learn how to build your own delayed response operator, please follow the steps as described in the linked tutorial.