从 Cassandra 读取 TIME 类型

Question

我正在尝试使用 datastax 连接器将 Cassandra 表读入 Spark。我的表有 2 列使用

TIME

数据类型。我正在使用

java.sql.Time

作为数据集中的相应类型，但是 spark throws

Exception in thread "main" java.lang.UnsupportedOperationException: No Encoder found for java.sql.Time
- field (class: "java.sql.Time", name: "start")
- root class: "model.Trigger"

我试过用 Kryo 注册

Time

课程，但没有成功。我想知道我是否应该使用不同的类来与 Cassandra 的

TIME

类型交互，或者是否存在范围问题，因为我在主要方法中使用 Kryo 注册了该类，但在另一个方法中从 cassandra 检索数据（通过将 conf 生成的会话传递给方法）。

谢谢！