原文:Flink基础(三十六):FLINK-SQL函数(1) 函数(一)概述

函数 Flink 允许用户在 Table API 和 SQL 中使用函数进行数据的转换。 函数类型 Flink 中的函数有两个划分标准。 一个划分标准是:系统 内置 函数和 Catalog 函数。系统函数没有名称空间,只能通过其名称来进行引用。 Catalog 函数属于 Catalog 和数据库,因此它们拥有 Catalog 和数据库命名空间。 用户可以通过全 部分限定名 catalog.db. ...

2020-11-28 18:24 0 1315 推荐指数:

查看详情

Flink基础(三十九):FLINK-SQL函数(3) 函数(四)自定义函数(二)

1 标量函数 自定义标量函数可以把 0 到多个标量值映射成 1 个标量值,数据类型里列出的任何数据类型都可作为求值方法的参数和返回值类型。 想要实现自定义标量函数,你需要扩展 org.apache.flink.table.functions 里面的 ScalarFunction 并且实现一个 ...

Sun Nov 29 02:50:00 CST 2020 0 1180
 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM