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.IBasicBoltprepare in class org.apache.storm.topology.base.BaseBasicBoltpublic void execute(org.apache.storm.tuple.Tuple tuple,
org.apache.storm.topology.BasicOutputCollector outputCollector)
public void declareOutputFields(org.apache.storm.topology.OutputFieldsDeclarer outputFieldsDeclarer)