函数实现对发送结果的处理。 void onCompletion(RecordMetadata metadata, Exception exception); 回调函数接口方法，通过实现Callback中的此方法来进行异步发送结果的处理。 Consumer重要接口 表3 Consumer重要参数

查看更多 →

count() 返回的是dataset中的element的个数。 T first() 返回的是dataset中的第一个元素。 java.util.List<T> take(int num) 返回前n个elements。 java.util.List<T> takeSample(boolean

查看更多 →

提供迭代的能力 表9 提供迭代的能力的相关接口 API 说明 public IterativeStream<T> iterate() 在流(flow)中创建一个带反馈的循环，通过重定向一个operator的输出到之前的operator。 说明： 对于定义一些需要不断更新模型的算法是非常有帮助的。

查看更多 →

提供迭代的能力 表9 提供迭代的能力的相关接口 API 说明 public IterativeStream<T> iterate() 在流(flow)中创建一个带反馈的循环，通过重定向一个operator的输出到之前的operator。 说明： 对于定义一些需要不断更新模型的算法是非常有帮助的。

查看更多 →

long len) 通过该接口可查找指定文件在HDFS集群上块的位置，其中file为文件的完整路径，start和len来标识查找文件的块的范围。 public FSDataInputStream open(Path f) 通过该接口可以打开HDFS上指定文件的输出流，并可通过FSDa

查看更多 →

count() 返回的是dataset中的element的个数。 T first() 返回的是dataset中的第一个元素。 java.util.List<T> take(int num) 返回前n个elements。 java.util.List<T> takeSample(boolean

查看更多 →

int numRegions) 创建一个有指定数量region的表，其中第一个region的endKey为参数中的startKey，最后一个region的StartKey为参数中的endKey。如果region的数量过多，该方法可能调用超时。 void createTable(final

查看更多 →

通过该接口可以打开HDFS上已经存在的指定文件的输入流，并可通过FSDataOutputStream类提供的接口进行文件的写入，其中“f”为文件的完整路径。 表2 类FileStatus常用接口说明 接口 说明 public long getModificationTime() 通过该接口可查看指定HDFS文件的修改时间。

查看更多 →

uest request) Client通过此接口从RM中获取队列的相关信息。 getQueueUserAcls(GetQueueUserAclsInfoRequest request) Client通过此接口从RM中获取当前用户的队列访问权限信息。 moveApplicatio

查看更多 →

提供迭代的能力 表9 提供迭代的能力的相关接口 API 说明 public IterativeStream<T> iterate() 在流(flow)中创建一个带反馈的循环，通过重定向一个operator的输出到之前的operator。 说明： 对于定义一些需要不断更新模型的算法是非常有帮助的。

查看更多 →

int numRegions) 创建一个有指定数量region的表，其中第一个region的endKey为参数中的startKey，最后一个region的StartKey为参数中的endKey。如果region的数量过多，该方法可能调用超时。 void createTable(final

查看更多 →

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

查看更多 →

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

查看更多 →

count() 返回的是dataset中的element的个数。 T first() 返回的是dataset中的第一个元素。 java.util.List<T> take(int num) 返回前n个elements。 java.util.List<T> takeSample(boolean

查看更多 →

uest request) Client通过此接口从RM中获取队列的相关信息。 getQueueUserAcls(GetQueueUserAclsInfoRequest request) Client通过此接口从RM中获取当前用户的队列访问权限信息。 moveApplicatio

查看更多 →

标准页面中预置的API 在开发标准页面时，可以通过编写JS代码，来实现页面组件与后台接口之间的交互。如图1所示，在编写JS代码时，可直接使用系统预置的API。 系统预置的API代码结构样例如下，提供事件上下文context，用于封装常用的对象及API。 context ├──$app

查看更多 →

高级页面中预置的API 在开发高级页面过程中，系统为页面组件和桥接器提供了一些预置API。 组件 在开发自定义组件时，需要定义“组件名.js”文件，该文件为组件逻辑文件，是整个组件的渲染核心JS，在组件编辑状态和页面最终的发布运行态都会被加载执行。主要包含的预置API说明，请参见表1。

查看更多 →

ultSet。 若对一个查询的结果集遍历时出现异常，也需要手动调用释放连接的操作closeResultSet。 可以调用SessionDataSetWrapper的getColumnNames()方法得到结果集列名。 表1 Session对应的接口的简要介绍及对应参数 方法 说明

查看更多 →

API（公测中） 获取API版本 云DBA

查看更多 →

通过Java API提交Oozie作业 通过Java API提交Oozie作业开发思路 通过Java API提交Oozie作业 父主题： 开发Oozie应用

查看更多 →

通过Java API提交Oozie作业 功能简介 Oozie通过org.apache.oozie.client.OozieClient的run方法提交作业，通过getJobInfo获取作业信息。 代码样例 代码示例中请根据实际情况，修改“OOZIE_URL_DEFALUT”为实际

查看更多 →