Helper interface attached to an underlying system to fetch information about streams, partitions, offsets, etc.
SystemConsumer is the interface that must be implemented by any system that wishes to integrate with Samza.
SystemProducers are how Samza writes messages from
The abstract class of all control messages, containing the task that produces the control message, the total number of producer tasks, and a version number.
The DrainMessage is a control message that is sent out to next stage once the task has consumed to the end of a bounded stream.
The EndOfStreamMessage is a control message that is sent out to next stage once the task has consumed to the end of a bounded stream.
This class represents a message envelope that is received by a StreamTask for each message that is received from a partition of a specific input stream.
StreamSpec is a blueprint for creating, validating, or simply describing a stream in the runtime environment.
Streams in Samza consist of both the stream name and the system to which the stream belongs.
SystemAdmins use this class to return useful metadata about a stream's offset and partition information.
Provides offset information for a given SystemStreamPartition.
The WatermarkMessage is a control message that is sent out to next stage with a watermark timestamp and the task that produces the watermark.
The type of the intermediate stream message.
OffsetType is an enum used to define which offset should be used when reading from a SystemStreamPartition for the first time.