在 Mosaic 决策的 sql 节点中使用 current_time 系统参数

Using current_time system parameter in sql node of Mosaic decisions

在mosaic-decisions的自定义SQL节点中,我使用了系统参数“current-time”。然而,在输出中,它以“文本”类型出现——而不是“日期”类型。应该怎么做才能将其解析为输出中的日期?

当你在自定义SQL节点中使用任何参数时,输入readerSQL,writer节点pre/postSQL等(简而言之任何SQL 选项),Mosaic Decisions 按原样替换 SQL 内的参数值。

所以下面的 SQL:

SELECT COL1,
   '$(currentTime)' as T1
FROM TABLE1..

将转换为:

SELECT COL1,
   '2020-06-17 21:44:55' as T1
FROM TABLE1..

在 Spark 上 运行 之前。如果您想将此列作为 date/timestamp,则必须显式转换它。

但是,另请注意,如果您在任何其他节点(例如,custom-select 节点)中使用这些参数,它们将仅显示为日期类型。