org.apache.samza.operators.functions

Interface SinkFunction<M>

Type Parameters:

M - type of the input message

All Superinterfaces:

ClosableFunction, InitableFunction, java.io.Serializable

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@InterfaceStability.Unstable
 @FunctionalInterface
public interface SinkFunction<M>
extends InitableFunction, ClosableFunction, java.io.Serializable

Allows sending a message to an output system.

Method Summary

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.

Methods inherited from interface org.apache.samza.operators.functions.InitableFunction

init

Methods inherited from interface org.apache.samza.operators.functions.ClosableFunction

close

Method Detail

apply

void apply(M message,
           MessageCollector messageCollector,
           TaskCoordinator taskCoordinator)

Allows sending the provided message to an output SystemStream using the provided MessageCollector. Also provides access to the TaskCoordinator to request commits or shut the container down.

Parameters:

message - the input message to be sent to an output SystemStream

messageCollector - the MessageCollector to send the message

taskCoordinator - the TaskCoordinator to request commits or shutdown