flink里删除cassandra的记录

[陈程程]

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