[大数据]Flink中KeySelector理解

泛型编程是框架的基础，Flink中可以传递POJO对象的get方法，来作为获取key的途径，这样给开发者足够大的灵活性。理解这个过程，对于加强对泛型编程的理解有很大的帮助。此外，对于传递方法，还用到了@FunctionInterface，注意这个注解并不是强制性的，但它减少了一些错误发生的可能。

KeySelector本身就是一个函数接口，它提供了两个泛化参数：T代表当前处理数据的类型，K代表Key的类型。KeySelector在Flink中用于获取处理数据内的键值。想象一下这样的一个问题：你要对输入的数据的一个字段进行某种计算，但是，使用者只有在使用时才会告诉你：1、数据类型，2、要处理的字段。而且这个过程是分成2次的，首先你将得到数据的类型，然后再得到这个数据要处理字段。KeySelector就是用于处理这样问题的一个接口，通过这个接口，你可以先处理自己的计算逻辑，使用者在使用时传入对应的参数即可。

这里将会实现一个简单的功能模拟这样的过程：使用者提供一个数据类型，以及这个数据类型要获取的字段，程序框架将从实例化的对象中获取对应字段的值。

package com.atguigu.hotitems_analysis.test;

public class App {

    public static void main(String[] args) {
        //要处理的对象实例
        Something something = new Something("apple", 10);

        Worker<Something> worker = new Worker<>();
        worker.doSomething();

        //传递获取Int1方法给GetterWorkder
        //Something::getInt1会具化GetFunction<T, K>中的K，这是因为接口 K get(T value); 的返回值就是K
        //这里有点特殊在于，函数接口的传入是类的非静态方法，一般使用类的静态方法或者实例的非静态方法
        //实际上，类的非静态方法也是允许的，只不过此时函数接口的第一个参数要作为额外的参数，而且类型必须为此类
        GetterWorker getterWorker1 = worker.toGetterWorkder(Something::getInt1);

        //传递获取Str1方法给GetterWorkder
        GetterWorker getterWorker2 = worker.toGetterWorkder(Something::getStr1);

        //获取实例对象中的对应值
        System.out.println(getterWorker1.getValue(something));
        System.out.println(getterWorker2.getValue(something));
    }
}

package com.atguigu.hotitems_analysis.test;

//使用者定义的POJO对象
public class Something {

    private String str1;

    private Integer int1;

    public Something(String str1, Integer int1) {
        this.str1 = str1;
        this.int1 = int1;
    }

    public String getStr1() {
        return this.str1;
    }

    public Integer getInt1() {
        return this.int1;
    }
}

package com.atguigu.hotitems_analysis.test;

// 获取属性值函数接口，难点在于理解是如何实现并赋值的
@FunctionalInterface
interface GetFunction<T, K> {
    K get(T value);
}

package com.atguigu.hotitems_analysis.test;

// 处理数据的普通操作的类，同时提供获取属性的工作对象
public class Worker<T> {
    //传入的getFunction会具化K，GetterWorker的泛型参数一个由Worker的实例化过程具化，一个由函数接口参数传入时具化
    public <K> GetterWorker<T, K> toGetterWorkder(GetFunction<T, K> getFunction) {
        return new GetterWorker<T, K>(getFunction);
    }

    public void doSomething() {
        System.out.println("Do something");
    }
}

package com.atguigu.hotitems_analysis.test;

//通过函数接口获取对象的属性值
public class GetterWorker<T, K> {

    private GetFunction<T, K> getFunction;

    public GetterWorker(GetFunction<T, K> getFunction) {
        this.getFunction = getFunction;
    }

    public K getValue(T something) {
        return getFunction.get(something);
    }
}

Worker只有一个泛型参数T，比较好理解。难点在于函数接口，函数接口一般会赋值为类的静态方法或者实例的普通方法，但是这里赋值为类的非静态方法，其实这是被允许的，这种情况第一个参数要设置为类的实例，而且在使用是要传入。