nathanmarz/storm — Issue #43: Pluggable stream groupings
Author: nathanmarz
Created: 2011-11-10 19:20:28+00:00
State: open
Labels: New feature

Storm should expose an interface for creating custom stream groupings. A stream grouping function should have this signature:

List partition(Tuple tuple, int numTasks)

It returns the indices of the tasks (from 0 to numTasks - 1) to send the tuple to.

This feature could then be used to do things like this: https://github.com/nathanmarz/storm/issues/42