EXTRACT - Amazon Kinesis Data Analytics
AWS 文档中描述的 AWS 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅中国的 AWS 服务入门

EXTRACT

EXTRACT(YEAR|MONTH|DAY|HOUR|MINUTE|SECOND FROM <datetime expression>|<interval expression>)

EXTRACT 函数将从 DATE、TIME、TIMESTAMP 或 INTERVAL 表达式中提取一个字段。对于 SECOND 之外的所有字段,它将返回 BIGINT。对于 SECOND,它将返回 DECIMAL (5,3) 并包含毫秒。

语法

示例

函数 结果
EXTRACT(DAY FROM INTERVAL '2 3:4:5.678' DAY TO SECOND)

2

EXTRACT(HOUR FROM INTERVAL '2 3:4:5.678' DAY TO SECOND)

3

EXTRACT(MINUTE FROM INTERVAL '2 3:4:5.678' DAY TO SECOND)

4

EXTRACT(SECOND FROM INTERVAL '2 3:4:5.678' DAY TO SECOND)

5.678

EXTRACT(MINUTE FROM CURRENT_ROW_TIMESTAMP) where CURRENT_ROW_TIMESTAMP is 2016-09-23 04:29:26.234

29

EXTRACT (HOUR FROM CURRENT_ROW_TIMESTAMP)

其中 CURRENT_ROW_TIMESTAMP 是 2016-09-23 04:29:26.234

4

在函数中的使用

EXTRACT 可用于限制数据,如以下函数所示,该函数在 CURRENT_ROW_TIMESTAMP 是 p_time 的输入时返回 30 分钟的底价。

CREATE or replace FUNCTION FLOOR30MIN( p_time TIMESTAMP ) RETURNS  TIMESTAMP CONTAINS SQL RETURNS NULL ON NULL INPUT RETURN  floor(p_time to HOUR) + (( EXTRACT (  MINUTE FROM p_time  ) / 30)* INTERVAL '30' MINUTE ) ;

您应使用以下行的代码实现此函数:

SELECT stream FLOOR30MIN( CURRENT_ROW_TIMESTAMP ) as ROWTIME , * from "MyStream" ) over (range current row ) as r
注意

上面的代码假定您之前已创建名为“MyStream”的流。