1 Scan、Projection 與 Filter 操作符 描述 Scan / Select / As批處理 流處理 ...
來源:https: ci.apache.org projects flink flink docs release . zh dev table sql queries.html 簡介 SELECT 語句和 VALUES 語句需要使用TableEnvironment的sqlQuery 方法加以指定。這個方法會以Table的形式返回 SELECT 或 VALUE 的查詢結果。Table可以被用於隨后 ...
2020-11-28 16:38 0 3418 推薦指數:
1 Scan、Projection 與 Filter 操作符 描述 Scan / Select / As批處理 流處理 ...
注意: LIMIT 查詢需要有一個 ORDER BY 字句。 6 Top ...
0 簡介 SHOW 語句用於列出所有的 catalog,或者列出當前 catalog 中所有的 database,或者列出當前 catalog 和當前 database 的所有表或視圖,或者列出所有的 function,包括:臨時系統 function,系統 function,臨時 ...
0 簡介 DROP 語句用於從當前或指定的 Catalog 中刪除一個已經注冊的表、視圖或函數。 Flink SQL 目前支持以下 DROP 語句: DROP TABLE DROP DATABASE DROP VIEW DROP FUNCTION 1 執行 DROP ...
0 簡介 CREATE 語句用於向當前或指定的 Catalog 中注冊表、視圖或函數。注冊后的表、視圖和函數可以在 SQL 查詢中使用。 目前 Flink SQL 支持下列 CREATE 語句: CREATE TABLE CREATE DATABASE CREATE VIEW ...
0 簡介 ALTER 語句用於修改一個已經在 Catalog 中注冊的表、視圖或函數定義。 Flink SQL 目前支持以下 ALTER 語句: ALTER TABLE ALTER DATABASE ALTER FUNCTION 1 執行 ALTER 語句 可以使 ...
Windowing table-valued functions (Windowing TVFs) Streaming 0 簡介 Windows are at the heart of pro ...
USE 語句用來設置當前的 catalog 或者 database。 1 運行一個 USE 語句 可以使用 TableEnvironment 中的 executeSql() 方法執行 USE 語句,也可以在 SQL CLI 中執行 USE 語句。 若 USE 操作執行成功,executeSql ...