Code sample :
Topology :
===================================
TopologyBuilder builder = new TopologyBuilder();
builder.setSpout("epd-spout",new MyJmsSpout());
builder.setBolt("epd-CPY001-bolt1", new Bolt1("CPY001"),
parallelismHintMap.get("CPY001"))
.shuffleGrouping("epd-spout");
builder.setBolt("epd-CPY001-bolt2", new Bolt2("CPY001"),
parallelismHintMap.get("CPY001"))
.fieldsGrouping("epd-CPY001-bolt1", new Fields("Bolt1Tuple"));
Bolt1:
====================================
public void declareOutputFields(OutputFieldsDeclarer declarer) {
// TODO Auto-generated method stub
declarer.declare(new Fields("Bolt1Tuple"));
}
public void execute(Tuple input) {
Class1 class1Instance = (Class1)input.getValueByField("JmsSpoutTuple");
collector.emit(new Values(class1Instance));
}
Bolt2:
======================================
public void execute(Tuple input) {
Class1 class1Instance = (Class1)input.getValueByField("Bolt1Tuple");
}
On Mon, Mar 17, 2014 at 1:19 PM, Binita Bharati
<[email protected]> wrote:
> 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
