Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
Z
ZHHT-IRN-BD-ANALYSIS
Project
Overview
Details
Activity
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
李凯旋
ZHHT-IRN-BD-ANALYSIS
Commits
0a1eab4b
Commit
0a1eab4b
authored
Nov 24, 2022
by
吴延飞
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
恢复实力类Travel的lineId命名,改为laneId会导致解析失败
parent
a6c61816
Show whitespace changes
Inline
Side-by-side
Showing
2 changed files
with
42 additions
and
42 deletions
+42
-42
Travel.java
...m-streaming/src/main/java/com/zhht/irn/entity/Travel.java
+36
-36
TravelMetricSink.java
...ing/src/main/java/com/zhht/irn/sink/TravelMetricSink.java
+6
-6
No files found.
realtime/hologram-streaming/src/main/java/com/zhht/irn/entity/Travel.java
View file @
0a1eab4b
...
@@ -51,7 +51,7 @@ public class Travel {
...
@@ -51,7 +51,7 @@ public class Travel {
private
String
carType
;
private
String
carType
;
// 捕获车道ID
// 捕获车道ID
private
String
firstL
a
neId
;
private
String
firstL
i
neId
;
// 捕获时速度
// 捕获时速度
private
Double
firstSpeed
;
private
Double
firstSpeed
;
...
@@ -60,7 +60,7 @@ public class Travel {
...
@@ -60,7 +60,7 @@ public class Travel {
private
String
firstTime
;
private
String
firstTime
;
// 达到车道ID
// 达到车道ID
private
String
arrivedL
a
neId
;
private
String
arrivedL
i
neId
;
// 到达时速度
// 到达时速度
private
Double
arrivedSpeed
;
private
Double
arrivedSpeed
;
...
@@ -69,7 +69,7 @@ public class Travel {
...
@@ -69,7 +69,7 @@ public class Travel {
private
String
arrivedTime
;
private
String
arrivedTime
;
// 进入车道ID
// 进入车道ID
private
String
inCrossL
a
neId
;
private
String
inCrossL
i
neId
;
// 进入时速度
// 进入时速度
private
Double
inSpeed
;
private
Double
inSpeed
;
...
@@ -78,7 +78,7 @@ public class Travel {
...
@@ -78,7 +78,7 @@ public class Travel {
private
String
inCrossTime
;
private
String
inCrossTime
;
// 通过车道ID
// 通过车道ID
private
String
outCrossL
a
neId
;
private
String
outCrossL
i
neId
;
// 通过时速度
// 通过时速度
private
Double
outSpeed
;
private
Double
outSpeed
;
...
@@ -87,7 +87,7 @@ public class Travel {
...
@@ -87,7 +87,7 @@ public class Travel {
private
String
outCrossTime
;
private
String
outCrossTime
;
// 驶离车道ID
// 驶离车道ID
private
String
awayL
a
neId
;
private
String
awayL
i
neId
;
// 驶离时速度
// 驶离时速度
private
Double
awaySpeed
;
private
Double
awaySpeed
;
...
@@ -96,7 +96,7 @@ public class Travel {
...
@@ -96,7 +96,7 @@ public class Travel {
private
String
awayTime
;
private
String
awayTime
;
// 丢失车道ID
// 丢失车道ID
private
String
lastL
a
neId
;
private
String
lastL
i
neId
;
// 丢失时速度
// 丢失时速度
private
Double
lastSpeed
;
private
Double
lastSpeed
;
...
@@ -216,12 +216,12 @@ public class Travel {
...
@@ -216,12 +216,12 @@ public class Travel {
this
.
carType
=
carType
;
this
.
carType
=
carType
;
}
}
public
String
getFirstL
a
neId
()
{
public
String
getFirstL
i
neId
()
{
return
firstL
a
neId
;
return
firstL
i
neId
;
}
}
public
void
setFirstL
aneId
(
String
firstLa
neId
)
{
public
void
setFirstL
ineId
(
String
firstLi
neId
)
{
this
.
firstL
aneId
=
firstLa
neId
;
this
.
firstL
ineId
=
firstLi
neId
;
}
}
public
Double
getFirstSpeed
()
{
public
Double
getFirstSpeed
()
{
...
@@ -240,12 +240,12 @@ public class Travel {
...
@@ -240,12 +240,12 @@ public class Travel {
this
.
firstTime
=
firstTime
;
this
.
firstTime
=
firstTime
;
}
}
public
String
getArrivedL
a
neId
()
{
public
String
getArrivedL
i
neId
()
{
return
arrivedL
a
neId
;
return
arrivedL
i
neId
;
}
}
public
void
setArrivedL
aneId
(
String
arrivedLa
neId
)
{
public
void
setArrivedL
ineId
(
String
arrivedLi
neId
)
{
this
.
arrivedL
aneId
=
arrivedLa
neId
;
this
.
arrivedL
ineId
=
arrivedLi
neId
;
}
}
public
Double
getArrivedSpeed
()
{
public
Double
getArrivedSpeed
()
{
...
@@ -264,12 +264,12 @@ public class Travel {
...
@@ -264,12 +264,12 @@ public class Travel {
this
.
arrivedTime
=
arrivedTime
;
this
.
arrivedTime
=
arrivedTime
;
}
}
public
String
getInCrossL
a
neId
()
{
public
String
getInCrossL
i
neId
()
{
return
inCrossL
a
neId
;
return
inCrossL
i
neId
;
}
}
public
void
setInCrossL
aneId
(
String
inCrossLa
neId
)
{
public
void
setInCrossL
ineId
(
String
inCrossLi
neId
)
{
this
.
inCrossL
aneId
=
inCrossLa
neId
;
this
.
inCrossL
ineId
=
inCrossLi
neId
;
}
}
public
Double
getInSpeed
()
{
public
Double
getInSpeed
()
{
...
@@ -288,12 +288,12 @@ public class Travel {
...
@@ -288,12 +288,12 @@ public class Travel {
this
.
inCrossTime
=
inCrossTime
;
this
.
inCrossTime
=
inCrossTime
;
}
}
public
String
getOutCrossL
a
neId
()
{
public
String
getOutCrossL
i
neId
()
{
return
outCrossL
a
neId
;
return
outCrossL
i
neId
;
}
}
public
void
setOutCrossL
aneId
(
String
outCrossLa
neId
)
{
public
void
setOutCrossL
ineId
(
String
outCrossLi
neId
)
{
this
.
outCrossL
aneId
=
outCrossLa
neId
;
this
.
outCrossL
ineId
=
outCrossLi
neId
;
}
}
public
Double
getOutSpeed
()
{
public
Double
getOutSpeed
()
{
...
@@ -312,12 +312,12 @@ public class Travel {
...
@@ -312,12 +312,12 @@ public class Travel {
this
.
outCrossTime
=
outCrossTime
;
this
.
outCrossTime
=
outCrossTime
;
}
}
public
String
getAwayL
a
neId
()
{
public
String
getAwayL
i
neId
()
{
return
awayL
a
neId
;
return
awayL
i
neId
;
}
}
public
void
setAwayL
aneId
(
String
awayLa
neId
)
{
public
void
setAwayL
ineId
(
String
awayLi
neId
)
{
this
.
awayL
aneId
=
awayLa
neId
;
this
.
awayL
ineId
=
awayLi
neId
;
}
}
public
Double
getAwaySpeed
()
{
public
Double
getAwaySpeed
()
{
...
@@ -336,12 +336,12 @@ public class Travel {
...
@@ -336,12 +336,12 @@ public class Travel {
this
.
awayTime
=
awayTime
;
this
.
awayTime
=
awayTime
;
}
}
public
String
getLastL
a
neId
()
{
public
String
getLastL
i
neId
()
{
return
lastL
a
neId
;
return
lastL
i
neId
;
}
}
public
void
setLastL
aneId
(
String
lastLa
neId
)
{
public
void
setLastL
ineId
(
String
lastLi
neId
)
{
this
.
lastL
aneId
=
lastLa
neId
;
this
.
lastL
ineId
=
lastLi
neId
;
}
}
public
Double
getLastSpeed
()
{
public
Double
getLastSpeed
()
{
...
@@ -447,22 +447,22 @@ public class Travel {
...
@@ -447,22 +447,22 @@ public class Travel {
", plate='"
+
plate
+
'\''
+
", plate='"
+
plate
+
'\''
+
", plateColor='"
+
plateColor
+
'\''
+
", plateColor='"
+
plateColor
+
'\''
+
", carType='"
+
carType
+
'\''
+
", carType='"
+
carType
+
'\''
+
", firstL
aneId='"
+
firstLa
neId
+
'\''
+
", firstL
ineId='"
+
firstLi
neId
+
'\''
+
", firstSpeed="
+
firstSpeed
+
", firstSpeed="
+
firstSpeed
+
", firstTime='"
+
firstTime
+
'\''
+
", firstTime='"
+
firstTime
+
'\''
+
", arrivedL
aneId='"
+
arrivedLa
neId
+
'\''
+
", arrivedL
ineId='"
+
arrivedLi
neId
+
'\''
+
", arrivedSpeed="
+
arrivedSpeed
+
", arrivedSpeed="
+
arrivedSpeed
+
", arrivedTime='"
+
arrivedTime
+
'\''
+
", arrivedTime='"
+
arrivedTime
+
'\''
+
", inCrossL
aneId='"
+
inCrossLa
neId
+
'\''
+
", inCrossL
ineId='"
+
inCrossLi
neId
+
'\''
+
", inSpeed="
+
inSpeed
+
", inSpeed="
+
inSpeed
+
", inCrossTime='"
+
inCrossTime
+
'\''
+
", inCrossTime='"
+
inCrossTime
+
'\''
+
", outCrossL
aneId='"
+
outCrossLa
neId
+
'\''
+
", outCrossL
ineId='"
+
outCrossLi
neId
+
'\''
+
", outSpeed="
+
outSpeed
+
", outSpeed="
+
outSpeed
+
", outCrossTime='"
+
outCrossTime
+
'\''
+
", outCrossTime='"
+
outCrossTime
+
'\''
+
", awayL
aneId='"
+
awayLa
neId
+
'\''
+
", awayL
ineId='"
+
awayLi
neId
+
'\''
+
", awaySpeed="
+
awaySpeed
+
", awaySpeed="
+
awaySpeed
+
", awayTime='"
+
awayTime
+
'\''
+
", awayTime='"
+
awayTime
+
'\''
+
", lastL
aneId='"
+
lastLa
neId
+
'\''
+
", lastL
ineId='"
+
lastLi
neId
+
'\''
+
", lastSpeed="
+
lastSpeed
+
", lastSpeed="
+
lastSpeed
+
", lastTime='"
+
lastTime
+
'\''
+
", lastTime='"
+
lastTime
+
'\''
+
", crossingTime="
+
crossingTime
+
", crossingTime="
+
crossingTime
+
...
...
realtime/hologram-streaming/src/main/java/com/zhht/irn/sink/TravelMetricSink.java
View file @
0a1eab4b
...
@@ -57,27 +57,27 @@ public class TravelMetricSink extends RichSinkFunction<Travel> {
...
@@ -57,27 +57,27 @@ public class TravelMetricSink extends RichSinkFunction<Travel> {
insertPstmt
.
setString
(
10
,
travel
.
getPlateColor
());
insertPstmt
.
setString
(
10
,
travel
.
getPlateColor
());
insertPstmt
.
setString
(
11
,
travel
.
getCarType
());
insertPstmt
.
setString
(
11
,
travel
.
getCarType
());
insertPstmt
.
setString
(
12
,
travel
.
getFirstL
a
neId
());
insertPstmt
.
setString
(
12
,
travel
.
getFirstL
i
neId
());
insertPstmt
.
setString
(
13
,
longToString
(
travel
.
getFirstTime
(),
timeFormat
));
insertPstmt
.
setString
(
13
,
longToString
(
travel
.
getFirstTime
(),
timeFormat
));
insertPstmt
.
setDouble
(
14
,
travel
.
getFirstSpeed
());
insertPstmt
.
setDouble
(
14
,
travel
.
getFirstSpeed
());
insertPstmt
.
setString
(
15
,
travel
.
getArrivedL
a
neId
());
insertPstmt
.
setString
(
15
,
travel
.
getArrivedL
i
neId
());
insertPstmt
.
setString
(
16
,
longToString
(
travel
.
getArrivedTime
(),
timeFormat
));
insertPstmt
.
setString
(
16
,
longToString
(
travel
.
getArrivedTime
(),
timeFormat
));
insertPstmt
.
setDouble
(
17
,
travel
.
getArrivedSpeed
());
insertPstmt
.
setDouble
(
17
,
travel
.
getArrivedSpeed
());
insertPstmt
.
setString
(
18
,
travel
.
getInCrossL
a
neId
());
insertPstmt
.
setString
(
18
,
travel
.
getInCrossL
i
neId
());
insertPstmt
.
setString
(
19
,
longToString
(
travel
.
getInCrossTime
(),
timeFormat
));
insertPstmt
.
setString
(
19
,
longToString
(
travel
.
getInCrossTime
(),
timeFormat
));
insertPstmt
.
setDouble
(
20
,
travel
.
getInSpeed
());
insertPstmt
.
setDouble
(
20
,
travel
.
getInSpeed
());
insertPstmt
.
setString
(
21
,
travel
.
getOutCrossL
a
neId
());
insertPstmt
.
setString
(
21
,
travel
.
getOutCrossL
i
neId
());
insertPstmt
.
setString
(
22
,
longToString
(
travel
.
getOutCrossTime
(),
timeFormat
));
insertPstmt
.
setString
(
22
,
longToString
(
travel
.
getOutCrossTime
(),
timeFormat
));
insertPstmt
.
setDouble
(
23
,
travel
.
getOutSpeed
());
insertPstmt
.
setDouble
(
23
,
travel
.
getOutSpeed
());
insertPstmt
.
setString
(
24
,
travel
.
getAwayL
a
neId
());
insertPstmt
.
setString
(
24
,
travel
.
getAwayL
i
neId
());
insertPstmt
.
setString
(
25
,
longToString
(
travel
.
getAwayTime
(),
timeFormat
));
insertPstmt
.
setString
(
25
,
longToString
(
travel
.
getAwayTime
(),
timeFormat
));
insertPstmt
.
setDouble
(
26
,
travel
.
getAwaySpeed
());
insertPstmt
.
setDouble
(
26
,
travel
.
getAwaySpeed
());
insertPstmt
.
setString
(
27
,
travel
.
getLastL
a
neId
());
insertPstmt
.
setString
(
27
,
travel
.
getLastL
i
neId
());
insertPstmt
.
setString
(
28
,
longToString
(
travel
.
getLastTime
(),
timeFormat
));
insertPstmt
.
setString
(
28
,
longToString
(
travel
.
getLastTime
(),
timeFormat
));
insertPstmt
.
setDouble
(
29
,
travel
.
getLastSpeed
());
insertPstmt
.
setDouble
(
29
,
travel
.
getLastSpeed
());
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment