Regarding flink-cassandra

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

Regarding flink-cassandra

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 wrapper on top of
data stax cassandra drivers.

Hence could some one please explain the benefits of the
flink-cassandra-connectors over the data stax driver apis. We are looking
for the APIs which are better in terms of performance. Please let me know
your thoughts.

Thanks & Regards,
Jagadisha G
Reply | Threaded
Open this post in threaded view
|

Re: Regarding flink-cassandra

Till Rohrmann
Hi Jagadisha,

the benefit of using Flink's connector is that you don't have to write the
sink function on your own. Moreover, it integrates with Flink's
checkpointing mechanism which gives you up to exactly once processing
guarantees if the update operation is idempotent.

I've included Chesnay who can give you more details about the
implementation details, if you want to hear more.

Cheers,
Till

On Tue, Sep 26, 2017 at 11:00 AM, Jagadish Gangulli <[hidden email]>
wrote:

> 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 wrapper on top of
> data stax cassandra drivers.
>
> Hence could some one please explain the benefits of the
> flink-cassandra-connectors over the data stax driver apis. We are looking
> for the APIs which are better in terms of performance. Please let me know
> your thoughts.
>
> Thanks & Regards,
> Jagadisha G
>