Dear

您好,

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

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

回复