函数名 | 实现的方法 | 用途 |
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"); } });
原文地址:https://www.cnblogs.com/dj-blog/p/9294863.html
时间: 2024-11-13 06:52:04