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 and 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 Detail

getProducer

IRichSpout getProducer()

Provides instance of IRichSpout which can be used as producer in topology.

See Also:

IRichSpout

getConsumer

IRichBolt getConsumer()

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