Package org.apache.storm.trident.spout
Class TridentSpoutExecutor
java.lang.Object
org.apache.storm.trident.spout.TridentSpoutExecutor
- All Implemented Interfaces:
- Serializable,- IComponent,- ITridentBatchBolt
- See Also:
- 
Field SummaryFields
- 
Constructor SummaryConstructorsConstructorDescriptionTridentSpoutExecutor(String txStateId, String streamName, ITridentSpout<Object> spout) 
- 
Method SummaryModifier and TypeMethodDescriptionvoidcleanup()voiddeclareOutputFields(OutputFieldsDeclarer declarer) Declare the output schema for all the streams of this topology.voidvoidfinishBatch(BatchInfo batchInfo) Declare configuration specific to this component.initBatchState(String batchGroup, Object batchId) voidprepare(Map<String, Object> conf, TopologyContext context, BatchOutputCollector collector) 
- 
Field Details- 
ID_FIELD- See Also:
 
- 
LOGpublic static final org.slf4j.Logger LOG
 
- 
- 
Constructor Details- 
TridentSpoutExecutor
 
- 
- 
Method Details- 
preparepublic void prepare(Map<String, Object> conf, TopologyContext context, BatchOutputCollector collector) - Specified by:
- preparein interface- ITridentBatchBolt
 
- 
execute- Specified by:
- executein interface- ITridentBatchBolt
 
- 
cleanuppublic void cleanup()- Specified by:
- cleanupin interface- ITridentBatchBolt
 
- 
declareOutputFieldsDescription copied from interface:IComponentDeclare the output schema for all the streams of this topology.- Specified by:
- declareOutputFieldsin interface- IComponent
- Parameters:
- declarer- this is used to declare output stream ids, output fields, and whether or not each output stream is a direct stream
 
- 
getComponentConfigurationDescription copied from interface:IComponentDeclare configuration specific to this component. Only a subset of the "topology.*" configs can be overridden. The component configuration can be further overridden when constructing the topology usingTopologyBuilder- Specified by:
- getComponentConfigurationin interface- IComponent
 
- 
finishBatch- Specified by:
- finishBatchin interface- ITridentBatchBolt
 
- 
initBatchState- Specified by:
- initBatchStatein interface- ITridentBatchBolt
 
 
-