0 简介 ALTER 语句用于修改一个已经在 Catalog 中注册的表、视图或函数定义。 Flink SQL 目前支持以下 ALTER 语句: ALTER TABLE ALTER DATABASE ALTER FUNCTION 1 执行 ALTER 语句 可以使 ...
简介 DROP 语句用于从当前或指定的Catalog中删除一个已经注册的表 视图或函数。 Flink SQL 目前支持以下 DROP 语句: DROP TABLE DROP DATABASE DROP VIEW DROP FUNCTION 执行 DROP 语句 可以使用TableEnvironment中的executeSql 方法执行 DROP 语句,也可以在SQL CLI中执行 DROP 语句 ...
2020-11-28 17:18 0 825 推荐指数:
0 简介 ALTER 语句用于修改一个已经在 Catalog 中注册的表、视图或函数定义。 Flink SQL 目前支持以下 ALTER 语句: ALTER TABLE ALTER DATABASE ALTER FUNCTION 1 执行 ALTER 语句 可以使 ...
0 简介 CREATE 语句用于向当前或指定的 Catalog 中注册表、视图或函数。注册后的表、视图和函数可以在 SQL 查询中使用。 目前 Flink SQL 支持下列 CREATE 语句: CREATE TABLE CREATE DATABASE CREATE VIEW ...
USE 语句用来设置当前的 catalog 或者 database。 1 运行一个 USE 语句 可以使用 TableEnvironment 中的 executeSql() 方法执行 USE 语句,也可以在 SQL CLI 中执行 USE 语句。 若 USE 操作执行成功,executeSql ...
0 简介 SHOW 语句用于列出所有的 catalog,或者列出当前 catalog 中所有的 database,或者列出当前 catalog 和当前 database 的所有表或视图,或者列出所有的 function,包括:临时系统 function,系统 function,临时 ...
EXPLAIN 语句用来解释一条 query 语句或者 INSERT 语句的逻辑计划和优化后的计划。 运行一条 EXPLAIN 语句 EXPLAIN 语句可以通过 TableEnvironment 的 executeSql() 执行,也可以在 SQL CLI 中执行 EXPLAIN 语句 ...
5 OrderBy & Limit 操作符 描述 Order By批处理 流处理 注意: 流处理结果需主要根据 时间属性 ...
来源:https://ci.apache.org/projects/flink/flink-docs-release-1.11/zh/dev/table/sql/queries.html 0 简介 SELECT 语句和 VALUES 语句需要使用 TableEnvironment ...
1 Scan、Projection 与 Filter 操作符 描述 Scan / Select / As批处理 流处理 ...