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 <miko5...@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, <rohan.thimma...@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
