MRS _HDFS_Client.tar tar -xvf MRS_HDFS_ClientConfig.tar 由于不兼容老版本客户端，建议用户获取与服务端集群相同版本的客户端安装包进行安装部署。 进入解压文件夹，即“MRS_HDFS_ClientConfig”，执行下列命令安装客户端。 sh

查看更多 →

户表。该方法的作用与listTables类似，只是该方法返回类型为TableName[]。 TableName[] listTableNames(final Pattern pattern, final boolean includeSysTables) 作用与上一个方法类似，用

查看更多 →

。 系统中不保留文件与LocatorId的映射关系，只保留节点与LocatorId的映射关系。当文件使用Colocation接口创建时，系统会将文件创建在LocatorId所对应的节点上。文件创建和写入要求使用Colocation相关接口。 文件写入完毕后，后续对该文件的相关操作

查看更多 →

法来进行异步发送结果的处理。 Consumer重要接口 表3 Consumer重要参数 参数 描述 备注 bootstrap.servers Broker地址列表 消费者通过此参数值，创建与Broker之间的连接。 security.protocol 安全协议类型 消费者使用的安

查看更多 →

JavaPairDStream：KV DStream的接口，提供reduceByKey和join等操作。 JavaReceiverInputDStream<T>：定义任何从网络接受数据的输入流。 Spark Streaming的常见方法与Spark Core类似，下表罗列了Spark Streaming特有的一些方法。

查看更多 →

eByKey。 对应的Spark Streaming的JAVA API是JavaStreamingContext，JavaDStream和JavaPairDStream。 Spark Streaming的常见方法与Spark Core类似，下表罗列了Spark Streaming特有的一些方法。

查看更多 →

T> reduce(ReduceFunction<T> reducer) 在一个KeyedStream上“滚动”reduce。合并当前元素与上一个被reduce的值，然后输出新的值。注意三者的类型是一致的。 public <R> SingleOutputStreamOperator<R>

查看更多 →

reduce(fun: (T, T) => T): DataStream[T] 在一个KeyedStream上“滚动”reduce。合并当前元素与上一个被reduce的值，然后输出新的值。注意三者的类型是一致的。 def reduce(reducer: ReduceFunction[T]):

查看更多 →

reduce(fun: (T, T) => T): DataStream[T] 在一个KeyedStream上“滚动”reduce。合并当前元素与上一个被reduce的值，然后输出新的值。注意三者的类型是一致的。 def reduce(reducer: ReduceFunction[T]):

查看更多 →

itApplicationRequest request) Client通过此接口提交一个新的应用到RM。 ApplicationMasterProtocol 用于ApplicationMaster与ResourceManager之间。ApplicationMaster使用该协议

查看更多 →

户表。该方法的作用与listTables类似，只是该方法返回类型为TableName[]。 TableName[] listTableNames(final Pattern pattern, final boolean includeSysTables) 作用与上一个方法类似，用

查看更多 →

HDFS C API接口介绍 功能简介 C语言应用开发代码样例中所涉及的文件操作主要包括创建文件、读写文件、追加文件、删除文件。完整和详细的接口请直接参考官网上的描述以了解其使用方法： http://hadoop.apache.org/docs/r3.1.1/hadoop-pro

查看更多 →

JavaPairDStream：KV DStream的接口，提供reduceByKey和join等操作。 JavaReceiverInputDStream<T>：定义任何从网络接受数据的输入流。 Spark Streaming的常见方法与Spark Core类似，下表罗列了Spark Streaming特有的一些方法。

查看更多 →

reduce(fun: (T, T) => T): DataStream[T] 在一个KeyedStream上“滚动”reduce。合并当前元素与上一个被reduce的值，然后输出新的值。注意三者的类型是一致的。 def reduce(reducer: ReduceFunction[T]):

查看更多 →

使用API接口创建流 前提条件 获取API接口 创建连接器 创建流 运行流 父主题： 进阶能力

查看更多 →

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

查看更多 →

Alluxio API接口介绍 Java API Alluxio接口遵循标准的Alluxio Parent API标准，详情请见https://docs.alluxio.io/os/javadoc/2.0/index.html。 HTTP REST API Master REST

查看更多 →

常用Oozie API接口介绍 Oozie Shell接口介绍 Oozie Java接口介绍 Oozie REST接口介绍 父主题： Oozie应用开发常见问题

查看更多 →

JavaPairDStream：KV DStream的接口，提供reduceByKey和join等操作。 JavaReceiverInputDStream<T>：定义任何从网络接受数据的输入流。 Spark Streaming的常见方法与Spark Core类似，下表罗列了Spark Streaming特有的一些方法。

查看更多 →

eByKey。 对应的Spark Streaming的JAVA API是JavaStreamingContext，JavaDStream和JavaPairDStream。 Spark Streaming的常见方法与Spark Core类似，下表罗列了Spark Streaming特有的一些方法。

查看更多 →

itApplicationRequest request) Client通过此接口提交一个新的应用到RM。 ApplicationMasterProtocol 用于ApplicationMaster与ResourceManager之间。ApplicationMaster使用该协议

查看更多 →