Flink SQL编辑

创建FLINK_SQL类型的实时作业后，会自动跳转至该作业的编辑页签。

页签中提供了表检索功能，方便用户直接检索表管理中的表，并生成DDL。但Flink SQL编辑框与表检索功能无强关联，表检索功能为辅助性功能，用户可从零开始自行编辑DDL。

 

编辑Flink SQL的步骤如下：

  1. 在页签左侧的表检索区域中，通过数据源类型和表名称检索需要的数据表。该处检索的表为表管理中的数据表，关于如何在表管理中增加数据表，请参见新建表。

  1. 从检索结果中，选择目标表，并单击后方的<生成DDL>按钮，页面左下方的source DDL和sink DDL页签中会生成对应的基本信息。

  1. 单击底部的<复制>按钮，即可复制source DDL或sink DDL内容。

  1. 在右侧的FLINK SQL编辑框中，粘贴复制的内容。自动生成的DDL仅为基本信息，用户可根据实际需求进行修改。

  1. 阶段性编辑完成后，可以单击<暂存>按钮，该操作不会触发预执行。

  1. 全部编辑完成后，可以单击<预执行>按钮，预执行SQL语句包含的功能。预执行后，下方的FLINK SQL预执行日志区域会展示全部SQL语句预执行的日志信息，根据日志信息，可以协助调试和开发。

·          语句前的“数字>”为预执行的次数。

·          预执行过程中，若有语句执行失败，则不再继续执行之后的语句。

·          单击<清空>按钮，可以清空所有日志，并预执行次数将重置为1。

 

  1. 预执行无问题后，可单击Flink SQL编辑框区域的<保存>按钮，系统会自动触发预执行进行检验，并保存SQL语句。

DDL示例（HBase）如下，仅供参考：

CREATE TABLE hTable (

rowkey INT,

family1 ROW<q1 INT>,

family2 ROW<q2 STRING, q3 BIGINT>,

family3 ROW<q4 DOUBLE, q5 BOOLEAN, q6 STRING>,

PRIMARY KEY (rowkey) NOT ENFORCED

) WITH (

'connector' = 'hbase-1.4',

'table-name' = 'mytable',

'zookeeper.quorum' = 'localhost:2181'

)