setStreamTableTimestamp

语法

setStreamTableTimestamp(streamTable, columnName)

详情

为指定的流数据表设置一个时间戳列(支持所有时间类型)。设置后,每次向流表写入数据时,系统会记录写入时的系统时间到该时间戳列。这有助于用户统计实时数据写入流表时的延迟。

注意:设置后不可更改和撤销时间戳列。

参数

streamTable 流数据表。可以是普通流表、共享流表、持久化流表和高可用流表。

columnName 一个字符串,是流数据表最后一列的列名。该列用于记录数据写入流表的系统时间。

例子

share streamTable(10000:0,`time`symbol`price`timestamp, [TIMESTAMP,SYMBOL,DOUBLE,TIMESTAMP]) as trades
//指定 timestamp 列为时间戳列
setStreamTableTimestamp(trades, `timestamp)

//插入的数据中不能包含 timestamp 列,系统会自动为其添加时间戳。
insert into trades values(2023.03.19T03:17:49, `A, 10.2)

select * from trades
            
time symbol price timestamp
2023.03.19 03:17:49.000 A 10.2 2024.03.31 08:01:31.324