BULK_INSERT（批量插入）：用于初始数据集加载， 该操作会对主键进行排序后直接以写普通parquet表的方式插入Hudi表，该操作性能是最高的，但是无法控制小文件，而UPSERT和INSERT操作使用启发式方法可以很好的控制小文件。 UPSERT（插入更新）： 默认操作类型。

查看更多 →

参数 是否必选 参数类型 描述 project_id 是 String 项目ID，获取方法请参见获取项目ID/账号名/AK/SK。 请求参数 表2 请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户Token。 用于获取操作API的权限。获取方法请参见认证鉴权。

查看更多 →

properties等配置文件放置到工程的“conf”目录下。 在“conf”目录创建“jaas_mr.conf”文件并添加如下内容（test是user.keytab对应的用户名称）： Client { com.sun.security.auth.module.Krb5LoginModule

查看更多 →

data elasticsearch版本是4.2.x。 准备工作 CSS 集群处于可用状态。 确保运行Java代码的 服务器 与 CS S集群的网络是互通的。 确认服务器已安装JDK1.8，JDK1.8官网下载地址：http://www.oracle.com/technetwork/jav

查看更多 →

路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID，获取方法请参见获取项目ID/账号名/AK/SK。 face_set_name 是 String 人脸库名称。 field_name 是 String 按条件删除的字段名，支持固定字段（exter

查看更多 →

分配给HFile/StoreFile所使用的块缓存的最大heap（-Xmx setting）的百分比。 当offheap关闭时，默认值为0.25。当offheap开启时，默认值是0.1。 父主题： HBase常见问题

查看更多 →

什么是 域名注册服务 ？ 域名 注册（Domain Registration）是用户付费获取Internet上某一域名一段时间使用权的过程。华为云域名注册服务提供域名的注册购买、实名认证以及管理功能。 华为云域名注册服务是指以 华为云计算 技术有限公司作为经营域名注册服务的主体，向您提供域名注册及后续域名管理服务。

查看更多 →

搜索文件创建到出现异常时间范围的NameNode的审计日志，搜索该文件是否被删除或者移动到其他目录。 如果该文件没有被删除或者移动，可能是该文件的父目录，或者更上层目录被删除或者移动，需要继续搜索上层目录。如本样例中，是文件的父目录被删除。 2017-05-31 02:04:08,286 | INFO | IPC Server

查看更多 →

出参 序号 属性 描述 参数位置 数据类型 示例值 备注 1 success 执行结果 Body String SUCCESS API返回的是角色名称，项目管理需要返回的值关联关系的oid和otype 2 code 响应码 Body String 200 - 3 message 错误信息

查看更多 →

收发顺序消息 顺序消息是分布式消息服务RocketMQ版提供的一种严格按照顺序来发布和消费的消息类型。 顺序消息分为全局顺序消息和分区顺序消息： 全局顺序消息：对于指定的一个Topic，将队列数量设置为1，这个队列内所有消息按照严格的先入先出FIFO（First In First

查看更多 →

用户查询设备列表 URI GET /v1/{user_id}/devices 表1 路径参数 参数 是否必选 参数类型 描述 user_id 是 String 用户ID：由数字组成，长度范围[15,25]，获取方式参考获取user ID与下载AK/SK章节 表2 Query参数 参数

查看更多 →

分配给HFile/StoreFile所使用的块缓存的最大heap（-Xmx setting）的百分比。 当offheap关闭时，默认值为0.25。当offheap开启时，默认值是0.1。 父主题： HBase常见问题

查看更多 →

#构造函数入参引用环境变量，使用`${ENV-[NAME]}`方式来引用 #NAME必须是一个已经定义的环境变量 - id: "zkHosts" className: "org.apache.storm.kafka.ZkHosts" constructorArgs:

查看更多 →

#构造函数入参引用环境变量，使用`${ENV-[NAME]}`方式来引用 #NAME必须是一个已经定义的环境变量 - id: "zkHosts" className: "org.apache.storm.kafka.ZkHosts" constructorArgs:

查看更多 →

可以选择在一次“transform”方法调用中输出任意数量的数据点。需要注意的是，输出数据点的类型必须与在“beforeStart”方法中设置的一致，而输出数据点的时间戳必须是严格单调递增的。 下面是一个实现了“void transform(Row row, PointCollector

查看更多 →

数据表复制样例代码 用户可以根据实际的业务需求基于HBase API开发应用程序，复制表数据到集群。以下样例代码，可供用户参考。 以下样例代码的场景是将一个集群的表数据复制到另一个集群中。 package com.huawei.cloudtable.hbase.tool.client; import

查看更多 →

dew.projectId 否 有 String DEW所在的项目ID， 默认是Flink作业所在的项目ID。 获取项目ID flink.hadoop.fs.dew.csms.secretName 是 无 String 在DEW服务的凭据管理中新建的通用凭据的名称。 配置示例：flink

查看更多 →

#构造函数入参引用环境变量，使用`${ENV-[NAME]}`方式来引用 #NAME必须是一个已经定义的环境变量 - id: "zkHosts" className: "org.apache.storm.kafka.ZkHosts" constructorArgs:

查看更多 →

<groupId>org.apache.rocketmq</groupId> <artifactId>rocketmq-client-java</artifactId> <version>5.0.5</version> </dependency> 同步发送 同步发送是指消息发

查看更多 →

Client，实现自定义的Elasticsearch请求内容。 准备工作 CSS集群处于可用状态。 确保运行Java代码的服务器与CSS集群的网络是互通的。 确认服务器已安装JDK1.8，JDK1.8官网下载地址：http://www.oracle.com/technetwork/jav

查看更多 →

application/json 是 无 Authorization bearer ${access_token} 是 bearer +“ ”+5.2.1中获取的access_token的值 请求参数 参数 类型 是否必填 描述 beginTimestamp Long 是 查询的开始时间段 endTimestamp

查看更多 →