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

查看更多 →

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

查看更多 →

OpenTSDB HTTP API接口介绍 OpenTSDB提供了基于HTTP或HTTPS的应用程序接口。请求方式是通过向资源对应的路径发送标准的HTTP请求，请求包含GET、POST方法。它的接口与开源OpenTSDB保持一致，请参见https://opentsdb.net/d

查看更多 →

HBase Phoenix API接口介绍 版本关系 若使用Phoenix，需下载与当前使用 MRS 集群相对应的Phoenix版本，具体请参见http://phoenix.apache.org。其对应关系如表1所示： 表1 MRS与Phoenix版本对应关系一览表 MRS版本 Phoenix版本

查看更多 →

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

查看更多 →

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

查看更多 →

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

查看更多 →

常用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特有的一些方法。

查看更多 →

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

查看更多 →

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

查看更多 →

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

查看更多 →

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

查看更多 →

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

查看更多 →

agged方式通过接口。tagged Vlan和untagged Vlan不能有交集，取值范围为1～4094，不支持all。 高级 自协商 缺省关闭。若开启，当前设备接口与直连的设备接口间自动协商双工模式和接口速率，使数据传输能力达到双方都支持的最大值。 接口速率 当且仅当“自协

查看更多 →

接口 支持查看GeminiDB(for Cassandra)数据库SDS SDK接口调用统计数据，帮助业务快速定位问题接口。 全量接口洞察 可以查看选定时间范围内客户端接口调用多种指标排序、历史趋势，方便用户分析接口调用量、时延、成功率等异常。 进入运维中心工作台。 在顶部导航栏选择自有服务。

查看更多 →

接口 支持查看GeminiDB(for Cassandra)数据库SDS SDK接口调用统计数据，帮助业务快速定位问题接口。 全量接口洞察 可以查看选定时间范围内客户端接口调用多种指标排序、历史趋势，方便用户分析接口调用量、时延、成功率等异常。 进入运维中心工作台。 在顶部导航栏选择自有服务。

查看更多 →

允许通过的VLAN应包含需要通过该接口所有报文所属VLAN ID。 允许通过的VLAN 高级 接口速率 自协商：用于该网口与直连的另一设备的网口之间自动协商双工模式和接口速率，使数据传输能力达到双方都支持的最大值。如果对端网口所属设备不支持自协商，或者自协商机制与本端不一致，可以将两端网口

查看更多 →

查询API接口的版本信息 功能介绍 查询接口的指定版本信息。 调用方法 请参见如何调用API。 URI GET /{version} 表1 路径参数 参数 是否必选 参数类型 描述 version 是 String 查询的目标版本号。 取值为：v1、v2、v3。 枚举值： v1 v2

查看更多 →

source bigdata_env kinit 组件业务用户 kinit一次票据时效24小时。24小时后再次运行样例，需要重新kinit。 与HTTP服务访问相比，以HTTPS方式访问Yarn时，由于使用了SSL安全加密，需要确保Curl命令所支持的SSL协议在集群中已添加支持。若

查看更多 →