类。常用接口参见表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的个数。

查看更多 →

请求签名流程 第三方应用对华为云API的访问需经过签名认证。 签名前的准备 下载API网关签名工具，请单击此处下载您需要不同语言的SDK和示例代码。 创建java工程，将解压出来的jar引用到依赖路径中。 签名过程 创建用于签名的请求com.cloud.sdk.DefaultRequest(JAVA)。

查看更多 →

开放接口示例代码 具体操作请参考《云商店开放接口示例工程》，路径如下： 父主题： 云商店开放接口指南

查看更多 →

Kafka Java API接口介绍 Kafka相关接口同开源社区保持一致。 Kafka Java API接口介绍可直接参考开源社区。 详情请参见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。

查看更多 →

类。常用接口参见表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的个数。

查看更多 →

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

查看更多 →

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

查看更多 →

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

查看更多 →

指定所发送消息的序列化方式。 表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。

查看更多 →

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的个数。

查看更多 →

见接口参见表表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。

查看更多 →