全部产品
Search
文档中心

实时计算Flink版:查询脚本

更新时间:Jan 02, 2024

查询脚本支持Call和DDL、DQL、DML语法。您可以通过查询脚本创建管理Catalog、表、数据查询,可以使用explain语法查看执行计划定位问题,也可以实现对Paimon的管理。

功能

脚本查询.png

  • 对SQL语法进行校验,校验失败无法运行。

  • 支持脚本全部语句运行和选中部分语句运行。

  • 支持Call命令和DDL、DQL、DML语法。

    重要

    对DDL或DML语句运行将会直接影响线上元数据或数据,请谨慎操作。

  • 编写的内容每分钟进行一次自动保存,您也可以选择手动将临时查询持久化保存在左侧文件夹下。

操作步骤

  1. 登录实时计算控制台

  2. Flink全托管页签,单击目标工作空间操作列下的控制台

  3. SQL开发页面,单击查询脚本页签。

  4. 单击image.png,新建查询脚本。

  5. 填写SQL代码。

    支持Call命令和DDL、DQL、DML语法。默认使用批模式,您可以使用如下所示的SET语法修改为流模式。

    SET 'execution.runtime-mode' = 'streaming';
  6. 选择或创建Session集群。

    单击页面右下角的执行环境,选择对应版本的Session集群(VVR 8.0.4及以上引擎版本)。如果没有,请参见步骤一:创建Session集群创建Session集群。

  7. 选中目标代码片段后,单击代码行左侧的运行

  8. (可选)单击右上方的保存,设置文件名称和存储位置。

相关文档