Package org.apache.storm.sql.runtime

Interface ISqlStreamsDataSource

public interface ISqlStreamsDataSource
An ISqlStreamsDataSource specifies how an external data source produces and consumes data.

  • Method Summary

    Modifier and Type
    Method
    Description
    IRichBolt
    getConsumer()
    Provides instance of IRichBolt which can be used as consumer in topology.
    IRichSpout
    getProducer()
    Provides instance of IRichSpout which can be used as producer in topology.

  • Method Details

    • getProducer

      IRichSpout getProducer()
      Provides instance of IRichSpout which can be used as producer in topology.
      See Also:

    • getConsumer

      IRichBolt getConsumer()
      Provides instance of IRichBolt which can be used as consumer in topology.