如何删除行在YugabyteDB YCQL火花连接器?

Question

[用户在YugabyteDB社区Slack上发布的问题]

是否有可能在YugabyteDB YCQL Spark连接器删除行?如果是，怎么做?

Answer 1

是有可能的。你可以将这个补丁应用到repo中，看看如何在测试用例中运行删除操作:

diff --git a/java/yb-cql-4x/src/test/java/org/yb/loadtest/TestSpark3Jsonb.java b/java/yb-cql-4x/src/test/java/org/yb/loadtest/TestSpark3Jsonb.java
index 50d075b529..3ccf3b42f4 100644
--- a/java/yb-cql-4x/src/test/java/org/yb/loadtest/TestSpark3Jsonb.java
+++ b/java/yb-cql-4x/src/test/java/org/yb/loadtest/TestSpark3Jsonb.java
@@ -124,6 +124,7 @@ public class TestSpark3Jsonb extends BaseMiniClusterTest {
}
// TODO to update a JSONB sub-object only using Spark SQL --
// for now requires using the Cassandra session directly.
+      session.execute("delete from " + tableWithKeysapce + " where id=3");
String update = "update " + tableWithKeysapce +
" set phone->'key'->1->'m'->2->'b'='320' where id=4";
session.execute(update);

在测试输出中，您将看到:

+---+----------------------+-----+-----------------------------------------------------------------+
|id |address               |name |phone                                                            |
+---+----------------------+-----+-----------------------------------------------------------------+
|2  |Acton London, UK      |Nick |{"code":"+43","phone":1200}                                      |
|4  |4 Act London, UK      |Kumar|{"code":"+45","key":[0,{"m":[12,-1,{"b":320},500]}],"phone":1500}|
|1  |Hammersmith London, UK|John |{"code":"+42","phone":1000}                                      |
+---+----------------------+-----+-----------------------------------------------------------------+

，删除下面一行:

|3  |11 Acton London, UK   |Smith|{"code":"+44","phone":1400}|