车道指标相关计算逻辑

realtime/hologram-streaming/src/main/java/com/zhht/irn/functions/LaneNormProcessFunction.java

@@ -185,7 +185,7 @@ public class LaneNormProcessFunction extends KeyedCoProcessFunction<String, Cycl
     @Override
     public void onTimer(long timestamp, OnTimerContext ctx, Collector<List<LaneNorm>> out) throws Exception {
         super.onTimer(timestamp, ctx, out);
-        System.out.println("触发定时器了。。。。");
+        //System.out.println("触发定时器了。。。。");
         //通过定时器清空字典表 防止字典表数据有更新
         dict.remove("phaseDirection");
         dict.remove("laneList");

realtime/hologram-streaming/src/main/java/com/zhht/irn/job/LaneNormJob.java

@@ -49,14 +49,14 @@ public class LaneNormJob {
                 public Cycle map(String cycle) throws Exception {
                     Cycle cycle1 = JSON.parseObject(cycle, Cycle.class);
                     cycle1 = getCycle(cycle1);
-                    System.out.println("周期数据->"+cycle);
+                    //System.out.println("周期数据->"+cycle);
                     return cycle1;
                 }
             };
             MapFunction<String, TravelEvent> getTravelEventFunction = new MapFunction<String, TravelEvent>() {
                 @Override
                 public TravelEvent map(String travelEvent) throws Exception {
-                    System.out.println("旅行事件数据->"+travelEvent);
+                    //System.out.println("旅行事件数据->"+travelEvent);
                     return JSON.parseObject(travelEvent, TravelEvent.class);
                 }
             };