Flink Cassandra Sink - Setting TTL for the record

[Rohan Thimmappa]

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

[miki haiat]

 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, <[hidden email]>
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
>

[Rohan Thimmappa]

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 <[hidden email]> 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, <[hidden email]>
> 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