从 scala TimeStampType 中提取值

Question

我有一个从 hive 查询创建的 schemaRDD

    val sqlContext = new org.apache.spark.sql.hive.HiveContext(sc)
    val rdd = sqlContext.sql("Select * from mytime")

我的 RDD 包含以下架构

    StructField(id,StringType,true)
    StructField(t,TimestampType,true)

我们有自己的自定义数据库，并希望将 TimestampType 与字符串相同。但我找不到提取值并将其保存为字符串的方法。

你能帮忙吗？谢谢！

Answer 1

如果您将查询更改为：

SELECT id, cast(t as STRING) from mytime