Hi Gordon, Thanks for the response, I did go over the links for sources and sinks prior to posting my question. Maybe, I didn't get my question across correctly so let me rephrase it. Can I get data out of data stores like Cassandra, Hbase in a streaming manner? coz, currently more or less all the sources are of message queue family.
Thanks, Kant On Thu, Sep 7, 2017 at 1:04 AM, Tzu-Li (Gordon) Tai <tzuli...@apache.org> wrote: > Hi! > > > I am wondering if Flink can do streaming from data sources other than > Kafka. For example can Flink do streaming from a database like Cassandra, > HBase, MongoDb to sinks like says Elastic search or Kafka. > > > Yes, Flink currently supports various connectors for different sources and > sinks. For an overview you can check out this documentation [1] > Apache Bahir [2] also maintains some Flink connectors and is released > separately. > > Also for out of core stateful streaming. Is RocksDB the only option? > > Currently, RocksDB is the only option for out-of-core state. There was > some previous discussion for a Cassandra state backend, though [3]. > > - Gordon > [1] https://ci.apache.org/projects/flink/flink-docs- > release-1.3/dev/connectors/index.html > [2] http://bahir.apache.org/ > [3] https://issues.apache.org/jira/browse/FLINK-4266 > > On 7 September 2017 at 2:58:38 PM, kant kodali (kanth...@gmail.com) wrote: > > Hi All, > > I am wondering if Flink can do streaming from data sources other than > Kafka. For example can Flink do streaming from a database like Cassandra, > HBase, MongoDb to sinks like says Elastic search or Kafka. > > Also for out of core stateful streaming. Is RocksDB the only option? Can I > use some other key value store that has SQL interface (since RocksDB > doesn't)? > > Thanks, > kant > >