Interface | Description |
---|---|
FilterFunction<M> |
Specifies whether a message should be retained for further processing.
|
FlatMapFunction<M,OM> |
Transforms an input message into a collection of 0 or more messages, possibly of a different type.
|
FoldLeftFunction<M,WV> |
Incrementally updates the window value as messages are added to the window.
|
InitableFunction |
A function that can be initialized before execution.
|
JoinFunction<K,M,JM,RM> |
Joins incoming messages in two streams by key.
|
MapFunction<M,OM> |
Transforms an input message into another message, possibly of a different type.
|
SinkFunction<M> |
Allows sending a message to an output system.
|