You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by Rohan Thimmappa <ro...@gmail.com> on 2018/06/04 18:32:10 UTC

Flink Cassandra Sink - Setting TTL for the record

Hi there,


i am using timeseries data in cassandra by reading data from kafka. I
didn't see any option set the TTL. Any help would be of great help!

-- 
Thanks
Rohan

Re: Flink Cassandra Sink - Setting TTL for the record

Posted by Rohan Thimmappa <ro...@gmail.com>.

Thanks.

I was able get this working with insert statement with "using TTL"

https://docs.datastax.com/en/cql/3.3/cql/cql_using/useExpireExample.html




Rohan

On Mon, Jun 4, 2018 at 11:45 AM, miki haiat <mi...@gmail.com> wrote:

>  if you dont have this option in the conector API  you need to implement  a
> richsinkfunction with your desire logic.
>
> https://ci.apache.org/projects/flink/flink-docs-
> master/api/java/org/apache/flink/streaming/api/functions/
> sink/RichSinkFunction.html
>
> On Mon, 4 Jun 2018, 21:32 Rohan Thimmappa, <ro...@gmail.com>
> wrote:
>
> > Hi there,
> >
> >
> > i am using timeseries data in cassandra by reading data from kafka. I
> > didn't see any option set the TTL. Any help would be of great help!
> >
> > --
> > Thanks
> > Rohan
> >
>



-- 
Thanks
Rohan

Re: Flink Cassandra Sink - Setting TTL for the record

Posted by miki haiat <mi...@gmail.com>.

 if you dont have this option in the conector API  you need to implement  a
richsinkfunction with your desire logic.

https://ci.apache.org/projects/flink/flink-docs-master/api/java/org/apache/flink/streaming/api/functions/sink/RichSinkFunction.html

On Mon, 4 Jun 2018, 21:32 Rohan Thimmappa, <ro...@gmail.com>
wrote:

> Hi there,
>
>
> i am using timeseries data in cassandra by reading data from kafka. I
> didn't see any option set the TTL. Any help would be of great help!
>
> --
> Thanks
> Rohan
>