Search Java Classes and Packages
Search Java Frameworks and Libraries
#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 |