开发者社区> 问答> 正文

Flink计算列语法如何写

已解决

Flink计算列语法如何写

展开
收起
提个问题 2024-05-30 10:07:09 18 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
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载