Flink SQL时间戳到毫秒

Question

是否有人指出，如果有一种方法转换Flink SQL TIMESTAMP(3)， TIMESTAMP_LTZ(3)到毫秒，而不涉及UDF

?或者也许有一种方法来表示Kafka事件时间毫秒使用表API?

Answer 1

我想这样做可能会起作用:

SELECT (1000 * EXTRACT(EPOCH FROM ts)) + EXTRACT(MILLISECOND FROM ts)

Answer 2

感谢@David Anderson和Flink错误消息，我找到了这个解决方案:

1000 * UNIX_TIMESTAMP(CAST(eTime AS STRING)) + EXTRACT(MILLISECOND FROM eTime)

也许将来我们会有一个内置的函数…