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 TypeMethodDescriptionProvides instance of IRichBolt which can be used as consumer in topology.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.
-