| Interface | Description |
|---|---|
| MessageStream<M> |
A stream of messages that can be transformed into another
MessageStream. |
| OutputStream<M> |
An output stream to send messages to.
|
| Scheduler<K> |
Allows scheduling
ScheduledFunction callbacks to be invoked later. |
| Class | Description |
|---|---|
| KV<K,V> |
A key and value pair.
|
| UpdateMessage<U,V> |
Represents an update and an optional default record to be inserted for a key,
if the update is applied to a non-existent record.
|
| Enum | Description |
|---|---|
| UpdateOptions |
This class defines the update contract used in the send-to-table-with-update operator.
|