小编Aar*_*ell的帖子

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

我试图将行从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)


)
Run Code Online (Sandbox Code Playgroud)

表格行示例:

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
Run Code Online (Sandbox Code Playgroud)

scala cassandra apache-spark

5
推荐指数
1
解决办法
4038
查看次数

标签 统计

apache-spark ×1

cassandra ×1

scala ×1