MessageCollector (samza-api 1.9.0-SNAPSHOT API)
JavaScript is disabled on your browser.
Skip navigation links
Overview
Package
Class
Tree
Deprecated
Index
Help
Prev Class
Next Class
Frames
No Frames
All Classes
Summary: 
Nested | 
Field | 
Constr | 
Method
Detail: 
Field | 
Constr | 
Method
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
All Methods Instance Methods Abstract Methods 
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.
Skip navigation links
Overview
Package
Class
Tree
Deprecated
Index
Help
Prev Class
Next Class
Frames
No Frames
All Classes
Summary: 
Nested | 
Field | 
Constr | 
Method
Detail: 
Field | 
Constr | 
Method