Spark_RDD之简单Java函数接口
Posted dj-blog
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Spark_RDD之简单Java函数接口相关的知识，希望对你有一定的参考价值。
| 函数名 | 实现的方法 | 用途 |
| 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"); } });
以上是关于Spark_RDD之简单Java函数接口的主要内容，如果未能解决你的问题，请参考以下文章