Package org.apache.storm.testing
Class PythonShellMetricsSpout
java.lang.Object
org.apache.storm.spout.ShellSpout
org.apache.storm.testing.PythonShellMetricsSpout
- All Implemented Interfaces:
Serializable,ISpout,IComponent,IRichSpout
- See Also:
-
Field Summary
Fields inherited from class org.apache.storm.spout.ShellSpout
LOG -
Constructor Summary
ConstructorsConstructorDescriptionPythonShellMetricsSpout(String[] command) PythonShellMetricsSpout(String command, String file) -
Method Summary
Modifier and TypeMethodDescriptionvoiddeclareOutputFields(OutputFieldsDeclarer declarer) Declare the output schema for all the streams of this topology.Declare configuration specific to this component.voidopen(Map<String, Object> conf, TopologyContext context, SpoutOutputCollector collector) Called when a task for this component is initialized within a worker on the cluster.Methods inherited from class org.apache.storm.spout.ShellSpout
ack, activate, changeChildCWD, close, deactivate, fail, nextTuple, setEnv, shouldChangeChildCWD
-
Constructor Details
-
PythonShellMetricsSpout
-
PythonShellMetricsSpout
-
-
Method Details
-
open
Description copied from interface:ISpoutCalled when a task for this component is initialized within a worker on the cluster. It provides the spout with the environment in which the spout executes.This includes the:
- Specified by:
openin interfaceISpout- Overrides:
openin classShellSpout- Parameters:
conf- The Storm configuration for this spout. 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 spout. Tuples can be emitted at any time, including the open and close methods. The collector is thread-safe and should be saved as an instance variable of this spout object.
-
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
-