Name'= 'Metric Value']* 举例：SizeOfHFileRefsQueue=0, AgeOfLastShippedOp=0 表2 org.apache.hadoop.hbase.replication.ReplicationLoadSource 方法 描述 getPeerID()

查看更多 →

方法 说明 T reduce(Function2<T,T,T> f) 对RDD中的元素调用Function2。 java.util.List<T> collect() 返回包含RDD中所有元素的一个数组。 long count() 返回的是dataset中的element的个数。

查看更多 →

Manager注册、申请资源、获取各个任务的运行情况等。 表2 ApplicationMasterProtocol常用方法 方法 说明 allocate(AllocateRequest request) AM通过此接口提交资源分配申请。 finishApplicationMast

查看更多 →

类。常用接口参见表1。 FileStatus：记录文件和目录的状态信息。常用接口参见表2。 DFSColocationAdmin：管理colocation组信息的接口。常用接口参见表3。 DFSColocationClient：操作colocation文件的接口。常用接口参见表4。

查看更多 →

Kafka Java API接口介绍 Kafka相关接口同开源社区保持一致，详情请参见http://kafka.apache.org/documentation.html#api。 父主题： Kafka接口介绍

查看更多 →

见接口参见表表2。 表1 org.apache.hadoop.hbase.client.Admin 方法 描述 boolean tableExists(final TableName tableName) 通过该方法可以判断指定的表是否存在。如果hbase:meta表中存在该表则返回true，否则返回false。

查看更多 →

权限 登录华为云主账号，访问“统一身份认证服务”。 选择需要访问的IAM子用户。 勾选“编程访问”后，点击确定即可。 请求签名流程 第三方应用对华为云API的访问需经过签名认证。 签名前的准备 下载API网关签名工具。 请单击此处下载后，解压下载的压缩包。 创建java工程，将解压出来的jar引用到依赖路径中。

查看更多 →

见接口参见表表2。 表1 org.apache.hadoop.hbase.client.Admin 方法 描述 boolean tableExists(final TableName tableName) 通过该方法可以判断指定的表是否存在。如果hbase:meta表中存在该表则返回true，否则返回false。

查看更多 →

类。常用接口参见表1。 FileStatus：记录文件和目录的状态信息。常用接口参见表2。 DFSColocationAdmin：管理colocation组信息的接口。常用接口参见表3。 DFSColocationClient：操作colocation文件的接口。常用接口参见表4。

查看更多 →

Manager注册、申请资源、获取各个任务的运行情况等。 表2 ApplicationMasterProtocol常用方法 方法 说明 allocate(AllocateRequest request) AM通过此接口提交资源分配申请。 finishApplicationMast

查看更多 →

JoinedStreams<T, T2> join(DataStream<T2> otherStream) 通过给定的key在一个窗口范围内join两条数据流。 public <T2> CoGroupedStreams<T, T2> coGroup(DataStream<T2> otherStream)

查看更多 →

类。常用接口参见表1。 FileStatus：记录文件和目录的状态信息。常用接口参见表2。 DFSColocationAdmin：管理colocation组信息的接口。常用接口参见表3。 DFSColocationClient：操作colocation文件的接口。常用接口参见表4。

查看更多 →

指定所发送消息的序列化方式。 表2 Producer重要接口函数 返回值类型 接口函数 描述 java.util.concurrent.Future<RecordMetadata> send(ProducerRecord<K,V> record) 不带回调函数的发送接口，通常使用Future

查看更多 →

方法 说明 T reduce(Function2<T,T,T> f) 对RDD中的元素调用Function2。 java.util.List<T> collect() 返回包含RDD中所有元素的一个数组。 long count() 返回的是dataset中的element的个数。

查看更多 →

JoinedStreams<T, T2> join(DataStream<T2> otherStream) 通过给定的key在一个窗口范围内join两条数据流。 public <T2> CoGroupedStreams<T, T2> coGroup(DataStream<T2> otherStream)

查看更多 →

类。常用接口参见表1。 FileStatus：记录文件和目录的状态信息。常用接口参见表2。 DFSColocationAdmin：管理colocation组信息的接口。常用接口参见表3。 DFSColocationClient：操作colocation文件的接口。常用接口参见表4。

查看更多 →

方法 说明 T reduce(Function2<T,T,T> f) 对RDD中的元素调用Function2。 java.util.List<T> collect() 返回包含RDD中所有元素的一个数组。 long count() 返回的是dataset中的element的个数。

查看更多 →

JoinedStreams<T, T2> join(DataStream<T2> otherStream) 通过给定的key在一个窗口范围内join两条数据流。 public <T2> CoGroupedStreams<T, T2> coGroup(DataStream<T2> otherStream)

查看更多 →

Manager注册、申请资源、获取各个任务的运行情况等。 表2 ApplicationMasterProtocol常用方法 方法 说明 allocate(AllocateRequest request) AM通过此接口提交资源分配申请。 finishApplicationMast

查看更多 →

SignedHeaders=host;x-sdk-date, Signature=26b2abfa40a4acf3c38b286cb6cbd9f07c2c22d1285bf0d4f6cf1f02d3bfdbf6] [main] INFO com.huawei.apig.sdk.demo.HttpClientDemo -

查看更多 →

g sql) 执行查询语句。 void executeNonQueryStatement(String sql) 执行非查询语句。 表2 测试接口说明 方法 说明 void testInsertRecords(List<String> deviceIds, List<Long> times

查看更多 →