Flink基礎（三十九）：FLINK-SQL函數(3) 函數（四）自定義函數（二）
1 標量函數 自定義標量函數可以把 0 到多個標量值映射成 1 個標量值，數據類型里列出的任何數據類型都可作為求值方法的參數和返回值類型。 想要實現自定義標量函數，你需要擴展 org.apache.flink.table.functions 里面的 ScalarFunction 並且實現一個 ...
原文：Flink基礎（三十八）：FLINK-SQL函數(2) 函數（三）自定義函數（一）
簡介 自定義函數 UDF 是一種擴展開發機制，可以用來在查詢語句里調用難以用其他方式表達的頻繁使用或自定義的邏輯。 自定義函數可以用 JVM 語言 例如 Java 或 Scala 或 Python 實現，實現者可以在 UDF 中使用任意第三方庫，本文聚焦於使用 JVM 語言開發自定義函數。 概述 當前 Flink 有如下幾種函數： 標量函數將標量值轉換成一個新標量值 表值函數將標量值轉換成新的行 ...
2020-11-28 18:44 0 2207 推薦指數：
相關推薦
Flink基礎（三十六）：FLINK-SQL函數(1) 函數（一）概述
0 函數 Flink 允許用戶在 Table API 和 SQL 中使用函數進行數據的轉換。 1 函數類型 Flink 中的函數有兩個划分標准。 一個划分標准是：系統（內置）函數和 Catalog 函數。系統函數沒有名稱空間，只能通過其名稱來進行引用。 Catalog 函數屬於 ...
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函數(7) 內置函數（三）數學函數
數學函數 加 減 乘 除 ABS ACOS BIN ASIN ATAN BITAND BITNOT BITOR BITXOR CARDINALITY COS COT EXP E ...
Flink基礎（四十六）：FLINK-SQL函數(8)內置函數（四）日期函數
日期函數 TO_TIMESTAMP 語法 TIMESTAMP TO_TIMESTAMP(BIGINT time) TIMESTAMP TO_TIMESTAMP(VARCHAR date ...