diff options
| author | zhanghongqing <[email protected]> | 2022-07-12 19:24:53 +0800 |
|---|---|---|
| committer | zhanghongqing <[email protected]> | 2022-07-12 19:24:53 +0800 |
| commit | 06042db9b11bf3a17eaec455b3daf5b31de679d7 (patch) | |
| tree | f27821ec8a5037a9ddcbdc82d31dfeb46233efad /src/main/java/com/zdjizhi/etl/ConnProcessFunction.java | |
| parent | c1b70a6da06a7a55123b7fb904e421b59c230a34 (diff) | |
优化代码：使用windowAll做数据批量操作
Diffstat (limited to 'src/main/java/com/zdjizhi/etl/ConnProcessFunction.java')
| -rw-r--r-- | src/main/java/com/zdjizhi/etl/ConnProcessFunction.java | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/main/java/com/zdjizhi/etl/ConnProcessFunction.java b/src/main/java/com/zdjizhi/etl/ConnProcessFunction.java index 6ed9eef..49041dc 100644 --- a/src/main/java/com/zdjizhi/etl/ConnProcessFunction.java +++ b/src/main/java/com/zdjizhi/etl/ConnProcessFunction.java @@ -1,13 +1,13 @@ package com.zdjizhi.etl; import cn.hutool.core.convert.Convert; +import cn.hutool.log.Log; +import cn.hutool.log.LogFactory; import org.apache.flink.api.java.tuple.Tuple2; import org.apache.flink.api.java.tuple.Tuple5; import org.apache.flink.streaming.api.functions.windowing.ProcessWindowFunction; import org.apache.flink.streaming.api.windowing.windows.TimeWindow; import org.apache.flink.util.Collector; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; import java.util.LinkedHashMap; import java.util.Map; @@ -20,7 +20,7 @@ import static com.zdjizhi.common.FlowWriteConfig.LOG_AGGREGATE_DURATION; */ public class ConnProcessFunction extends ProcessWindowFunction<Map<String, Object>, Map<String, Object>, Tuple2<String, String>, TimeWindow> { - private static final Logger logger = LoggerFactory.getLogger(ConnProcessFunction.class); + private static final Log logger = LogFactory.get(); @Override public void process(Tuple2<String, String> keys, Context context, Iterable<Map<String, Object>> elements, Collector<Map<String, Object>> out) { |