Package org.apache.samza.operators

Interface Summary

Interface	Description
MessageStream<M extends MessageEnvelope>	Represents a stream of MessageEnvelopes.
StreamOperatorTask	A StreamOperatorTask is the basic interface to implement for processing MessageStreams.