Flink SQL：将 Bigint 转换为时间戳

Question

这个问题很简单，但我在互联网上找不到任何答案。

我有一个如下所示的 Flink SQL 查询：

SELECT 
  HOP_START(timestampMs, INTERVAL '5' SECOND, INTERVAL '10' SECOND) as wStart, SUM(`value`) - MINVALUE(`value`), ID
FROM MySource 
GROUP BY HOP(timestampMs, INTERVAL '5' SECOND, INTERVAL '10' SECOND), ID

问题是我的字段 timestampMs 被视为 BIGINT 而不是 TIMESTAMP，并且我在 HOP 函数上有错误。如何将其转换为 TIMESTAMP 类型？

Answer 1

不幸的是，没有内置支持将 Epoch Millis 转换为 java.sql.Timestamp。您可以为此使用 UDF：

class UnixEpochToTimestamp extends ScalarFunction {
  def eval(epochMillis: Long): Timestamp = {
    new Timestamp(epochMillis)
  }
}