检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
SQL”:用户通过编辑SQL语句来启动作业。 名称 作业名称,只能由字母、中文、数字、中划线和下划线组成,并且长度为1~57字节。 说明: 作业名称必须是唯一的。 描述 作业的相关描述,长度为0~512字节。 模板名称 用户可以选择样例模板或自定义的作业模板。关于模板的详细信息,请参见管理Flink作业模板。
array_agg(x ORDER BY y DESC); array_agg(x ORDER BYx,y,z); 过滤filter 使用filter关键字可以在聚合的过程中,通过使用where的条件表达式来过滤掉不需要的行。所有的聚合函数都支持这个功能。 aggregate_function(
purge"='true', "dli.lifecycle.trash.dir"='obs://dli-test/Lifecycle-Trash' ); 关键字 TBLPROPERTIES:表的属性,增加表的生命周期功能。 OPTIONS:新建表的路径,适用于DataSource语法创建OBS表。
[db_name.]table_name OPTIONS(property_name=property_value, ...); 关键字 INPATH:数据路径。 OPTIONS:属性列表。 参数说明 表1 参数描述 参数 描述 folder_path 原始数据文件夹或者文件的OBS路径。
C1,程序包JAR2,因为F2和F1使用相同的类名,导致功能相互冲突,影响作业执行。 如需使用UDF热加载功能请提交工单开通白名单。 关键字 USING <resources>:需要加载的资源。可以是JAR、文件或者URI的列表。 OR REPLACE:支持自定义函数热加载功能。
选择Flink Jar。 名称 作业名称,只能由英文、中文、数字、中划线和下划线组成,并且长度为1~57字节。 说明: 作业名称必须是唯一的。 描述 作业的相关描述,且长度为0~512字节。 标签 使用标签标识云资源。包括标签键和标签值。如果您需要使用同一标签标识多种云资源,即所有服务
replace(string <str>, string <old>, string <new>) STRING 将字符串中与指定字符串匹配的子串替换为另一字符串。 regexp_replace 适用于Spark2.4.5:regexp_replace(string <source>, string
表名长度不能超过128个字符。 表名中不能包含空格和特殊字符,如冒号、分号、斜杠等。 表名不区分大小写,但建议使用小写字母。 Hive保留关键字不能作为表名,如select、from、where等。 示例: my_table、customer_info、sales_data 由于作业
SQL语法相关约束限制 表9 SQL语法相关约束限制 限制项 说明 SQL语法限制 不支持在创建DLI表时指定存储路径。 SQL语句大小限制 须小于500000字符。 须小于1MB。 其他约束限制 表10 DLI其他约束限制 限制项 说明 配额类 DLI配额相关约束限制请参考配额管理操作指导。 浏览器版本要求
含INSERT消息的查询。 在Elasticsearch连接器中,主键用于计算Elasticsearch 的文档ID,文档ID为最多512字节且不包含空格的字符串。 Elasticsearch连接器通过使用 document-id.key-delimiter 指定的键分隔符按照 DDL