Как построить топологию Storm Trident, которая будет сохранять кортежи в HBase

Я хочу построить топологию трезубца, которая будет получать кортежи из Kafka, группировать их по одному полю и сохранять целые сгруппированные кортежи в HBase. Причина группировки заключается в том, что операции размещения HBase выполняются быстрее с несколькими объектами размещения по сравнению с размещением одного объекта, я хочу сгруппировать объекты Put по одному полю и вставить все эти объекты Put в один вызов API HBase.

Я написал следующий код, но не уверен, где мне написать код, который преобразует все кортежи в объекты типа "Put" HBase и сохраняет все эти объекты Put в HBase.

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

Кто-нибудь может мне помочь, пожалуйста!