日期函數 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 ...