检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
插入数据至CSS表 功能描述 INSERT INTO命令将DLI表中的数据插入到已关联的指定CSS表中。 语法格式 将SELECT查询结果插入到表中： 1 2 3 4 5 6 7 INSERT INTO DLI_TABLE SELECT field1,field2... [FROM
DML语法定义 DML语句 语法定义 INSERT INTO table_name [PARTITION part_spec] query part_spec: (part_col_name1=val1 [, part_col_name2=val2, ...]) query:
内置函数 数学运算函数 字符串函数 时间函数 类型转换函数 聚合函数 表值函数 其他函数 父主题： Flink SQL语法参考（不再演进，推荐使用Flink OpenSource SQL）
创建输入流 CloudTable HBase输入流 DIS输入流 DMS输入流 EdgeHub输入流（EOS） MRS Kafka输入流 开源Kafka输入流 OBS输入流 父主题： Flink SQL语法参考（不再演进，推荐使用Flink OpenSource SQL）
假设声明了主键的列都是不包含 Null 值的，Connector 在处理数据时需要自己保证语义正确。 注意: 在 CREATE TABLE 语句中，创建主键会修改列的 nullable 属性，主键声明的列默认都是非 Nullable 的。 PARTITIONED BY 根据指定的列对已经创建的表进行分区。若表使用
Kafka Broker节点的hostname和IP请联系Kafka服务的部署人员。如何添加IP域名映射，请参见《数据湖探索用户指南》中修改主机信息章节。 Kafka是线下集群，需要通过增强型跨源连接功能将Flink作业与Kafka进行对接。且用户可以根据实际所需设置相应安全组规则。
或者批模式(BATCH)下输入结束，文件的Pending状态转换为 Finished 状态 只有 Finished 状态下的文件才能被下游安全读取，并且保证不会被修改。 默认的，Part文件命名策略如下: In-progress / Pending：part-<uid>-<partFileIndex>.inprogress
SQL语法约束与定义 语法支持类型 语法定义 父主题： Flink Opensource SQL1.10语法参考
假设声明了主键的列都是不包含 Null 值的，Connector 在处理数据时需要自己保证语义正确。 注意: 在 CREATE TABLE 语句中，创建主键会修改列的 nullable 属性，主键声明的列默认都是非 Nullable 的。 PARTITIONED BY 根据指定的列对已经创建的表进行分区。若表使用
窗口 GROUP WINDOW 语法说明 Group Window定义在GROUP BY里，每个分组只输出一条记录，包括以下几种： time_attr可以设置processing-time或者event-time。 time_attr设置为event-time时参数类型为bigint或者timestamp类型。
删除SQL模板 功能介绍 该接口用于批量删除SQL模板。 调试 您可以在API Explorer中调试该接口。 URI URI格式： POST /v1.0/{project_id}/sqls-deletion 参数说明 表1 URI参数说明 参数 是否必选 参数类型 描述 project_id
SQL语法约束与定义 语法支持类型 语法定义 父主题： Flink Opensource SQL1.10语法参考
Kafka Broker节点的hostname和IP请联系Kafka服务的部署人员。如何添加IP域名映射，请参见《数据湖探索用户指南》中修改主机信息章节。 Kafka是线下集群，需要通过增强型跨源连接功能将Flink作业与Kafka进行对接。且用户可以根据实际所需设置相应安全组规则。
行打宽，并输出到print。 如下脚本中的加粗参数请根据实际环境修改。 CREATE CATALOG myhive WITH ( 'type' = 'hive' , 'default-database' = 'demo', 'hive-conf-dir'
效。 CU设置时怎样调小CU范围最大值？ 弹性资源池CU范围的最小值小于等于弹性资源池的实际CUs，如果想要调整的CU范围的最大值小于当前CUs，需要先调小实际CUs。 包年包月计费模式的弹性资源池，通过调小当前弹性资源池中队列的最大CU或删除队列，以调小弹性资源池的实际CUs，
时间函数 Flink SQL所支持的时间函数如表1所示。 函数说明 表1 时间函数 函数 返回值 描述 DATE string DATE 将日期字符串以“yyyy-MM-dd”的形式解析为SQL日期。 TIME string TIME 将时间字符串以“HH:mm:ss”形式解析为SQL时间。
DDL语法定义 CREATE TABLE语句 CREATE VIEW语句 CREATE FUNCTION语句 父主题： 语法定义
关联OBS桶中嵌套的JSON格式数据如何创建表 如果需要关联OBS桶中嵌套的JSON格式数据，可以使用异步模式创建表。 以下是一个示例的建表语句，展示了如何使用 JSON 格式选项来指定 OBS 中的路径： create table tb1 using json options(path
Avro Format 功能描述 Avro格式允许基于Avro schema 读取和写入Avro 数据。目前，Avro schema 从表schema 推导。 支持的Connector Kafka Upsert Kafka 参数说明 表1 参数说明 参数 是否必选 默认值 类型 说明
数据定义语句DDL 创建源表 创建结果表 创建维表 父主题： Flink Opensource SQL1.10语法参考
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
