【发布时间】:2022-07-19 09:17:40
【问题描述】:
我正在将 kafka 的实时数据消耗到 Pinot 中。数据的日期时间格式如下:
“2022 年 3 月 14 日星期一 15:58:24 IST”
我正在努力在架构文件中编写“dateTimeFieldSpecs”。 你能帮帮我吗?
谢谢,
苏库玛
【问题讨论】:
标签: datetime schema apache-pinot
我正在将 kafka 的实时数据消耗到 Pinot 中。数据的日期时间格式如下:
“2022 年 3 月 14 日星期一 15:58:24 IST”
我正在努力在架构文件中编写“dateTimeFieldSpecs”。 你能帮帮我吗?
谢谢,
苏库玛
【问题讨论】:
标签: datetime schema apache-pinot
您可以使用转换函数来为您做到这一点。
首先将该列添加到您的常规schema.json。之后,在表格设置中添加一个转换函数,通常是table.json。此函数接收原始列并将其重新格式化为 Pinot 的类型。
请记住,可能需要检查服务器与本地时区,尤其是在实时表中。
看看这些docs
希望这会有所帮助!
【讨论】: