src/main/java/com/zdjizhi/etl/connection/IpKeysSelector.java


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

package com.zdjizhi.etl.connection;


import org.apache.flink.api.java.functions.KeySelector;
import org.apache.flink.api.java.tuple.Tuple2;

import java.util.Map;

/**
 * @description:
 * @author: zhq
 * @create: 2022-07-05
 **/
public class IpKeysSelector implements KeySelector<Map<String, Object>, Tuple2<String, String>> {

    @Override
    public Tuple2<String, String> getKey(Map<String,Object> log) throws Exception {
        return Tuple2.of(
                String.valueOf(log.get("src_ip")),
                String.valueOf(log.get("dst_ip")));
    }
}