rue的元素。 聚合能力 表4 聚合能力的相关接口 API 说明 public KeyedStream<T, Tuple> keyBy(int... fields) 将流逻辑分区成不相交的分区，每个分区包含相同key的元素。内部是用hash分区来实现的。这个转换返回了一个KeyedStream。

查看更多 →

Kafka Java API接口介绍 Kafka相关接口同开源社区保持一致，详情请参见https://kafka.apache.org/24/documentation.html。 Producer重要接口 表1 Producer重要参数 参数 描述 备注 bootstrap.servers

查看更多 →

计算统计信息，包含计数，平均值，标准差，最小值和最大值。 Row first() 返回第一行。 Row[] head(int n) 返回前n行。 void show() 用表格形式显示DataFrame的前20行。 Row[] take(int n) 返回DataFrame中的前n行。 表7 基本的DataFrame

查看更多 →

describe() 计算统计信息，包含计数，平均值，标准差，最小值和最大值。 first() 返回第一行。 head(n) 返回前n行。 show() 用表格形式显示DataFrame。 take(num) 返回DataFrame中的前num行。 表5 基本的DataFrame Functions

查看更多 →

资质提交支持API接口吗？ 消息&短信服务申请资质暂未提供接口，请在短信控制台提交申请，具体操作请参见短信资质管理。 父主题： 资质相关

查看更多 →

怎么变更用例执行人？ 用例的主执行人可以变更用例执行人，点击用例管理界面的流程历史按钮，第一个用例执行人就是主执行人，主执行人可以看到【变更执行人】按钮，点击进行变更 需求提交人可以在需求提交阶段，编辑需求里的流程图，修改流程图里的执行人，修改后提交需求审核通过后，用例的执行人即可被修改

查看更多 →

资产安装（API接口：installTaskScenes） 功能介绍 安装资料文件 相关接口 接口名称 调用说明 获取Token 调用该接口获取到Token，再调用其他接口时，需要在请求消息头中添加“Authorization”，其值即为Token。 URL 请求方式 HTTPS地址

查看更多 →

YARN Java API接口介绍 关于YARN的详细API可以直接参考官方网站上的描述： http://hadoop.apache.org/docs/r3.1.1/api/index.html 常用接口 YARN常用的Java类有如下几个。 ApplicationClientProtocol

查看更多 →

Kafka Java API接口介绍 Kafka相关接口同开源社区保持一致，详情请参见https://kafka.apache.org/24/documentation.html。 Producer重要接口 表1 Producer重要参数 参数 描述 备注 bootstrap.servers

查看更多 →

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

查看更多 →

计算统计信息，包含计数，平均值，标准差，最小值和最大值。 Row first() 返回第一行。 Row[] head(int n) 返回前n行。 void show() 用表格形式显示DataFrame的前20行。 Row[] take(int n) 返回DataFrame中的前n行。 表7 基本的DataFrame

查看更多 →

describe() 计算统计信息，包含计数，平均值，标准差，最小值和最大值。 first() 返回第一行。 head(n) 返回前n行。 show() 用表格形式显示DataFrame。 take(num) 返回DataFrame中的前num行。 表5 基本的DataFrame Functions

查看更多 →

rue的元素。 聚合能力 表4 聚合能力的相关接口 API 说明 public KeyedStream<T, Tuple> keyBy(int... fields) 将流逻辑分区成不相交的分区，每个分区包含相同key的元素。内部是用hash分区来实现的。这个转换返回了一个KeyedStream。

查看更多 →

返回第一行。 Head(n:Int): Row 返回前n行。 show(numRows: Int, truncate: Boolean): Unit 用表格形式显示DataFrame。 take(n:Int): Array[Row] 返回DataFrame中的前n行。 表7 基本的DataFrame

查看更多 →

类DFSColocationClient常用接口说明 接口 说明 public FSDataOutputStream create(Path f, boolean overwrite, String groupId,String locatorId) 用colocation模式，创建一个F

查看更多 →

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

查看更多 →

rue的元素。 聚合能力 表4 聚合能力的相关接口 API 说明 public KeyedStream<T, Tuple> keyBy(int... fields) 将流逻辑分区成不相交的分区，每个分区包含相同key的元素。内部是用hash分区来实现的。这个转换返回了一个KeyedStream。

查看更多 →

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

查看更多 →

类DFSColocationClient常用接口说明 接口 说明 public FSDataOutputStream create(Path f, boolean overwrite, String groupId,String locatorId) 用colocation模式，创建一个F

查看更多 →

计算统计信息，包含计数，平均值，标准差，最小值和最大值。 Row first() 返回第一行。 Row[] head(int n) 返回前n行。 void show() 用表格形式显示DataFrame的前20行。 Row[] take(int n) 返回DataFrame中的前n行。 表6 基本的DataFrame

查看更多 →

StorageLevel = StorageLevel.MEMORY_AND_DISK_SER_2): ReceiverInputDStream[String] 用TCP协议（源主机:端口）创建一个输入流。 start():Unit 启动Streaming计算。 awaitTermination(timeout:

查看更多 →