public class PrintBolt extends Object implements backtype.storm.topology.IBasicBolt
| Constructor and Description |
|---|
PrintBolt() |
| Modifier and Type | Method and Description |
|---|---|
void |
cleanup() |
void |
declareOutputFields(backtype.storm.topology.OutputFieldsDeclarer declarer) |
void |
execute(backtype.storm.tuple.Tuple input,
backtype.storm.topology.BasicOutputCollector collector) |
Map<String,Object> |
getComponentConfiguration() |
void |
prepare(Map stormConf,
backtype.storm.task.TopologyContext context) |
public PrintBolt()
public void declareOutputFields(backtype.storm.topology.OutputFieldsDeclarer declarer)
declareOutputFields in interface backtype.storm.topology.IComponentpublic Map<String,Object> getComponentConfiguration()
getComponentConfiguration in interface backtype.storm.topology.IComponentpublic void prepare(Map stormConf, backtype.storm.task.TopologyContext context)
prepare in interface backtype.storm.topology.IBasicBoltpublic void execute(backtype.storm.tuple.Tuple input, backtype.storm.topology.BasicOutputCollector collector)
execute in interface backtype.storm.topology.IBasicBoltpublic void cleanup()
cleanup in interface backtype.storm.topology.IBasicBolt