原文:Flink基础(三十一):FLINK-SQL语法(七)DML(一)INSERT 语句

INSERT 语句用来向表中添加行。 执行 INSERT 语句 单条 INSERT 语句,可以使用TableEnvironment中的executeSql 方法执行,也可以在SQL CLI中执行 INSERT 语句。executeSql 方法执行 INSERT 语句时会立即提交一个 Flink 作业,并且返回一个 TableResult 对象,通过该对象可以获取 JobClient 方便的操作提交 ...

2020-11-28 17:34 0 2509 推荐指数:

查看详情

Flink基础(三十五):FLINK-SQL语法(十一)DDL(七)SHOW 语句

0 简介 SHOW 语句用于列出所有的 catalog,或者列出当前 catalog 中所有的 database,或者列出当前 catalog 和当前 database 的所有表或视图,或者列出所有的 function,包括:临时系统 function,系统 function,临时 ...

Sun Nov 29 02:03:00 CST 2020 0 458
Flink基础(三十四):FLINK-SQL语法(十)DDL(六)USE 语句

USE 语句用来设置当前的 catalog 或者 database。 1 运行一个 USE 语句 可以使用 TableEnvironment 中的 executeSql() 方法执行 USE 语句,也可以在 SQL CLI 中执行 USE 语句。 若 USE 操作执行成功,executeSql ...

Sun Nov 29 01:56:00 CST 2020 0 434
Flink基础(二十八):FLINK-SQL语法(四)DDL(一)CREATE 语句

0 简介 CREATE 语句用于向当前或指定的 Catalog 中注册表、视图或函数。注册后的表、视图和函数可以在 SQL 查询中使用。 目前 Flink SQL 支持下列 CREATE 语句: CREATE TABLE CREATE DATABASE CREATE VIEW ...

Sun Nov 29 01:14:00 CST 2020 0 3990
 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM