How to built trident topology which will persist tuples in HBase?

[Chandrashekhar Kotekar]

Hi,

I want to build a trident topology which will get tuples from Kafka, group
them by one field and persist entire grouped tuples in HBase. I have
written following code but not sure where should I write code which will
convert all tuples into HBase 'Put' type objects and persist all those Put
objects in HBase. Can anyone please help me?

        OpaqueTridentKafkaSpout kafkaTridentSpout = new
OpaqueTridentKafkaSpout(spoutConfig);
        TridentTopology topology = new TridentTopology();
        topology.newStream("stream", kafkaTridentSpout)
                                     .groupBy(new Fields("pointId"))
                                     .toStream();
        topology.build();

Regards,
Chandrash3khar Kotekar
Mobile - +91 8600011455