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