你确定吗 ignoreNulls 不适合你？Cassandra输出 null 当给定单元格中没有值时。您可以使用 sstabledump 工具-您肯定会看到附加了删除信息的单元格（这就是空值的存储方式）。
下面是运行spark的例子 ignoreNulls （默认），并带有 ignoreNulls 设置为 true . 测试是在dse 5.1.11上完成的，它有旧版本的连接器，但与cassandra 3.11相匹配。
创建如下测试表：

create table test.t3 (id int primary key, t1 text, t2 text, t3 text);

没有 ignoreNulls -我们需要以下代码进行测试：

case class T3(id: Int, t1: Option[String], t2: Option[String], t3: Option[String])
val rdd = sc.parallelize(Seq(new T3(1, None, Some("t2"), None)))
rdd.saveToCassandra("test", "t3")

如果我们使用 cqlsh 我们将看到以下内容：

cqlsh:test> SELECT * from test.t3;

 id | t1   | t2 | t3
----+------+----+------
  1 | null | t2 | null

(1 rows)

做完之后 nodetool flush 我们可以看看table。我们将在这里看到：

>sstabledump mc-1-big-Data.db
[
  {
    "partition" : {
      "key" : [ "1" ],
      "position" : 0
    },
    "rows" : [
      {
        "type" : "row",
        "position" : 30,
        "liveness_info" : { "tstamp" : "2018-11-06T07:53:38.418171Z" },
        "cells" : [
          { "name" : "t1", "deletion_info" : { "local_delete_time" : "2018-11-06T07:53:38Z" }
          },
          { "name" : "t2", "value" : "t2" },
          { "name" : "t3", "deletion_info" : { "local_delete_time" : "2018-11-06T07:53:38Z" }
          }
        ]
      }
    ]
  }
]

你可以在列中看到 t1 & t3 有一个字段 deletion_info .
现在，让我们用 TRUNCATE test.t3 ，重新启动spark shell ignoreNulls 设置为真：

dse spark --conf spark.cassandra.output.ignoreNulls=true

在执行相同的spark代码之后，我们将在 cqlsh :

cqlsh:test> SELECT * from test.t3;

 id | t1   | t2 | t3
----+------+----+------
  1 | null | t2 | null

但在执行冲洗后 sstabledump 显示完全不同的图片：

>sstabledump mc-3-big-Data.db
[
  {
    "partition" : {
      "key" : [ "1" ],
      "position" : 0
    },
    "rows" : [
      {
        "type" : "row",
        "position" : 27,
        "liveness_info" : { "tstamp" : "2018-11-06T07:56:27.035600Z" },
        "cells" : [
          { "name" : "t2", "value" : "t2" }
        ]
      }
    ]
  }
]

如您所见，我们只有列的数据 t2 ，没有提到列 t3 & t1 都是空的。