在Hologres源表定义中,可以映射为Flink的Timestamp。具体映射方式如下:
- 在源表定义中,将时间列的数据类型设置为TIMESTAMP或者DATETIME。例如:
CREATE TABLE source_table (
...
event_time TIMESTAMP,
...
);
- 在Flink SQL中使用
CAST
函数将时间列转换为Flink的Timestamp类型。例如:
SELECT CAST(event_time AS TIMESTAMP(3)) AS flink_timestamp FROM source_table;
这样,源表中的时间列就会被映射为Flink的Timestamp类型,可以在后续的Flink操作中使用。