Hi ,

I have a Bolt1 that emits a tuple of type a.b.c.MyClass1. MyClass1 has
a String field - class1Key1.
I need to segregate all tuples having same value for
a.b.c.MyClass1:class1Key1 into a specific task in another Bolt2.

How do I go about defining such a topology ? I have seen egs where
tuples emitted were simple string values. But, my emitted tuple is a
Class instance , and the field on which I want to do fieldGrouping is
a particular field of that Class.

(I tried defining a equals and hashcode method in a.b.c.MyClass1.
Didn't work as expected..)

Thanks
Binita

Reply via email to