git.net

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

Re: Flink Cassandra Sink - Setting TTL for the record


 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
>