public class PartitionDataBolt
extends org.apache.storm.topology.base.BaseBasicBolt
<hash(selector), dataPartitions>
Currently receives a <hash(selector), JSON data record>
as input.
Constructor and Description |
---|
PartitionDataBolt() |
Modifier and Type | Method and Description |
---|---|
void |
declareOutputFields(org.apache.storm.topology.OutputFieldsDeclarer outputFieldsDeclarer) |
void |
execute(org.apache.storm.tuple.Tuple tuple,
org.apache.storm.topology.BasicOutputCollector outputCollector) |
void |
prepare(java.util.Map map,
org.apache.storm.task.TopologyContext context) |
public void prepare(java.util.Map map, org.apache.storm.task.TopologyContext context)
prepare
in interface org.apache.storm.topology.IBasicBolt
prepare
in class org.apache.storm.topology.base.BaseBasicBolt
public void execute(org.apache.storm.tuple.Tuple tuple, org.apache.storm.topology.BasicOutputCollector outputCollector)
public void declareOutputFields(org.apache.storm.topology.OutputFieldsDeclarer outputFieldsDeclarer)