Class RichShellBolt

java.lang.Object
org.apache.storm.task.ShellBolt
org.apache.storm.clojure.RichShellBolt
All Implemented Interfaces:
Serializable, IBolt, IComponent, IRichBolt

public class RichShellBolt extends ShellBolt implements IRichBolt
See Also:
  • Constructor Details

  • Method Details

    • declareOutputFields

      public void declareOutputFields(OutputFieldsDeclarer declarer)
      Description copied from interface: IComponent
      Declare the output schema for all the streams of this topology.
      Specified by:
      declareOutputFields in 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
    • getComponentConfiguration

      public Map<String,Object> getComponentConfiguration()
      Description copied from interface: IComponent
      Declare 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 using TopologyBuilder
      Specified by:
      getComponentConfiguration in interface IComponent