A function that can be closed after its execution.
Specifies whether a message should be retained for further processing.
Transforms an input message into a collection of 0 or more messages, possibly of a different type.
Incrementally updates the aggregated value as messages are added.
A function that can be initialized before execution.
Joins incoming messages in two streams by key.
Transforms an input message into another message, possibly of a different type.
Allows sending a message to an output system.
Joins incoming messages with records from a table by the join key.
A supplier to return a new value at each invocation
Allows timer registration with a key and is invoked when the timer is fired.
Allows handling of watermarks.