检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
DROP CONSTRAINT所需权限列表 权限描述 表的ALTER权限 细粒度权限：dli:table:alter。 由LakeFormation提供的元数据服务，权限配置详见LakeFormation文档。 示例 alter table delta_table0 drop constraint
'table-name' = 'order', 'zookeeper.quorum' = 'ZookeeperAddress:ZookeeperPort' ) ; create table printSink ( order_id string, order_channel string
'table-name' = 'order', 'zookeeper.quorum' = 'ZookeeperAddress:ZookeeperPort' ) ; create table printSink ( order_id string, order_channel string
WRAPPER) -- Scalars must be wrapped to be returned -- NULL JSON_QUERY(1, '$') -- '[1]' JSON_QUERY(1, '$' WITH CONDITIONAL ARRAY WRAPPER) --
Parquet格式的Hive表、Datasource表。 Orc格式Datasource表。 Filter：Filter算子通常由WHERE语句触发，例如：select * from test_table where id = xxx。 使用Explain语句可以查看SQL命令触发的算子类型，例如：Explain
取项目ID。 queue_name 是 String 队列名称。 表2 query参数 参数名称 是否必选 参数类型 说明 limit 是 Integer 分页查询数量。 offset 是 Integer 分页查询偏移量。 请求消息 无请求参数。 响应消息 表3 响应参数 参数名称
所需权限 SQL权限 表2 ALTER TABLE所需权限列表 权限描述 表的ALTER权限 细粒度权限：dli:table:alter。 由LakeFormation提供的元数据服务，权限配置详见LakeFormation文档。 示例 alter table h0 add columns(ext0
读写压力。 命令格式 RUN CLEAN ON tableIdentifier; RUN CLEAN ON tablelocation; 参数描述 表1 参数描述 参数 描述 tableIdentifier Hudi表的名称 tablelocation Hudi表的存储路径 示例
batch_job_info) except DliException as e: print(e) return print(batch_job.job_id) while True: time.sleep(3)
语法格式 开启多版本功能 ALTER TABLE [db_name.]table_name SET TBLPROPERTIES ("dli.multi.version.enable"="true"); 关闭多版本功能 1 2 ALTER TABLE [db_name.]table_name
16 17 18 19 20 21 22 23 24 private static final Logger logger = LoggerFactory.getLogger(FlinkJarJobExample.class); public static void main(String[]
法作业上传数据至DLI。 当前接口已废弃，不推荐使用。 URI URI格式： POST /v1.0/{project_id}/uploader/authentication 参数说明 表1 URI 参数 名称 是否必选 说明 project_id 是 项目编号，用于资源隔离。获取方式请参考获取项目ID。
io.confluent.kafka.serializers.KafkaAvroSerializer序列化的记录，以及可以写入成能被 io.confluent.kafka.serializers.KafkaAvroDeserializer反序列化的记录。 当以这种格式读取（反序列化）记录时，将根据记录中编码的
= './krb5.conf',\ 'keytab'='./user.keytab',\ 'principal' ='krbtest')") 与未开启kerberos认证相比，开启了kerberos认证需要多设置三个参数，如表1所示。 表1 参数说明 参数名称与参数值
io.confluent.kafka.serializers.KafkaAvroSerializer 序列化的记录，以及可以写入成能被 io.confluent.kafka.serializers.KafkaAvroDeserializer 反序列化的记录。 当以这种格式读取（反序列化）记录时，将根据记录中编码的
); INSERT into sink_table SELECT * from orders;""", # 自定义 Stream SQL语句，至少包含source, query, sink三个部分。长度限制：1024*1024个字符。
tableIdentifier/tablelocation; 按保留时间进行清理，需要配置参数： hoodie.archive.file.cleaner.policy = KEEP_ARCHIVED_FILES_BY_DAYS; hoodie.archive.file.cleaner.days.retained
charging_mode 是 Integer 计费模式。 包周期计费模式默认取值为2。 period_type 是 String 包周期类型，year或者month。 枚举值： year：包年 month：包月 period_num 否 Integer 周期数，默认1。 缺省值：1 tags
return url.hostname except Exception as e: logger.error("Failed to get bucket name from full path", e) return None
创建SQL拦截规则 功能介绍 该API用于创建SQL拦截规则，拦截匹配规则的SQL。 调试 您可以在API Explorer中调试该接口，支持自动认证鉴权。API Explorer可以自动生成SDK代码示例，并提供SDK代码示例调试功能。 URI POST /v1/{project_id}/sql-defend-rules
