| Interface | Description |
|---|---|
| ContextManager |
Manages custom context that is shared across multiple operator functions in a task.
|
| MessageStream<M> |
A stream of messages that can be transformed into another
MessageStream. |
| OutputStream<K,V,M> |
An output stream to send messages to.
|
| StreamGraph |
Provides access to
MessageStreams and OutputStreams used to describe the processing logic. |