Package org.apache.storm.perf.bolt
Class SplitSentenceBolt
java.lang.Object
org.apache.storm.topology.base.BaseComponent
org.apache.storm.topology.base.BaseBasicBolt
org.apache.storm.perf.bolt.SplitSentenceBolt
- All Implemented Interfaces:
- Serializable,- IBasicBolt,- IComponent
- See Also:
- 
Field SummaryFields
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionvoiddeclareOutputFields(OutputFieldsDeclarer declarer) Declare the output schema for all the streams of this topology.voidexecute(Tuple input, BasicOutputCollector collector) Process the input tuple and optionally emit new tuples based on the input tuple.voidprepare(Map<String, Object> topoConf, TopologyContext context) static String[]splitSentence(String sentence) Methods inherited from class org.apache.storm.topology.base.BaseBasicBoltcleanupMethods inherited from class org.apache.storm.topology.base.BaseComponentgetComponentConfigurationMethods inherited from class java.lang.Objectclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.apache.storm.topology.IComponentgetComponentConfiguration
- 
Field Details- 
FIELDS- See Also:
 
 
- 
- 
Constructor Details- 
SplitSentenceBoltpublic SplitSentenceBolt()
 
- 
- 
Method Details- 
splitSentence
- 
prepare- Specified by:
- preparein interface- IBasicBolt
- Overrides:
- preparein class- BaseBasicBolt
 
- 
executeDescription copied from interface:IBasicBoltProcess the input tuple and optionally emit new tuples based on the input tuple.All acking is managed for you. Throw a FailedException if you want to fail the tuple. 
- 
declareOutputFieldsDescription copied from interface:IComponentDeclare the output schema for all the streams of this topology.- Parameters:
- declarer- this is used to declare output stream ids, output fields, and whether or not each output stream is a direct stream
 
 
-