Commit 6503c349 by 吴延飞

修复旅行信息旅行时长没有正确插入的问题。bug fixed,

parent 24b01b53
...@@ -116,8 +116,8 @@ public class Travel { ...@@ -116,8 +116,8 @@ public class Travel {
//实际停车次数 //实际停车次数
private int stopCount; private int stopCount;
//停车总时长 //停车总时长, 单位毫秒
private double stopTime; private int stopTime;
//平均车速 //平均车速
private double avgSpeed; private double avgSpeed;
...@@ -392,11 +392,11 @@ public class Travel { ...@@ -392,11 +392,11 @@ public class Travel {
this.stopCount = stopCount; this.stopCount = stopCount;
} }
public double getStopTime() { public int getStopTime() {
return stopTime; return stopTime;
} }
public void setStopTime(double stopTime) { public void setStopTime(int stopTime) {
this.stopTime = stopTime; this.stopTime = stopTime;
} }
......
...@@ -70,7 +70,7 @@ public class DirectionEvalJob { ...@@ -70,7 +70,7 @@ public class DirectionEvalJob {
.keyBy(record -> record.getCrossId()); .keyBy(record -> record.getCrossId());
// 定义好doris sink builder // 定义好doris sink builder
DorisSink.Builder<String> builder = DorisUtils.getBuilder("doris-connector.properties"); DorisSink.Builder<String> builder = DorisUtils.getBuilder("doris-connector-direction-eval.properties");
// 周期数据join 旅行事件 // 周期数据join 旅行事件
cycleStream.assignTimestampsAndWatermarks(cycleWatermarkStrategy) cycleStream.assignTimestampsAndWatermarks(cycleWatermarkStrategy)
......
...@@ -93,7 +93,7 @@ public class TravelInfoJob { ...@@ -93,7 +93,7 @@ public class TravelInfoJob {
boolean stopped = false; boolean stopped = false;
List<Location> locations = travel.getLocations(); List<Location> locations = travel.getLocations();
long stopTime = 0; int stopTime = 0;
int stopCount = 0; int stopCount = 0;
for(int j = 0; j < locations.size(); j ++) { for(int j = 0; j < locations.size(); j ++) {
......
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