检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
为0则表示不根据时间刷新 connector.write.max-retries 否 3 Integer 写数据失败时的最大尝试次数，默认值为：3。 示例 从Kafka中读取数据，并将数据插入到数据库为flink、表名为order的ClickHouse数据库中，其具体步骤如下（clickhouse版本为MRS的21
window_interval, period_interval, lateness_interval) 语法示例 例如当前time_attr属性列为：testtime，窗口时间间隔为10秒，语法示例为： TUMBLE(testtime, INTERVAL '10' SECOND, INTERVAL
jar httpcore-nio-4.4.4.jar - Flink 1.7.2 依赖包 Flink 1.7.2作业程序开发的样例代码可以参考DLI样例代码中的“luxor-demo\dli-flink-demo”。 表6 Flink 1.7.2 依赖包 依赖包名称 bcpkix-jdk15on-1
is_partition_column 是 Boolean 表示该列是否为分区列，“true”表示为分区列，“false”为非分区列，默认为“false”。 请求示例 无 响应示例 MANAGED类型表 { "is_success": true, "message": "", "column_count":
选择Spark版本。在下拉列表中选择支持的Spark版本，推荐使用最新版本。 不建议长期混用不同版本的Spark引擎。 长期混用不同版本的Spark引擎会导致代码在新旧版本之间不兼容，影响作业的执行效率。 当作业依赖于特定版本的库或组件，长期混用不同版本的Spark引擎可能会导致作业因依赖冲突而执行失败。
需要指定DATEFORMAT及TIMESTAMPFORMAT选项，否则将以默认的日期及时间戳格式进行解析。 示例 导入数据前已参考创建OBS表或者创建DLI表中的示例描述创建对应的表。 可使用下列语句将CSV文件导入到DLI表，“t”为表名。 1 2 LOAD DATA INPATH
ency的DLI云服务委托并授权。 该委托需新建后自定义权限，但委托名称固定为dli_data_clean_agency。 委托的权限策略示例请参考常见场景的委托权限策略。 其他自定义委托 自定义委托 使用Flink 1.15和Spark 3.3及以上版本的引擎执行作业时，请自行
https://{Endpoint}/v3/projects”，其中{Endpoint}为IAM的终端节点，可以从地区和终端节点获取。 响应示例如下，例如DLI服务部署的区域为“cn-north-4”，相应消息体中查找“name”为“cn-north-4”，其中projects下的“id”即为项目ID。
7天范围内。 注意事项 DLI数据多版本功能当前仅支持通过Hive语法创建的OBS表，具体建表语法可以参考使用Hive语法创建OBS表。 示例 在DLI数据多版本中，设置备份数据保留时间为5天。 1 2 ALTER TABLE test_table SET TBLPROPERTIES
不限制开始时间。 end_time 运行模式为dry_run、repair时有效，产生无效数据文件的结束时间，可选，默认不限制结束时间。 示例 call clean_file(table => 'h1', mode=>'repair'); call clean_file(table
目录的子目录的信息 否 sort 默认true，true表示根据storage_size排序结果，false表示根据文件数量排序结果 否 示例 call show_fs_path_detail(path=>'obs://bucket/path/hudi_mor/dt=2021-08-28'
添加EXTENDED关键字会将表的所有元数据信息以“Thrift”序列化的格式显示出来。 添加FORMATTED关键字会将表的元数据信息以表格的形式展示。 示例 显示fruit数据表的列信息： DESCRIBE fruit; 显示fruit 元数据信息： DESCRIBE FORMATTED fruit;
is_async 否 Boolean 是否使用异步方式上传资源包。默认值为“false”，表示不使用异步方式。推荐使用异步方式上传资源包。 请求示例 从OBS上传jar包至DLI，并定义分组名称为gatk。 { "paths": [ "https://xkftest
临时文件也会被删除掉。 分区功能 Filesystem sink支持分区功能，通过partitioned by语法根据选择的字段进行分区。示例如下： path └── datetime=2022-06-25 └── hour=10 ├── part-0.parquet
DATABASE与SCHEMA两者没有区别，可替换使用，建议使用DATABASE。 “default”为内置数据库，不能创建名为“default”的数据库。 示例 完整的SQL作业提交流程您可以参考《快速入门》中的《提交SQL作业》等章节描述。 队列是使用DLI服务的基础，执行SQL前需要先创建队列
AG2由tags指定。 TAG1 String TAG2 String timestamp Timestamp value double 示例 1 2 3 4 5 CREATE table opentsdb_table USING OPENTSDB OPTIONS ( 'host'
对查询结果进行限制，num参数仅支持INT类型。 values_row 想要插入到表中的值，列与列之间用逗号分隔。 注意事项 DLI表必须已经存在。 示例 查询表“user”中的数据插入表“test”中。 1 2 3 4 5 6 INSERT INTO test SELECT ATTR_EXPR
DLI数据多版本功能当前仅支持通过Hive语法创建的OBS表，具体建表SQL语法可以参考使用Hive语法创建OBS表。 该命令不会删除当前版本数据。 示例 删除dliTable表在2021-09-25 23:59:59之前生成的多版本数据（多版本生成时会自带一个生成时间时的时间戳）。 clear
from V limit 10，则最终只有5条数据返回。 限制 以上两种语法不可混用。 当视图包含分区，那么将无法通过这个语法来改变定义。 示例 CREATE OR REPLACE VIEW tv_view as SELECT id,name from (values (1, 'HetuEngine'))
column_name 位置修改参照列，例如：AFTER column_name的语义是要将待修改列放到参照列column_name之后。 示例 列类型修改 ALTER TABLE table1 ALTER COLUMN a.b.c TYPE bigint a.b.c 表示嵌套列全路径，嵌套列具体规则见ADD
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
