日期函数 TO_TIMESTAMP 语法 TIMESTAMP TO_TIMESTAMP(BIGINT time) TIMESTAMP TO_TIMESTAMP(VARCHAR date ...
函数 Flink 允许用户在 Table API 和 SQL 中使用函数进行数据的转换。 函数类型 Flink 中的函数有两个划分标准。 一个划分标准是:系统 内置 函数和 Catalog 函数。系统函数没有名称空间,只能通过其名称来进行引用。 Catalog 函数属于 Catalog 和数据库,因此它们拥有 Catalog 和数据库命名空间。 用户可以通过全 部分限定名 catalog.db. ...
2020-11-28 18:24 0 1315 推荐指数:
日期函数 TO_TIMESTAMP 语法 TIMESTAMP TO_TIMESTAMP(BIGINT time) TIMESTAMP TO_TIMESTAMP(VARCHAR date ...
。 1 概述 当前 Flink 有如下几种函数: 标量函数 将标量值转换成一个新标量值; ...
数学函数 加 减 乘 除 ABS ACOS BIN ASIN ATAN BITAND BITNOT BITOR BITXOR CARDINALITY COS COT EXP E ...
1 标量函数 自定义标量函数可以把 0 到多个标量值映射成 1 个标量值,数据类型里列出的任何数据类型都可作为求值方法的参数和返回值类型。 想要实现自定义标量函数,你需要扩展 org.apache.flink.table.functions 里面的 ScalarFunction 并且实现一个 ...
字符串函数 STR_TO_MAP 语法 MAP STR_TO_MAP(VARCHAR text) MAP STR_TO_MAP(VARCHAR text, VARCHAR listDelimiter, VARCHAR keyValueDelimiter ...
条件函数 IS_DECIMAL IS_DIGIT IS_ALPHA IF CASE WHEN NULLIF COALESCE ...
表值函数 STRING_SPLIT JSON_TUPLE GENERATE_SERIES MULTI_KEYVALUE ...
JSON_VALUE 语法 VARCHAR JSON_VALUE(VARCHAR content, VARCHAR path) 入参 content VARCHAR ...