Flink计算列语法如何写
已解决
收起
提个问题!
2024-05-30 10:07:09
36
0
1
条回答
写回答
取消
提交回答
-
计算列是使用语法column_ name As Computed_ column_expression生成的虛拟列。
计算列计算可以引用同一表中声明的其他列的表达式。物理列和元数据列都可以访问。
列本身井没有物理存储在表中。列的数据类型是从给定的表达式自动派生的,不必手动声明表达式可以包含列、常量或西数的任何组合。表达式不能包含子查询。
CREATE TABLE MyTable (user_id BIGINT, price®DOUBLE, quantity DOUBLE, cost AS price * quanitity,-- evaluate expression and supplythe result to queries) WITH ('connector’= kafka'.);
计算列通常在Flink中用于定义CREATETABLE语句中的时间属性。处理时间属性可以使用系统的PROCTIME ()函数通过procASPROCIME ()轻松定义。事件时间属性时问戳可以在WATERIMARK声明之前进行预处理。例如,如果原始宇段不是TINESTAMP(3) 类型或嵌套在JSON宇符串中,则可以使用计算列。
2024-05-30 10:07:10