Github user arunmahadevan commented on the issue:
https://github.com/apache/storm/pull/1693
@revans2
A few basic examples are
[here](https://github.com/arunmahadevan/storm/tree/9cc722194f30470eddba1b2257bab6ea5444ee94/examples/storm-starter/src/jvm/org/apache/storm/starter/streams).
Will add more examples, a Readme and api documentation, but I have very
less free cycles to work on it right now, so will take some more time.
I also pushed a commit to change the groupBy semantics so that it returns a
pair of `key, Iterable<V>`. The aggregation operations on key now does an
automatic partitioning on the key (unless the stream is already partitioned by
key). Examples are updated to reflect the same.
I will raise follow up tasks to add additional examples and apis like
cogroup, transform and so on which I think would be useful. I plan to work on
it incrementally when I get time, but if someone in the community wants to
contribute, I will be happy to help.
@HeartSaVioR thanks for your inputs I also added Typed tuples (upto Tuple10
for now), see
[TypedTupleExample](https://github.com/arunmahadevan/storm/blob/9cc722194f30470eddba1b2257bab6ea5444ee94/examples/storm-starter/src/jvm/org/apache/storm/starter/streams/TypedTupleExample.java)
for usage.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
