【发布时间】:2019-12-14 13:33:57
【问题描述】:
在spark中,有没有办法通过提供一个Timstamp对象来获取分区路径,而不是提供一个字符串形式的分区键?
我知道我们可以通过运行以下查询来获取分区路径:
val x = "date='2019-08-06 23:48:32.113'"
spark.sql(s"describe extended hospitaltest partition (${x})")
但上述查询需要将分区键作为字符串。
【问题讨论】:
-
您能举例说明您计划如何创建时间戳对象吗?据我所知,它必须传递一个字符串。
-
@Goldie 我正在使用 java date 的 getTime 方法从 java date 对象创建时间戳对象。那么如果另一个应用想知道 Timestamp 对象和实际分区路径之间的映射关系,它如何在不知道使用什么日期格式的情况下得到答案呢?或者反过来说,如果给定一个分区路径为字符串,在不知道格式的情况下怎么知道这个字符串代表的是哪个日期呢?
标签: sql scala apache-spark hive hive-metastore