原文: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