Re: flink里删除cassandra的记录

Wed, 13 Nov 2019 18:51:49 -0800 

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

您好，

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

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

回复