我应该在scala类构造函数中声明什么类型的DateTime对象？

Question

我试图将行从cassandra表映射到自定义类，但始终获取DateTime值的IllegalArgumentException。我已经尝试过我能想到的每种类型，并且它们都抛出相同的异常。帮助将不胜感激。我是斯卡拉菜鸟。

case class ClickData(Uuid: String, Tile: String, Latestclick: Long, OriginalTimestamp: Long, Rating: Int)

----------------------------

val data = sc.cassandraTable[ClickData]("test", "user_data")

data.foreach((i: ClickData) =>

  println("CASSIE ROW: "+i)


)

表格行示例：

uuid: 4hgfyt24854grh3fg34u3re47ff, tile: blah-blah, latest_click_timestamp: 2016-08-05 16:17:53+0100, original_timestamp: 2016-08-05 16:17:53+0100, rating: 1

Answer 1

您可以在此处的 Spark中找到默认的Java / Scala数据类型。根据您的数据库实际包含的内容，您可能需要尝试：

• java.sql.Date一DateType列
• java.sql.Timestamp一TimestampType列