通过Java8的Lambda表达式提升大数据编码速度

拿到大量数据以后，通常需要使用Hadoop/Spark对数据集进行清洗。

在这里我整理了Java中Lambda表达式的一些用法，希望能够提高大家的编码速度

Lambda

在Java 8中添加了Lambda新特性。如果接口中只有一个方法，则可以使用Lambda来完成。

例如Runnable接口，只有一个run方法。在Java 8以下中我们需要这么写：

new Thread(new Runnable(){
    @Override
    public void run(){
        // ...
    }
}).start();

在Java 8及以上版本：

new Thread(() -> ...).start();

Lambda表达式语法格式如下：

(partameters) -> expression

或者

(partameters) -> { stamements; }

例如：

(int a,int b) -> a + b

(a,b) -> a + b

(a,b) -> { return a + b;}

a -> a + 1

Lambda表达式的重要特征是：

1. 类型声明可选：不需要声明参数的类型，编译器可以自动识别

2. 参数圆括号可选：如果只有一个参数，可以省略定义参数的圆括号

3. 大括号可选：如果表达式只有一条语句，可以省略主体的花括号

4. return关键字可选：如果主体只有一条语句有表达式，编译器会返回该值。花括号内需要手动return指定返回值

下面是一个简单的Lambda实例：

import static java.lang.System.out;
interface BinOper<T> {
    T apply(T a, T b);
}
public class Main {
    public static void main(String[] args) {
        out.println(run(2, 3, (a, b) -> a + b));
    }
    private static int run(int a, int b, BinOper<Integer> oper) {
        return oper.apply(a, b);
    }
}

方法引用

在Java 8以上版本中，增加了方法引用。方法引用和Lambda很相似，可以使语言更加的紧凑和简介。减少冗余代码。Java中的方法引用使用两个冒号 :: 完成

下面我们来看一个最简单的用法：

import static System.out;
@FunctionalInterface
interface MyConsumer<T> {
    void accpet(T obj);
}
public class Main {
    public static void main(String[] args) {
        echo("Hello Java 8", Main::print);
    }
    private static void print(Object o) {
        out.println(o.toString());
    }
    private static void echo(Object obj,MyConsumer<? super Object> consumer){
        consumer.accpet(obj);
    }
}

上面代码中一共经历了以下几个步骤：

1. 在把Main::print传入echo方法时，实际上相当于是实现了MyConsumer接口，类似于Lambda的(obj) -> Main.print(obj)

2. echo方法内调用accept并传入obj，相当于调用了print方法

3. print方法输出变量obj

Java 8中包含的预定义函数式接口