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


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

package com.zdjizhi.etl.connection;

import com.alibaba.fastjson.util.TypeUtils;
import com.zdjizhi.utils.json.TypeUtil;
import org.apache.flink.api.common.functions.MapFunction;

import java.util.Map;

public class SketchTimeMapFunction implements MapFunction<Map<String, Object>, Map<String, Object>> {

    @Override
    public Map<String, Object> map(Map<String, Object> value) throws Exception {
        value.put("sketch_start_time", TypeUtil.coverMSToS(value.get("sketch_start_time")));

        value.put("sketch_sessions", TypeUtils.castToLong(value.get("sketch_sessions")));
        value.put("sketch_packets", TypeUtils.castToLong(value.get("sketch_packets")));
        value.put("sketch_bytes", TypeUtils.castToLong(value.get("sketch_bytes")));
        return value;
    }

}