7.2 Transforming 变换操作 - Buffer/Window/Map/FlatMap/GroupBy/Scan
2016-10-09 10:46
239 查看
这个页面展示了可用于对Observable发射的数据执行变换操作的各种操作符。
对序列的每一项都应用一个函数来变换Observable发射的数据序列
and
将Observable发射的数据集合变换为Observables集合,然后只发射这些Observables最近发射的数据
对Observable发射的每一项数据应用一个函数,然后按顺序依次发射每一个值
将Observable分拆为Observable集合,将原始Observable发射的数据按Key分组,每一个Observable发射一组不同的数据
它定期从Observable收集数据到一个集合,然后把这些数据集合打包发射,而不是一次发射一个
定期将来自Observable的数据分拆成一些Observable窗口,然后发射这些窗口,而不是每次发射一项
在发射之前强制将Observable发射的所有数据转换为指定类型
map( )—
对序列的每一项都应用一个函数来变换Observable发射的数据序列
flatMap( ),
concatMap( ),
and
flatMapIterable( )— 将Observable发射的数据集合变换为Observables集合,然后将这些Observable发射的数据平坦化的放进一个单独的Observable
switchMap( )—
将Observable发射的数据集合变换为Observables集合,然后只发射这些Observables最近发射的数据
scan( )—
对Observable发射的每一项数据应用一个函数,然后按顺序依次发射每一个值
groupBy( )—
将Observable分拆为Observable集合,将原始Observable发射的数据按Key分组,每一个Observable发射一组不同的数据
buffer( )—
它定期从Observable收集数据到一个集合,然后把这些数据集合打包发射,而不是一次发射一个
window( )—
定期将来自Observable的数据分拆成一些Observable窗口,然后发射这些窗口,而不是每次发射一项
cast( )—
在发射之前强制将Observable发射的所有数据转换为指定类型
相关文章推荐
- RX操作符之对Observable发射的数据执行变换操作二(scan、groupby、buffer、window)
- Spark RDD/Core 编程 API入门系列 之rdd案例(map、filter、flatMap、groupByKey、reduceByKey、join、cogroupy等)(四)
- RX操作符之对Observable发射的数据执行变换操作一(map、flatmap)
- spark中textFile、groupByKey、collect、flatMap、map结合小案例(案例虽小,功能齐全)
- RX操作符之对Observable发射的数据执行变换操作一(map、cast、flatmap、flatmapiteriable、switchmap)
- RxJava【变换】操作符 map flatMap concatMap buffer
- Spark RDD/Core 编程 API入门系列 之rdd案例(map、filter、flatMap、groupByKey、reduceByKey、join、cogroupy等)(四)
- spark 的一些常用函数 filter,map,flatMap,lookup ,reduce,groupByKey
- Spark算子:RDD键值转换操作(3)–groupByKey、reduceByKey、reduceByKeyLocally
- hive GroupBy操作(翻译自Hive wiki)
- RxJava变换操作符:.concatMap( )与.flatMap( )的比较
- RDD键值转换操作(1)–partitionBy、mapValues、flatMapValues
- scala基础36-List的map/flatmap/filter等操作
- Transforming 变换操作
- Spark RDD/Core 编程 API入门系列之map、filter、textFile、cache、对Job输出结果进行升和降序、union、groupByKey、join、reduce、lookup(一)
- Spark算子:RDD键值转换操作(1)–partitionBy、mapValues、flatMapValues
- RxJava变换操作符:.concatMap( )与.flatMap( )的比较
- Spark算子:RDD键值转换操作(3)–groupByKey、reduceByKey、reduceByKeyLocally
- 第35讲:List的map、flatMap、foreach、filter操作代码实战
- List的map、flatMap、foreach、filter操作代码实战之Scala学习笔记-27