Flink SQL: 如何将 Kafka 时间戳转换为时间类型

在 Flink SQL 中，可以使用 TO_TIMESTAMP 函数将 Kafka 的时间戳类型转换成时间类型。具体用法如下：

SELECT TO_TIMESTAMP(timestamp) as event_time
FROM kafka_table;

其中，timestamp 是 Kafka 数据流中的时间戳字段，kafka_table 是 Kafka 数据流的表。执行上述 SQL 语句后，将会将 Kafka 的时间戳类型转换成时间类型，并将其命名为 event_time。

需要注意的是，TO_TIMESTAMP 函数的参数类型应该是一个长整型（Long），表示从 1970 年 1 月 1 日 00:00:00 GMT（格林尼治标准时间）开始的毫秒数。如果 Kafka 数据流中的时间戳字段不是长整型，需要先进行类型转换，确保参数类型正确。