本文为您介绍如何使用实时计算Flink版日期函数TO_TIMESTAMP。
语法
TIMESTAMP TO_TIMESTAMP(BIGINT time)
TIMESTAMP TO_TIMESTAMP(VARCHAR date)
TIMESTAMP TO_TIMESTAMP(VARCHAR date, VARCHAR format)
入参
参数 | 数据类型 |
---|---|
time | BIGINT
说明 单位为毫秒。
|
date | VARCHAR
说明 默认格式为
yyyy-MM-dd HH:mm:ss 。如果您的date为非默认格式,请使用自定义函数编写Java代码进行转化,详情请参见自定义标量函数(UDF)。
|
format | VARCHAR |
功能描述
将BIGINT类型的日期或者VARCHAR类型的日期转换成TIMESTAMP类型。
示例
- 测试数据
timestamp1(BIGINT) timestamp2(VARCHAR) timestamp3(VARCHAR) 1513135677000 2017-09-15 00:00:00 20170915000000 - 测试语句
SELECT TO_TIMESTAMP(timestamp1) as var1, TO_TIMESTAMP(timestamp2) as var2, TO_TIMESTAMP(timestamp3, 'yyyyMMddHHmmss') as var3 FROM T1;
- 测试结果
var1(TIMESTAMP) var2(TIMESTAMP) var3(TIMESTAMP) 2017-12-13 03:27:57.0 2017-09-15 00:00:00.0 2017-09-15 00:00:00.0