Flink基础（三十八）：FLINK-SQL函数(2) 函数（三）自定义函数（一）
0 简介 自定义函数（UDF）是一种扩展开发机制，可以用来在查询语句里调用难以用其他方式表达的频繁使用或自定义的逻辑。 自定义函数可以用 JVM 语言（例如 Java 或 Scala）或 Python 实现，实现者可以在 UDF 中使用任意第三方库，本文聚焦于使用 JVM 语言开发自定义函数 ...
原文：Flink基础（三十九）：FLINK-SQL函数(3) 函数（四）自定义函数（二）
标量函数 自定义标量函数可以把 到多个标量值映射成 个标量值，数据类型里列出的任何数据类型都可作为求值方法的参数和返回值类型。 想要实现自定义标量函数，你需要扩展org.apache.flink.table.functions里面的ScalarFunction并且实现一个或者多个求值方法。标量函数的行为取决于你写的求值方法。求值方法必须是public的，而且名字必须是eval。 下面的例子展示了 ...
2020-11-28 18:50 0 1180 推荐指数：
相关推荐
Flink基础（三十六）：FLINK-SQL函数(1) 函数（一）概述
0 函数 Flink 允许用户在 Table API 和 SQL 中使用函数进行数据的转换。 1 函数类型 Flink 中的函数有两个划分标准。 一个划分标准是：系统（内置）函数和 Catalog 函数。系统函数没有名称空间，只能通过其名称来进行引用。 Catalog 函数属于 ...
Flink基础（四十五）：FLINK-SQL函数(7) 内置函数（三）数学函数
数学函数 加 减 乘 除 ABS ACOS BIN ASIN ATAN BITAND BITNOT BITOR BITXOR CARDINALITY COS COT EXP E ...
Flink基础（四十四）：FLINK-SQL函数(6) 内置函数（二）字符串函数（一）
字符串函数 STR_TO_MAP 语法 MAP STR_TO_MAP(VARCHAR text) MAP STR_TO_MAP(VARCHAR text, VARCHAR listDelimiter, VARCHAR keyValueDelimiter ...
Flink基础（48）：FLINK-SQL函数(10) 内置函数（六）条件函数
条件函数 IS_DECIMAL IS_DIGIT IS_ALPHA IF CASE WHEN NULLIF COALESCE ...
Flink基础（49）：FLINK-SQL函数(11) 内置函数（七）表值函数
表值函数 STRING_SPLIT JSON_TUPLE GENERATE_SERIES MULTI_KEYVALUE ...
Flink基础（53）：FLINK-SQL函数(16)内置函数（11）字符串函数（二）
JSON_VALUE 语法 VARCHAR JSON_VALUE(VARCHAR content, VARCHAR path) 入参 content VARCHAR ...
Flink基础（四十六）：FLINK-SQL函数(8)内置函数（四）日期函数
日期函数 TO_TIMESTAMP 语法 TIMESTAMP TO_TIMESTAMP(BIGINT time) TIMESTAMP TO_TIMESTAMP(VARCHAR date ...