diff options
| author | wanglihui <[email protected]> | 2021-09-10 17:35:25 +0800 |
|---|---|---|
| committer | wanglihui <[email protected]> | 2021-09-10 17:35:25 +0800 |
| commit | 8c790354c09b7b79e6cfa0c85f76d7970dd2a94f (patch) | |
| tree | e45cd8844b4a4814533c5d7ceae0a690cc636391 | |
| parent | ca19b6c0e61b36842f42c64bcd7c631fe4ac3783 (diff) | |
修改计算速率方式，使用session总数除以时间窗口tsg-v08
| -rw-r--r-- | src/main/java/com/zdjizhi/etl/EtlProcessFunction.java | 4 | ||||
| -rw-r--r-- | src/main/resources/common.properties | 2 |
2 files changed, 4 insertions, 2 deletions
diff --git a/src/main/java/com/zdjizhi/etl/EtlProcessFunction.java b/src/main/java/com/zdjizhi/etl/EtlProcessFunction.java index 464b5f6..64881bb 100644 --- a/src/main/java/com/zdjizhi/etl/EtlProcessFunction.java +++ b/src/main/java/com/zdjizhi/etl/EtlProcessFunction.java @@ -80,7 +80,9 @@ public class EtlProcessFunction extends ProcessWindowFunction<DosSketchLog, DosS } } String sourceIpList = StringUtils.join(sourceIpSet, ","); - return Tuple6.of(sessions/cnt/duration,packets/cnt/duration,bytes/cnt/duration,sourceIpList,startTime,duration); +// return Tuple6.of(sessions/cnt/duration,packets/cnt/duration,bytes/cnt/duration,sourceIpList,startTime,duration); + return Tuple6.of(sessions/CommonConfig.FLINK_WINDOW_MAX_TIME,packets/CommonConfig.FLINK_WINDOW_MAX_TIME, + bytes/CommonConfig.FLINK_WINDOW_MAX_TIME,sourceIpList,startTime,duration); }catch (Exception e){ logger.error("聚合中间结果集失败 {}",e); } diff --git a/src/main/resources/common.properties b/src/main/resources/common.properties index 072c787..0c242b5 100644 --- a/src/main/resources/common.properties +++ b/src/main/resources/common.properties @@ -50,7 +50,7 @@ hbase.client.operation.timeout=30000 hbase.client.scanner.timeout.period=30000 ##hbase baseline表名 -hbase.baseline.table.name=ddos_traffic_baselines +hbase.baseline.table.name=dos:ddos_traffic_baselines #读取baseline限制 hbase.baseline.total.num=1000000 |