Package org.apache.storm.trident.planner
Class SubtopologyBolt
java.lang.Object
org.apache.storm.trident.planner.SubtopologyBolt
- All Implemented Interfaces:
Serializable,IComponent,ITridentBatchBolt
A Bolt that does processing for a subsection of the complete graph.
- See Also:
-
Nested Class Summary
Nested Classes -
Constructor Summary
ConstructorsConstructorDescriptionSubtopologyBolt(org.apache.storm.shade.org.jgrapht.graph.DefaultDirectedGraph<Node, IndexedEdge> graph, Set<Node> nodes, Map<Node, String> batchGroups) -
Method Summary
Modifier 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 batchCollector)
-
Constructor Details
-
SubtopologyBolt
-
-
Method Details
-
prepare
public void prepare(Map<String, Object> conf, TopologyContext context, BatchOutputCollector batchCollector) - Specified by:
preparein interfaceITridentBatchBolt
-
execute
- Specified by:
executein interfaceITridentBatchBolt
-
finishBatch
- Specified by:
finishBatchin interfaceITridentBatchBolt
-
initBatchState
- Specified by:
initBatchStatein interfaceITridentBatchBolt
-
cleanup
public void cleanup()- Specified by:
cleanupin interfaceITridentBatchBolt
-
declareOutputFields
Description copied from interface:IComponentDeclare the output schema for all the streams of this topology.- Specified by:
declareOutputFieldsin interfaceIComponent- Parameters:
declarer- this is used to declare output stream ids, output fields, and whether or not each output stream is a direct stream
-
getComponentConfiguration
Description 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 interfaceIComponent
-