nathanmarz/storm — Issue #42: Field grouping by object's field?
Author: killme2008
Created: 2011-11-10 10:09:11+00:00
State: open

Hi,

I have a my own class Message ,and i have implemented my own Serialization for this class,so i can put this class's instances into tuple and use it in bolts.

But i have a problem, when i want to declare field grouping by a field in this class,it throw exception.
For example, i declare the Message class as "message" field in spout, and the message has a field named "appId",i want to group events by message.appId,i did it by:

builder.setBolt(2, new LogBolt()).fieldsGrouping(1, new Fields("message.appId"));

It doesn't work in storm now. But in yahoo! s4,we can set key like this.

I think storm implements this feature is very simple ,just using reflection to read filed's value and group events by that.Will you implement this feature?

Forgive my poor english, i don't know if i describe it clearly.