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 |
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 | |