Commit 7d8c33fc by 黄准

车道指标增加日志级别配置 方便现场调试程序

parent 183bdef1
...@@ -219,7 +219,6 @@ public class LaneNormProcessFunction extends KeyedCoProcessFunction<String, Cycl ...@@ -219,7 +219,6 @@ public class LaneNormProcessFunction extends KeyedCoProcessFunction<String, Cycl
} }
} }
@Override @Override
public void onTimer(long timestamp, OnTimerContext ctx, Collector<List<LaneNorm>> out) throws Exception { public void onTimer(long timestamp, OnTimerContext ctx, Collector<List<LaneNorm>> out) throws Exception {
super.onTimer(timestamp, ctx, out); super.onTimer(timestamp, ctx, out);
...@@ -246,8 +245,6 @@ public class LaneNormProcessFunction extends KeyedCoProcessFunction<String, Cycl ...@@ -246,8 +245,6 @@ public class LaneNormProcessFunction extends KeyedCoProcessFunction<String, Cycl
} }
return AllGreenTime + ""; return AllGreenTime + "";
} }
/** /**
* 北 直行 * 北 直行
* @param cycle * @param cycle
...@@ -273,7 +270,6 @@ public class LaneNormProcessFunction extends KeyedCoProcessFunction<String, Cycl ...@@ -273,7 +270,6 @@ public class LaneNormProcessFunction extends KeyedCoProcessFunction<String, Cycl
} }
return AllGreenTime + ""; return AllGreenTime + "";
} }
/** /**
* 提前计算所有相位允许的流向 * 提前计算所有相位允许的流向
* *
...@@ -294,8 +290,6 @@ public class LaneNormProcessFunction extends KeyedCoProcessFunction<String, Cycl ...@@ -294,8 +290,6 @@ public class LaneNormProcessFunction extends KeyedCoProcessFunction<String, Cycl
} }
return stageForDirections; return stageForDirections;
} }
/** /**
* 生成流向指标 * 生成流向指标
* *
...@@ -350,7 +344,6 @@ public class LaneNormProcessFunction extends KeyedCoProcessFunction<String, Cycl ...@@ -350,7 +344,6 @@ public class LaneNormProcessFunction extends KeyedCoProcessFunction<String, Cycl
} }
} }
} }
/** /**
* 生成方向指标 * 生成方向指标
* *
...@@ -431,7 +424,6 @@ public class LaneNormProcessFunction extends KeyedCoProcessFunction<String, Cycl ...@@ -431,7 +424,6 @@ public class LaneNormProcessFunction extends KeyedCoProcessFunction<String, Cycl
} }
} }
public static Cycle setCycle()throws Exception{ public static Cycle setCycle()throws Exception{
String cycleJson="{\n" + String cycleJson="{\n" +
" \"id\": 39240,\n" + " \"id\": 39240,\n" +
...@@ -507,7 +499,6 @@ public class LaneNormProcessFunction extends KeyedCoProcessFunction<String, Cycl ...@@ -507,7 +499,6 @@ public class LaneNormProcessFunction extends KeyedCoProcessFunction<String, Cycl
Cycle cycle1 = LaneNormJob.getCycle(cycle); Cycle cycle1 = LaneNormJob.getCycle(cycle);
return cycle1; return cycle1;
} }
/** /**
* @param map 车道信息 * @param map 车道信息
* @param cycle 周期信息 * @param cycle 周期信息
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment