流式计算 Flink 版支持通过可视化向导快速生成 Flink SQL。您可以选择数据来源和数据目的地、配置字段映射与字段处理规则，然后创建新任务或将 SQL 插入已有任务。

快速生成 Flink SQL 适用于表到表同步和常见字段处理场景。系统读取已注册的 Catalog 表结构，生成字段映射和 SQL，减少手动编写表名、字段列表、建表语句和连接器参数的工作量。
典型场景包括：

• 表到表同步或数据入湖：​例如将 Kafka JSON 数据写入 Paimon，或将 Paimon 数据写入已有的 ByteHouse 表。
• 字段级处理：​裁剪或重命名字段，转换字段类型，应用字符串、数值或日期时间函数，并通过 WHERE 条件过滤数据。
• 补充已有任务：​生成同步 SQL，并插入已有 Flink SQL 任务。

• 已创建流式计算 Flink 版实例，并进入目标项目或工作空间。
• 数据来源表和已有目的表已注册到数据目录。

支持的数据来源和数据目的地 #

最终支持范围取决于实例中已接入的数据目录和连接器版本。您可以单击向导右上角的Catalog 能力支持，在连接器支持页签中查看连接器能否作为数据来源、数据目的地或按源 schema 新建表。

支持的字段处理能力 #

可用函数以向导右上角的Catalog 能力支持弹窗中数据处理函数页签的实际展示为准。

进入快速生成 Flink SQL #

1. 进入流式计算 Flink 版控制台。
2. 在左侧导航栏选择任务开发，进入使用引导页面。
3. 单击快速生成 Flink SQL。系统将在当前页签中打开快速生成向导。
   

选择数据来源 #

1. 在数据来源区域依次选择 Catalog、Database 和 Table。
2. 按需添加 Hint 参数。单击参数名称输入框后，可以选择系统根据连接器推荐的参数，也可以手动输入参数名称和值。
3. 在字段映射区域中确认系统已读取来源表字段，并显示字段名称和字段类型。

配置数据目的地 #

数据目的地支持以下两种配置方式：

调整字段映射 #

选择已有目的表后，系统以目的表结构为准生成初始映射：

• 目的表中不存在的来源字段不会纳入当前字段映射和生成的 SQL。该行为不会删除来源表中的实际字段。
• 已映射字段的类型不一致时，系统按目的字段类型自动生成 CAST 表达式。

您可以在字段映射区域执行以下操作：

• 启用或不启用字段，控制字段是否写入目的表。
• 修改目的字段名称。
• 在新建表模式下修改目的字段类型。
• 为字段添加类型转换或数据处理函数。
• 配置 WHERE 过滤条件。

调整后，请通过字段映射概览和 SQL 预览确认最终字段、类型、表达式与顺序。

检查生成的 SQL #

右侧 SQL 预览会随配置实时更新。您可以展开或收起预览区域；该操作仅改变页面布局，不影响当前配置和 SQL 生成结果。

提交前，依次完成以下检查：

• 在引擎版本下拉框中选择当前 SQL 对应的 Flink 引擎版本。
• 单击字段映射概览，检查来源字段、来源类型、目的字段、目的类型及映射关系。
• 确认表名、目的字段顺序、类型转换、函数表达式、Hint 参数、WITH 参数和 WHERE 条件符合预期。
• 单击复制可以复制当前 SQL。
• 单击验证，然后在确认弹窗中单击快速验证。验证失败时，根据错误详情返回相应配置项修改；验证通过仅表示未发现语法问题。

创建新任务 #

1. 单击创建新任务。
2. 选择处理方式（流式或批式）。
3. 填写作业名称，选择存储位置。
   
4. 单击立即创建。系统将生成的 SQL 写入新任务。创建成功后，根据需要选择后续操作：
   • 继续配置：​关闭创建成功提示并留在快速生成 Flink SQL 页面，继续配置或创建其他任务。
   • 开发任务：​跳转到任务开发页面并打开新建任务。您可以继续编辑生成的 SQL，并执行格式化、验证、保存和上线等操作。

插入已有任务 #

1. 单击插入已有任务。
2. 在任务列表中选择目标 SQL 任务，并在右侧预览现有 SQL。
3. 选择插入位置：文件末尾或选中行前。
4. 确认待插入的 SQL 片段后，单击确定。
   

批量处理字段 #

在字段映射区域勾选一个或多个字段后，可以使用字段映射区域右上角的操作按钮批量处理所选字段。操作结果会实时反映在 SQL 预览中。

• 不启用：​从 INSERT 目的字段列表和对应的 SELECT 表达式中移除所选字段。该操作不会删除来源表或已有目的表中的实际字段。
• 启用：​将已裁剪字段重新加入同步 SQL。启用后，请检查字段映射和输入、输出类型。
• 重命名：​统一增加前缀、增加后缀或按正则表达式替换目的字段名称。选择已有目的表时，修改后的名称需与目的表实际字段对应。
• 类型转换：​为所选字段批量应用 CAST 或数据处理函数。

选择字段映射编辑模式 #

建议优先使用可视化映射。仅当可视化控件无法表达所需逻辑时，再切换到直接编辑 SQL。

查看和撤销调整历史 #

单击字段映射区域搜索框右侧的操作记录，可以查看单字段调整和批量调整。入口上的数字表示当前记录的操作数量。

• 查看操作明细：​查看操作类型、字段名称等信息。
  
• 逐步撤回：​单击当前可撤销记录右侧的撤回操作。如需撤回较早的记录，请先撤回其后的操作。
• 撤销全部：​单击撤销全部并确认，清除当前操作记录并恢复全部调整。

为什么部分连接器不能新建目的表？
当前仅 LAS-Hive、Paimon 和 Iceberg 支持新建目的表。实际能力以 Catalog 能力支持中的展示为准。
为什么选择已有目的表后，部分来源字段不见了？
系统会以目的表结构生成字段映射。目的表中不存在的来源字段不会写入当前 SQL，但不会删除来源表中的实际字段。详情参见附：SQL 生成规则
为什么 CONCAT、SUBSTRING 等函数无法填写完整参数？
可视化映射模式不能配置这类函数所需的额外参数。请切换到 直接编辑 SQL模式补全表达式。右侧 SQL 预览为只读，不能直接修改。
为什么填写的 WHERE 条件没有生效？
独立的 WHERE 输入框仅在可视化映射模式下生效。使用直接编辑 SQL 模式时，需要在 SQL 编辑框中手动编写 WHERE 子句。
为什么切回可视化映射后，手工修改的 SQL 消失了？
两种编辑模式不保证无损切换。从直接编辑 SQL 切回可视化映射前，请先复制并留存当前 SQL。
修改表结构后，为什么向导仍显示旧字段？
向导读取的是数据目录中已同步的表结构。修改表结构后，需要先在目标数据目录中手动执行同步，再返回向导重新选择 Catalog、Database 和 Table。