OSDir


[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Re: Flink Cassandra Sink - Setting TTL for the record


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 <miko5054@xxxxxxxxx> 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, <rohan.thimmappa@xxxxxxxxx>
> 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