org.apache.samza.operators.functions

Interface SinkFunction<M extends MessageEnvelope>

Type Parameters:

M - type of the input MessageEnvelope

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 MessageEnvelope>

A function that allows sending a MessageEnvelope to an output system.

Method Summary

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.

Method Detail

apply

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

Allows sending the provided MessageEnvelope 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 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