标签：cti lin aggregate atm tst error UNC java函数 col
| 函数名 | 实现的方法 | 用途 |
| Function<T, R> | R call(T) | 接收一个输入值并返回一个输出值，用于类似 map() 和 filter() 等操作中 |
| Function2<T1, T2, R> | R call(T1, T2) | 接收两个输入值并返回一个输出值，用于类似 aggregate() 和 fold() 等操作中 |
| FlatMapFunction<T, R> | Iterable<R> call(T) | 接收一个输入值并返回任意个输出，用于类似 flatMap() 这样的操作中 |
RDD<String> errors = lines.filter(new Function<String, Boolean>() { public Boolean call(String x) { return x.contains("error"); } });
标签：cti lin aggregate atm tst error UNC java函数 col
原文地址：https://www.cnblogs.com/dj-blog/p/9294863.html
