Flink基礎（二十七）：FLINK-SQL語法(三)DQL(三)查詢語句（三）操作符（二）
5 OrderBy & Limit 操作符 描述 Order By批處理 流處理 注意： 流處理結果需主要根據 時間屬性 按照升序進行排序。支持使用其他排序屬性。 Limit批處理 ...
原文：Flink基礎（二十六）：FLINK-SQL語法(二)DQL(二)查詢語句（二）操作符（一）
Scan Projection 與 Filter 操作符 描述 Scan Select As批處理流處理 Where Filter批處理流處理 用戶定義標量函數 Scalar UDF 批處理流處理 自定義函數必須事先注冊到 TableEnvironment 中。 可閱讀自定義函數文檔以獲得如何指定和注冊自定義函數的詳細信息。 聚合 操作符 描述 GroupBy 聚合批處理流處理結果更新 注意：G ...
2020-11-28 16:42 0 1014 推薦指數：
相關推薦
Flink基礎（二十五）：FLINK-SQL語法 (一)DQL(一)查詢語句（一）基本查詢
來源：https://ci.apache.org/projects/flink/flink-docs-release-1.11/zh/dev/table/sql/queries.html 0 簡介 SELECT 語句和 VALUES 語句需要使用 TableEnvironment ...
Flink基礎（二十九）：FLINK-SQL語法(五)DDL(二)DROP 語句
0 簡介 DROP 語句用於從當前或指定的 Catalog 中刪除一個已經注冊的表、視圖或函數。 Flink SQL 目前支持以下 DROP 語句： DROP TABLE DROP DATABASE DROP VIEW DROP FUNCTION 1 執行 DROP ...
Flink基礎（二十八）：FLINK-SQL語法(四)DDL(一)CREATE 語句
0 簡介 CREATE 語句用於向當前或指定的 Catalog 中注冊表、視圖或函數。注冊后的表、視圖和函數可以在 SQL 查詢中使用。 目前 Flink SQL 支持下列 CREATE 語句： CREATE TABLE CREATE DATABASE CREATE VIEW ...
Flink基礎（三十）：FLINK-SQL語法(六)DDL(三)ALTER 語句
0 簡介 ALTER 語句用於修改一個已經在 Catalog 中注冊的表、視圖或函數定義。 Flink SQL 目前支持以下 ALTER 語句： ALTER TABLE ALTER DATABASE ALTER FUNCTION 1 執行 ALTER 語句 可以使 ...
Flink基礎（120）：FLINK-SQL語法 (14) DQL(6) OPERATIONS(3) 窗口 (1) Windowing table-valued functions (Windowing TVFs)
Windowing table-valued functions (Windowing TVFs) Streaming 0 簡介 Windows are at the heart of pro ...
Flink基礎（三十六）：FLINK-SQL函數(1) 函數（一）概述
0 函數 Flink 允許用戶在 Table API 和 SQL 中使用函數進行數據的轉換。 1 函數類型 Flink 中的函數有兩個划分標准。 一個划分標准是：系統（內置）函數和 Catalog 函數。系統函數沒有名稱空間，只能通過其名稱來進行引用。 Catalog 函數屬於 ...
Flink基礎（三十四）：FLINK-SQL語法(十)DDL(六)USE 語句
USE 語句用來設置當前的 catalog 或者 database。 1 運行一個 USE 語句 可以使用 TableEnvironment 中的 executeSql() 方法執行 USE 語句，也可以在 SQL CLI 中執行 USE 語句。 若 USE 操作執行成功，executeSql ...