Dear Wiki user, You have subscribed to a wiki page or wiki category on "Samza Wiki" for change notification.
The "Pluggable MessageChooser" page has been changed by ChrisRiccomini: https://wiki.apache.org/samza/Pluggable%20MessageChooser?action=diff&rev1=5&rev2=6 * Quality of service (if I've picked too many messages from topic X, don't pick from it for a while, so we don't starve other topics). * Round robin (just pick in a circular buffer) * Batching (pick 100 messages from stream X, then 100 messages from stream Y, etc). + + Let's look at how different strategies can enable different use cases. === Use cases === @@ -65, +67 @@ * @param envelope * An unprocessed envelope. */ - void update(!IncomingMessageEnvelope envelope); + void update(IncomingMessageEnvelope envelope); /** * The choose method is invoked when the SamzaContainer is ready to process a @@ -76, +78 @@ * @return The next envelope to process, or null if the chooser has no * messages or doesn't want to process any at the moment. */ - !IncomingMessageEnvelope choose(); + IncomingMessageEnvelope choose(); } }}}
