Regarding flink-cassandra-connectors

2017-09-26 Thread Jagadish Gangulli
Hi, I have been recently into the application development with flink. We are trying to use the flink-apache connectors to get the data in and out from Cassandra. We attempted both Datastax drivers and Flink-cassandra connectors. In this process felt that flink-cassandra connector is more of a wr

Re: Regarding flink-cassandra-connectors

2017-09-26 Thread Tzu-Li (Gordon) Tai
Hi Jagadish, Yes, you are right that the Flink Cassandra connector uses the Datastax drivers internally, which is also the case for all the other Flink connectors; e.g., the Kafka connector uses the Kafka Java client, Elasticearch connector uses the ES Java client, etc. The main advantage when

Re: Regarding flink-cassandra-connectors

2017-09-26 Thread Tzu-Li (Gordon) Tai
Ah, sorry I just realized Till also answered your question on your cross-post at dev@. It’s usually fine to post questions to just a single mailing list :) On 26 September 2017 at 12:10:55 PM, Tzu-Li (Gordon) Tai (tzuli...@apache.org) wrote: Hi Jagadish, Yes, you are right that the Flink Cass

Re: Regarding flink-cassandra-connectors

2017-09-26 Thread Jagadish Gangulli
Thanks Gordon, Have few more queries on the same lines, if I have to perform fetch i.e. select queries, I have to go for the batch queries, no streaming support is available. Regards, Jagadisha G On Tue, Sep 26, 2017 at 3:40 PM, Tzu-Li (Gordon) Tai wrote: > Hi Jagadish, > > Yes, you are right

Re: Regarding flink-cassandra-connectors

2017-09-26 Thread Tzu-Li (Gordon) Tai
Hi Jagadish, Yes, that indeed is something missing. If that is something you’re interested in, could you perhaps open a JIRA for that (AFAIK there isn’t one for the feature yet). Gordon On 26 September 2017 at 2:09:37 PM, Jagadish Gangulli (jagadi...@gmail.com) wrote: Thanks Gordon, Have f

Re: Regarding flink-cassandra-connectors

2017-09-26 Thread Jagadish Gangulli
Sure, I will create a Jira for that. In addition to that, I would like to confirm, would it be possible to reuse the connection builder object across queries and across jobs. i.e if I create a Singleton class which would create a connection builder instance and could I use across the queries. I h