FlinkSQL 将时间戳转换为bigint

Question

我必须将时间戳列转换为 bigint 以映射 flinksql 中的目标列，并且不想为其编写自定义 UDF。 有什么建议吗？？

"max_updated": {
    "long": "2024-11-04T22:04:17.793Z"
}

Answer 1

在FlinkSQL中，您可以通过直接使用SQL函数提取纪元毫秒来将时间戳转换为bigint。尝试

CAST (FLOOR(YOUR_TIMESTAMP_COLUMN TO SECOND) AS BIGINT) * 1000

。这将为您提供以毫秒为单位的时间戳。