Search Java Classes and Packages
#Org.apache.samza.system Classes and Interfaces - 15 results found.
| Name | Description | Type | Package | Framework |
| BaseMessageChooser | An abstract MessageChooser that implements start/stop/register for choosers that don't use them. | Class | org.apache.samza.system.chooser | Apache Samza |
| IncomingMessageEnvelope | 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. | Class | org.apache.samza.system | Apache Samza |
| MessageChooser | MessageChooser is an interface for programmatic fine-grain control over stream consumption. | Interface | org.apache.samza.system.chooser | Apache Samza |
| MessageChooserFactory | Interface | org.apache.samza.system.chooser | Apache Samza | |
| OutgoingMessageEnvelope | An OutgoingMessageEnvelope is sent to a specified SystemStream via the appropriate SystemProducer from the user's StreamTask. | Class | org.apache.samza.system | Apache Samza |
| SystemAdmin | Helper interface attached to an underlying system to fetch information about streams, partitions, offsets, etc. | Interface | org.apache.samza.system | Apache Samza |
| SystemConsumer | SystemConsumer is the interface that must be implemented by any system that wishes to integrate with Samza. | Interface | org.apache.samza.system | Apache Samza |
| SystemFactory | Build the SystemConsumer and SystemProducer for a particular system, as well as the accompanying SystemAdmin. | Interface | org.apache.samza.system | Apache Samza |
| SystemProducer | SystemProducers are how Samza writes messages from StreamTasks to outside systems, such as messaging systems like Kafka, or file systems. | Interface | org.apache.samza.system | Apache Samza |
| SystemStream | Streams in Samza consist of both the stream name and the system to which the stream belongs. | Class | org.apache.samza.system | Apache Samza |
| SystemStreamMetadata | SystemAdmins use this class to return useful metadata about a stream's offset and partition information. | Class | org.apache.samza.system | Apache Samza |
| SystemStreamMetadata .OffsetType | OffsetType is an enum used to define which offset should be used when reading from a SystemStreamPartition for the first time. | Class | org.apache.samza.system.SystemStreamMetadata | Apache Samza |
| SystemStreamMetadata .SystemStreamPartitionMetadata | Provides offset information for a given SystemStreamPartition. | Class | org.apache.samza.system.SystemStreamMetadata | Apache Samza |
| SystemStreamPartition | Aggregate object representing a both the SystemStream and Partition. | Class | org.apache.samza.system | Apache Samza |
| SystemStreamPartitionIterator | Iterator that wraps a SystemConsumer to iterate over the messages the consumer provides for the specified SystemStreamPartition. | Class | org.apache.samza.system | Apache Samza |