java - 如何使用 Spark Cassandra 连接器插入 TimeUUID 和 TimeStamp？

Question

我在 Java 中使用 Spark Cassandra 连接器来插入数据。我的数据有一个 timeuuid 和 timestamp 字段。我有下表:

CREATE TABLE abc.log (
time_uuid timeuuid,
session_id text,
event text,
time timestamp,
sequence int,
PRIMARY KEY (customer)
);

我正在使用这段代码来插入:

JavaRDD<EventLog> rdd = sc.parallelize(eventLogs);
    javaFunctions(rdd)
    .writerBuilder("dove", "event_log", mapToRow(EventLog.class))
    .saveToCassandra();

如何插入 timeuuid 和 timestamp 字段？使用普通插入，我将只使用 now() 函数，我该怎么做？

Answer 1

您可以使用 com.datastax.driver.core.utils.UUIDs为了这。UUIDsTest利用这样的类来创建一个 TimeUUID:

 UUID uuid = UUIDs.timeBased();

注意 UUID 是 java.util.UUID。请注意您的用例是否需要它，但之后您可以通过调用 UUIDs.unixTimestamp(uuid); 来检索 UUID 的时间戳。

至于你的时间戳，你传递了一个 java.util.Date 的实例，正如 docs 中所建议的那样.