【发布时间】:2016-12-12 18:34:54
【问题描述】:
我试图将行从 cassandra 表映射到自定义类,但不断收到 DateTime 值的 IllegalArgumentException。我已经尝试了所有我能想到的类型,它们都抛出了相同的异常。帮助将不胜感激。顺便说一句,我是一个 scala 菜鸟。
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
【问题讨论】:
标签: scala apache-spark cassandra