Package org.apache.storm.flux.model
Class TopologyDef
java.lang.Object
org.apache.storm.flux.model.TopologyDef
Bean represenation of a topology.
 
 It consists of the following:
   1. The topology name
   2. A `java.util.Map` representing the `org.apache.storm.config` for the topology
   3. A list of spout definitions
   4. A list of bolt definitions
   5. A list of stream definitions that define the flow between spouts and bolts.
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionvoidaddAllBolts(List<BoltDef> bolts, boolean override) Adds a list of bolt definitions.voidaddAllComponents(List<BeanDef> components, boolean override) Adds a list of component definitions.voidaddAllSpouts(List<SpoutDef> spouts, boolean override) Adds a list of spout definitions.voidaddAllStreams(List<StreamDef> streams, boolean override) Adds a list of stream definitions.voidaddAllWorkerHooks(List<WorkerHookDef> workerHooks, boolean override) Adds a list of worker hook definitions.getBoltDef(String id) getBolts()Returns bolt definitions.getComponent(String id) Returns a list of all component definitions.getName()getSpoutDef(String id) Returns all spout definitions.getWorkerHook(String id) Returns worker hook definitions.booleanintparallelismForBolt(String boltId) voidSets bolt definitions.voidsetComponents(List<BeanDef> components) Sets the list of component definitions.voidvoidsetIncludes(List<IncludeDef> includes) voidvoidSets the name of the topology.voidSet spout definitions.voidsetStreams(List<StreamDef> streams) voidsetTopologySource(TopologySourceDef topologySource) voidsetWorkerHooks(List<WorkerHookDef> workerHooks) Sets worker hook definitions.booleanvalidate()Determines is this represents a valid Topology.
- 
Constructor Details- 
TopologyDefpublic TopologyDef()
 
- 
- 
Method Details- 
getName
- 
setName
- 
setNameSets the name of the topology.- Parameters:
- name- topology name
- override- whether to override if already set
 
- 
getSpoutsReturns all spout definitions.- Returns:
- spout definitions.
 
- 
setSpoutsSet spout definitions.- Parameters:
- spouts- spout definitions
 
- 
getBoltsReturns bolt definitions.- Returns:
- bolt definitions
 
- 
setBoltsSets bolt definitions.- Parameters:
- bolts- bolt definitions
 
- 
getStreams
- 
setStreams
- 
getConfig
- 
setConfig
- 
getComponentsReturns a list of all component definitions.- Returns:
- components
 
- 
setComponentsSets the list of component definitions.- Parameters:
- components- components definitions
 
- 
getIncludes
- 
setIncludes
- 
getWorkerHooksReturns worker hook definitions.- Returns:
- worker hook definitions
 
- 
setWorkerHooksSets worker hook definitions.- Parameters:
- workerHooks- worker hook definitions
 
- 
parallelismForBolt
- 
getBoltDef
- 
getSpoutDef
- 
getComponent
- 
getWorkerHook
- 
addAllBoltsAdds a list of bolt definitions. Optionally overriding existing definitions if one with the same ID already exists.- Parameters:
- bolts- bolt definitions
- override- whether or not to override existing definitions
 
- 
addAllSpoutsAdds a list of spout definitions. Optionally overriding existing definitions if one with the same ID already exists.- Parameters:
- spouts- spout definitions
- override- whether or not to override existing definitions
 
- 
addAllComponentsAdds a list of component definitions. Optionally overriding existing definitions if one with the same ID already exists.- Parameters:
- components- component definitions
- override- whether or not to override existing definitions
 
- 
addAllStreamsAdds a list of stream definitions. Optionally overriding existing definitions if one with the same ID already exists.- Parameters:
- streams- stream definitions
- override- whether or not to override existing definitions (currently ignored)
 
- 
addAllWorkerHooksAdds a list of worker hook definitions. Optionally overriding existing definitions if one with the same ID already exists.- Parameters:
- workerHooks- worker hook definitions
- override- whether or not to override existing definitions
 
- 
getTopologySource
- 
setTopologySource
- 
isDslTopologypublic boolean isDslTopology()
- 
validatepublic boolean validate()Determines is this represents a valid Topology.- Returns:
- true if valid
 
 
-