org.apache.samza.task

Interface MessageCollector

public interface MessageCollector

Used as an interface for the means of sending message envelopes to an output stream.

A MessageCollector is provided on every call to StreamTask.process(org.apache.samza.system.IncomingMessageEnvelope, org.apache.samza.task.MessageCollector, org.apache.samza.task.TaskCoordinator) and WindowableTask.window(org.apache.samza.task.MessageCollector, org.apache.samza.task.TaskCoordinator). You must use those MessageCollector objects only within those method calls, and not hold on to a reference for use at any other time.

Method Summary

Modifier and Type	Method and Description
void	send(OutgoingMessageEnvelope envelope) Sends message envelope out onto specified stream.

Method Detail

send

void send(OutgoingMessageEnvelope envelope)

Sends message envelope out onto specified stream.

Parameters:

envelope - Self contained envelope containing message, key and specified stream to be sent to.