Boolean): RDD[T] 对RDD中所有元素调用f方法，生成将满足条件数据集以RDD形式返回。 flatMap[U](f: (T) => TraversableOnce[U])(implicit arg0: ClassTag[U]): RDD[U] 先对RDD所有元素调用f方法，然后将结果扁平化，生成新的RDD。

查看更多 →

SingleOutputStreamOperator<T> min(int positionToMin) 对窗口数据的某一列求最小值。min返回了最小值，不保证非最小值列的准确性。 positionToMin和field代表对某一列求最小值。 public SingleOutputStreamOperator<T>

查看更多 →

Boolean): RDD[T] 对RDD中所有元素调用f方法，生成将满足条件数据集以RDD形式返回。 flatMap[U](f: (T) => TraversableOnce[U])(implicit arg0: ClassTag[U]): RDD[U] 先对RDD所有元素调用f方法，然后将结果扁平化，生成新的RDD。

查看更多 →

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

查看更多 →

历史API接口（待下线） 下载构建日志(待下线) 获取构建记录的有向无环图(待下线) 获取构建记录信息(待下线) 停止构建任务(待下线)

查看更多 →

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

查看更多 →

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

查看更多 →

DataStream[T] 对窗口数据的某一列求和。 position和field代表数据的某一列。 def sum(field: String): DataStream[T] def min(position: Int): DataStream[T] 对窗口数据的某一列求最小值。

查看更多 →

HBase JDBC API接口介绍 Phoenix实现了大部分的java.sql接口，SQL语法紧跟ANSI SQL标准。 其支持处理函数可参见： http://phoenix.apache.org/language/functions.html 其支持语法可参见： http://phoenix

查看更多 →

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

查看更多 →

<R> JavaRDD<R> map(Function<T,R> f) 对RDD中的每个element使用Function。 JavaRDD<T> filter(Function<T,Boolean> f) 对RDD中所有元素调用Function，返回为true的元素。 <U> JavaRDD<U>

查看更多 →

统。 countByKey() 对每个key出现的次数做统计。 foreach(func) 在数据集的每一个元素上，运行函数。 countByValue() 对RDD中每个不同value出现的次数进行统计。 Spark Streaming常用接口 Spark Streaming中常见的类有：

查看更多 →

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

查看更多 →

HBase JDBC API接口介绍 Phoenix实现了大部分的java.sql接口，SQL语法紧跟ANSI SQL标准。 其支持处理函数可参见： http://phoenix.apache.org/language/functions.html 其支持语法可参见： http://phoenix

查看更多 →

Boolean): RDD[T] 对RDD中所有元素调用f方法，生成将满足条件数据集以RDD形式返回。 flatMap[U](f: (T) => TraversableOnce[U])(implicit arg0: ClassTag[U]): RDD[U] 先对RDD所有元素调用f方法，然后将结果扁平化，生成新的RDD。

查看更多 →

Boolean): RDD[T] 对RDD中所有元素调用f方法，生成将满足条件数据集以RDD形式返回。 flatMap[U](f: (T) => TraversableOnce[U])(implicit arg0: ClassTag[U]): RDD[U] 先对RDD所有元素调用f方法，然后将结果扁平化，生成新的RDD。

查看更多 →

boolean[] existsAll(List<Get> gets) 判断这批指定的rowkey在表中是否存在，返回的boolean数组结果与入参位置一一对应。 Result get(Get get) 通过指定的rowkey读取数据。 Result[] get(List<Get> gets) 通

查看更多 →

HBase JDBC API接口介绍 Phoenix实现了大部分的java.sql接口，SQL语法紧跟ANSI SQL标准。 其支持处理函数可参见： http://phoenix.apache.org/language/functions.html 其支持语法可参见： http://phoenix

查看更多 →

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

查看更多 →

统。 countByKey() 对每个key出现的次数做统计。 foreach(func) 在数据集的每一个元素上，运行函数。 countByValue() 对RDD中每个不同value出现的次数进行统计。 Spark Streaming常用接口 Spark Streaming中常见的类有：

查看更多 →

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

查看更多 →