1. 程式人生 > >Spark_RDD之簡單Java函數接口

Spark_RDD之簡單Java函數接口

width orm 輸出 fun gate 方法 atm bool iter

函數名 實現的方法 用途
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函數接口