flink里删除cassandra的记录

[陈程程]

大家好，
我们可以通过CassandraSink插入行到Cassandra，但是如何删除该行呢？
我试图写了一个定制的sink，但是出错了（NotSerializableException）。到底如何执行删除行操作呀？
Thanks,程程

[163]

Dear

您好，

    我们使用 DataStax Cassandra Driver 定制了 Cassandra Sink 实现了 detele 操作。

> On Nov 13, 2019, at 3:54 PM, 陈程程 <[hidden email]> wrote:
>
> 大家好，
> 我们可以通过CassandraSink插入行到Cassandra，但是如何删除该行呢？
> 我试图写了一个定制的sink，但是出错了（NotSerializableException）。到底如何执行删除行操作呀？
> Thanks,程程

[陈程程]

 您好，
可以share下code吗？
thanks
    On Thursday, November 14, 2019, 10:05:58 AM GMT+8, 163 <[hidden email]> wrote:  
 
 Dear

您好，

    我们使用 DataStax Cassandra Driver 定制了 Cassandra Sink 实现了 detele 操作。

> On Nov 13, 2019, at 3:54 PM, 陈程程 <[hidden email]> wrote:
>
> 大家好，
> 我们可以通过CassandraSink插入行到Cassandra，但是如何删除该行呢？
> 我试图写了一个定制的sink，但是出错了（NotSerializableException）。到底如何执行删除行操作呀？
> Thanks,程程