【问题标题】:What type should I declare a DateTime object in a scala class constructor?我应该在 Scala 类构造函数中声明什么类型的 DateTime 对象?
【发布时间】: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


    【解决方案1】:

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

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

    【讨论】:

      【解决方案2】:

      我的参数名称与列名称不匹配,将它们复制出来正确解决了我的问题。它们也是 Long 类型。

      【讨论】:

        猜你喜欢
        • 2012-04-05
        • 1970-01-01
        • 2019-04-05
        • 1970-01-01
        • 1970-01-01
        • 2011-11-02
        • 2013-04-05
        • 1970-01-01
        相关资源
        最近更新 更多