public abstract class AbstractBoltSink extends Object implements backtype.storm.topology.IRichBolt
(a1, a2, ..., an)
with Object.toString()
for each attribute).Constructor and Description |
---|
AbstractBoltSink(OutputFormatter formatter) |
Modifier and Type | Method and Description |
---|---|
void |
cleanup() |
void |
declareOutputFields(backtype.storm.topology.OutputFieldsDeclarer declarer) |
void |
execute(backtype.storm.tuple.Tuple input) |
Map<String,Object> |
getComponentConfiguration() |
void |
prepare(Map stormConf,
backtype.storm.task.TopologyContext context,
backtype.storm.task.OutputCollector collector) |
protected abstract void |
prepareSimple(Map<?,?> stormConf,
backtype.storm.task.TopologyContext context) |
protected abstract void |
writeExternal(String line) |
public AbstractBoltSink(OutputFormatter formatter)
public final void prepare(Map stormConf, backtype.storm.task.TopologyContext context, backtype.storm.task.OutputCollector collector)
prepare
in interface backtype.storm.task.IBolt
protected abstract void prepareSimple(Map<?,?> stormConf, backtype.storm.task.TopologyContext context)
public final void execute(backtype.storm.tuple.Tuple input)
execute
in interface backtype.storm.task.IBolt
protected abstract void writeExternal(String line)
public void cleanup()
cleanup
in interface backtype.storm.task.IBolt
public final void declareOutputFields(backtype.storm.topology.OutputFieldsDeclarer declarer)
declareOutputFields
in interface backtype.storm.topology.IComponent
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.