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. |
initclosevoid 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 SystemStreammessageCollector - the MessageCollector to send the messagetaskCoordinator - the TaskCoordinator to request commits or shutdown