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.IComponent
public Map<String,Object> getComponentConfiguration()
getComponentConfiguration
in interface backtype.storm.topology.IComponent
public void prepare(Map stormConf, backtype.storm.task.TopologyContext context)
prepare
in interface backtype.storm.topology.IBasicBolt
public void execute(backtype.storm.tuple.Tuple input, backtype.storm.topology.BasicOutputCollector collector)
execute
in interface backtype.storm.topology.IBasicBolt
public void cleanup()
cleanup
in interface backtype.storm.topology.IBasicBolt