本文为您介绍如何使用实时计算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