Package org.apache.storm.testing
Class PythonShellMetricsBolt
java.lang.Object
org.apache.storm.task.ShellBolt
org.apache.storm.testing.PythonShellMetricsBolt
- All Implemented Interfaces:
- Serializable,- IBolt,- IComponent,- IRichBolt
- See Also:
- 
Field SummaryFields inherited from class org.apache.storm.task.ShellBoltHEARTBEAT_STREAM_ID, LOG
- 
Constructor SummaryConstructorsConstructorDescriptionPythonShellMetricsBolt(String[] args) PythonShellMetricsBolt(String command, String file) 
- 
Method SummaryModifier and TypeMethodDescriptionvoiddeclareOutputFields(OutputFieldsDeclarer declarer) Declare the output schema for all the streams of this topology.Declare configuration specific to this component.voidprepare(Map<String, Object> topoConf, TopologyContext context, OutputCollector collector) Called when a task for this component is initialized within a worker on the cluster.Methods inherited from class org.apache.storm.task.ShellBoltchangeChildCWD, cleanup, execute, setEnv, shouldChangeChildCWD
- 
Constructor Details- 
PythonShellMetricsBolt
- 
PythonShellMetricsBolt
 
- 
- 
Method Details- 
preparepublic void prepare(Map<String, Object> topoConf, TopologyContext context, OutputCollector collector) Description copied from interface:IBoltCalled when a task for this component is initialized within a worker on the cluster. It provides the bolt with the environment in which the bolt executes.This includes the: - Specified by:
- preparein interface- IBolt
- Overrides:
- preparein class- ShellBolt
- Parameters:
- topoConf- The Storm configuration for this bolt. This is the configuration provided to the topology merged in with cluster configuration on this machine.
- context- This object can be used to get information about this task's place within the topology, including the task id and component id of this task, input and output information, etc.
- collector- The collector is used to emit tuples from this bolt. Tuples can be emitted at any time, including the prepare and cleanup methods. The collector is thread-safe and should be saved as an instance variable of this bolt object.
 
- 
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
 
 
-