M
- type of the input MessageEnvelope
@InterfaceStability.Unstable @FunctionalInterface public interface SinkFunction<M extends MessageEnvelope>
MessageEnvelope
to an output system.Modifier and Type | Method and Description |
---|---|
void |
apply(M message,
MessageCollector messageCollector,
TaskCoordinator taskCoordinator)
Allows sending the provided
MessageEnvelope to an output SystemStream using
the provided MessageCollector . |
void apply(M message, MessageCollector messageCollector, TaskCoordinator taskCoordinator)
MessageEnvelope
to an output SystemStream
using
the provided MessageCollector
. Also provides access to the TaskCoordinator
to request commits
or shut the container down.message
- the MessageEnvelope
to be sent to an output SystemStream
messageCollector
- the MessageCollector
to use to send the MessageEnvelope
taskCoordinator
- the TaskCoordinator
to request commits or shutdown