Search Java Classes and Packages

Search Java Frameworks and Libraries

255581 classes and counting ...
Search Tips Index Status



#Org.apache.samza.system Classes and Interfaces - 15 results found.
NameDescriptionTypePackageFramework
BaseMessageChooserAn abstract MessageChooser that implements start/stop/register for choosers that don't use them.Classorg.apache.samza.system.chooserApache Samza
IncomingMessageEnvelopeThis 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.Classorg.apache.samza.systemApache Samza
MessageChooserMessageChooser is an interface for programmatic fine-grain control over stream consumption.Interfaceorg.apache.samza.system.chooserApache Samza
MessageChooserFactoryInterfaceorg.apache.samza.system.chooserApache Samza
OutgoingMessageEnvelopeAn OutgoingMessageEnvelope is sent to a specified SystemStream via the appropriate SystemProducer from the user's StreamTask.Classorg.apache.samza.systemApache Samza
SystemAdminHelper interface attached to an underlying system to fetch information about streams, partitions, offsets, etc.Interfaceorg.apache.samza.systemApache Samza
SystemConsumer SystemConsumer is the interface that must be implemented by any system that wishes to integrate with Samza.Interfaceorg.apache.samza.systemApache Samza
SystemFactoryBuild the SystemConsumer and SystemProducer for a particular system, as well as the accompanying SystemAdmin.Interfaceorg.apache.samza.systemApache Samza
SystemProducerSystemProducers are how Samza writes messages from StreamTasks to outside systems, such as messaging systems like Kafka, or file systems.Interfaceorg.apache.samza.systemApache Samza
SystemStreamStreams in Samza consist of both the stream name and the system to which the stream belongs.Classorg.apache.samza.systemApache Samza
SystemStreamMetadataSystemAdmins use this class to return useful metadata about a stream's offset and partition information.Classorg.apache.samza.systemApache Samza
SystemStreamMetadata .OffsetTypeOffsetType is an enum used to define which offset should be used when reading from a SystemStreamPartition for the first time.Classorg.apache.samza.system.SystemStreamMetadataApache Samza
SystemStreamMetadata .SystemStreamPartitionMetadataProvides offset information for a given SystemStreamPartition.Classorg.apache.samza.system.SystemStreamMetadataApache Samza
SystemStreamPartitionAggregate object representing a both the SystemStream and Partition.Classorg.apache.samza.systemApache Samza
SystemStreamPartitionIteratorIterator that wraps a SystemConsumer to iterate over the messages the consumer provides for the specified SystemStreamPartition.Classorg.apache.samza.systemApache Samza