Commit 0f11e5b1 by 吴延飞

分方向指标计算时,statistic_time 字段获取不争取,bug fixed

parent 25b3bee5
...@@ -82,7 +82,7 @@ public class DirectionEvalJob { ...@@ -82,7 +82,7 @@ public class DirectionEvalJob {
return desm.getCrossId() + "\t" + desm.getLineId() + "\t" + desm.getCycleOrder() + "\t" + longToStandardFormatString(desm.getCycleStart()) + "\t" return desm.getCrossId() + "\t" + desm.getLineId() + "\t" + desm.getCycleOrder() + "\t" + longToStandardFormatString(desm.getCycleStart()) + "\t"
+ longToStandardFormatString(desm.getCycleEnd()) + "\t" + desm.getCurrentSecond() + "\t" + desm.getAccArrivedFlow() + "\t" + longToStandardFormatString(desm.getCycleEnd()) + "\t" + desm.getCurrentSecond() + "\t" + desm.getAccArrivedFlow() + "\t"
+ desm.getAccQueueLength() + "\t" + desm.getStopFlagCount() + "\t" + desm.getAccStopCount() + "\t" + desm.getAccQueueLength() + "\t" + desm.getStopFlagCount() + "\t" + desm.getAccStopCount() + "\t"
+ DateUtils.getCurrentDateTime("yyyy-MM-dd HH:mm:ss") + "\t" + DateUtils.getCurrentDateTime("yyyy-MM-dd"); + longToStandardFormatString(System.currentTimeMillis()) + "\t" + longToStandardFormatString(System.currentTimeMillis());
}).sinkTo(builder.build()); }).sinkTo(builder.build());
// 旅行数据流 // 旅行数据流
......
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