DROP Statements

DROP statements are used to remove a catalog with the given catalog name or to remove a registered table/view/function from the current or specified Catalog.
DROP语句用于删除具有给定目录名称的目录，或从当前或指定的目录中删除已注册的表/视图/函数。

Flink SQL supports the following DROP statements for now:
Flink SQL目前支持以下DROP语句：

DROP CATALOG
DROP TABLE
DROP DATABASE
DROP VIEW
DROP FUNCTION

Run a DROP statement

Java
DROP statements can be executed with the executeSql() method of the TableEnvironment. The executeSql() method returns ‘OK’ for a successful DROP operation, otherwise will throw an exception.
DROP语句可以使用TableEnvironment的executeSql()方法执行。executeSql()方法为成功的DROP操作返回“OK”，否则将引发异常。

The following examples show how to run a DROP statement in TableEnvironment.
以下示例显示了如何在TableEnvironment中运行DROP语句。

TableEnvironment tableEnv = TableEnvironment.create(...);// register a table named "Orders"
tableEnv.executeSql("CREATE TABLE Orders (`user` BIGINT, product STRING, amount INT) WITH (...)");// a string array: ["Orders"]
String[] tables = tableEnv.listTables();
// or tableEnv.executeSql("SHOW TABLES").print();// drop "Orders" table from catalog
tableEnv.executeSql("DROP TABLE Orders");// an empty string array
String[] tables = tableEnv.listTables();
// or tableEnv.executeSql("SHOW TABLES").print();

SQL CLI
DROP statements can be in SQL CLI.
DROP语句可以在SQL CLI中。

The following examples show how to run a DROP statement in SQL CLI.
以下示例显示了如何在SQL CLI中运行DROP语句。

Flink SQL> CREATE TABLE Orders (`user` BIGINT, product STRING, amount INT) WITH (...);
[INFO] Table has been created.Flink SQL> SHOW TABLES;
OrdersFlink SQL> DROP TABLE Orders;
[INFO] Table has been removed.Flink SQL> SHOW TABLES;
[INFO] Result was empty.

DROP CATALOG

DROP CATALOG [IF EXISTS] catalog_name

Drop a catalog with the given catalog name.
删除具有给定目录名称的目录。

IF EXISTS

If the catalog does not exist, nothing happens.
如果目录不存在，则不会发生任何事情。

DROP TABLE

DROP [TEMPORARY] TABLE [IF EXISTS] [catalog_name.][db_name.]table_name

Drop a table with the given table name. If the table to drop does not exist, an exception is thrown.
删除具有给定表名的表。如果要删除的表不存在，将引发异常。

TEMPORARY

Drop temporary table that has catalog and database namespaces.
删除具有目录和数据库命名空间的临时表。

IF EXISTS

If the table does not exist, nothing happens.
如果表不存在，则不会发生任何事情。

DROP DATABASE

DROP DATABASE [IF EXISTS] [catalog_name.]db_name [ (RESTRICT | CASCADE) ]

Drop a database with the given database name. If the database to drop does not exist, an exception is thrown.
删除具有给定数据库名称的数据库。如果要删除的数据库不存在，将引发异常。

IF EXISTS

If the database does not exist, nothing happens.
如果数据库不存在，则不会发生任何事情。

RESTRICT

Dropping a non-empty database triggers an exception. Enabled by default.
删除非空数据库会触发异常。默认情况下启用。

CASCADE

Dropping a non-empty database also drops all associated tables and functions.
删除非空数据库也会删除所有关联的表和函数。

DROP VIEW

DROP [TEMPORARY] VIEW  [IF EXISTS] [catalog_name.][db_name.]view_name

Drop a view that has catalog and database namespaces. If the view to drop does not exist, an exception is thrown.
删除具有目录和数据库名称空间的视图。如果要删除的视图不存在，将引发异常。

TEMPORARY

Drop temporary view that has catalog and database namespaces.
删除具有目录和数据库命名空间的临时视图。

IF EXISTS

If the view does not exist, nothing happens.
如果视图不存在，则不会发生任何事情。

MAINTAIN DEPENDENCIES Flink does not maintain dependencies of view by CASCADE/RESTRICT keywords, the current way is producing postpone error message when user tries to use the view under the scenarios like the underlying table of view has been dropped.
维护依赖性:Flink不通过CASCADE/RESTRICT关键字维护视图的依赖性，当前的方法是当用户试图在视图的基础表被删除的情况下使用视图时，生成延迟错误消息。

DROP FUNCTION

DROP [TEMPORARY|TEMPORARY SYSTEM] FUNCTION [IF EXISTS] [catalog_name.][db_name.]function_name;

Drop a catalog function that has catalog and database namespaces. If the function to drop does not exist, an exception is thrown.
删除具有目录和数据库名称空间的目录函数。如果要删除的函数不存在，将引发异常。

TEMPORARY

Drop temporary catalog function that has catalog and database namespaces.
删除具有目录和数据库命名空间的临时目录函数。

TEMPORARY SYSTEM

Drop temporary system function that has no namespace.
删除没有命名空间的临时系统函数。

IF EXISTS

If the function doesn’t exists, nothing happens.
如果函数不存在，则不会发生任何事情。

Flink SQL:DROP Statements相关推荐

Flink SQL: SET Statements
SET Statements SET statements are used to modify the configuration or list the configuration. SET语句用 ...
Flink SQL Client CLI 使用入门
参照:https://blog.csdn.net/boling_cavalry/article/details/105964425 一.SQL Client Flink 的 Table & S ...
使用flink Table Sql api来构建批量和流式应用(3)Flink Sql 使用
从flink的官方文档,我们知道flink的编程模型分为四层,sql层是最高层的api,Table api是中间层,DataStream/DataSet Api 是核心,stateful Stream ...
Flink SQL 的 9 个示例
作者:贺小令(晓令) 本文由阿里巴巴技术专家贺小令分享,社区志愿者郑仲尼整理.文章基于 Flink 1.9 版本,从用户的角度来讲解 Flink 1.9 版本中 SQL 相关原理及部分功能变更,希望对 ...
Flink SQL Client注册JAVA UDF完整流程
概述听大佬说[1]里面有flink sql client注册udf的方法去看了一眼,全是文字,闹心,索性琢磨了一下,记录下来． UDF的完整maven工程 https://github.com/a ...
Flink SQL Client方言切换与datagen-＞Hive(DDL形式+streaming形式)
概述本文是对[1]的完整复现,补充了[1]中缺失的大量细节. 切换方言切换目标 Flink SQL Client命令切换为hive SET table.sql-dialect=hive; 切换为 ...
flink sql client读取hive时卡住
问题复现如下: 查看$FLINK_HOME/log/flink-appleyuchi-sql-client-Desktop.log 2020-12-23 11:48:56,811 INFO org. ...
1.30.Flink SQL案例将Kafka数据写入hive
1.30.Flink SQL案例将Kafka数据写入hive 1.30.1.1.场景,环境,配置准备 1.30.1.2.案例代码 1.30.1.2.1.编写pom.xml文件 1.30.1.2.2.M ...
网易游戏 Flink SQL 平台化实践
摘要:本文整理自网易游戏资深开发工程师林小铂在 Flink Forward Asia 2021 平台建设专场的演讲.主要内容包括: 网易游戏 Flink SQL 发展历程基于模板 jar 的 Str ...

Flink SQL:DROP Statements

DROP Statements

Run a DROP statement

DROP CATALOG

DROP TABLE

DROP DATABASE

DROP VIEW

DROP FUNCTION

Flink SQL:DROP Statements相关推荐

最新文章

热门文章