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
7d8d0355
Commit
7d8d0355
authored
Jan 09, 2023
by
吴延飞
Browse files
Options
Browse Files
Download
Plain Diff
Merge remote-tracking branch 'origin/master'
parents
0f940087
46691e55
Hide whitespace changes
Inline
Side-by-side
Showing
1 changed file
with
1 addition
and
1 deletion
+1
-1
TravelLineSinkInfoFlatMapFunction.java
...zhht/irn/functions/TravelLineSinkInfoFlatMapFunction.java
+1
-1
No files found.
realtime/hologram-streaming/src/main/java/com/zhht/irn/functions/TravelLineSinkInfoFlatMapFunction.java
View file @
7d8d0355
...
@@ -31,7 +31,7 @@ public class TravelLineSinkInfoFlatMapFunction implements FlatMapFunction<List<T
...
@@ -31,7 +31,7 @@ public class TravelLineSinkInfoFlatMapFunction implements FlatMapFunction<List<T
String
record_date
=
sdf2
.
format
(
t
.
getLast_car_inCross_time
());
String
record_date
=
sdf2
.
format
(
t
.
getLast_car_inCross_time
());
// String record_date = "2023-01-09";
// String record_date = "2023-01-09";
collector
.
collect
(
record_date
+
"\t"
+
t
.
getCross_id
()+
"\t"
+
statistic_time
+
"\t"
+
t
.
getCycle_begin_time
()+
"\t"
+
t
.
getCycle_end_time
(
)
collector
.
collect
(
record_date
+
"\t"
+
t
.
getCross_id
()+
"\t"
+
statistic_time
+
"\t"
+
sdf
.
format
(
t
.
getCycle_begin_time
())+
"\t"
+
sdf
.
format
(
t
.
getCycle_end_time
()
)
+
"\t"
+
t
.
getLane_id
()+
"\t"
+
t
.
getCycle_id
()+
"\t"
+
t
.
getDirection
()+
"\t"
+
t
.
getFlow_direction
()+
"\t"
+
t
.
getPass_numbers
()
+
"\t"
+
t
.
getLane_id
()+
"\t"
+
t
.
getCycle_id
()+
"\t"
+
t
.
getDirection
()+
"\t"
+
t
.
getFlow_direction
()+
"\t"
+
t
.
getPass_numbers
()
+
"\t"
+
t
.
getLast_car_inCross_time
()+
"\t"
+
t
.
getAverage_pass_time
()+
"\t"
+
t
.
getAverage_pass_speed
()+
"\t"
+
t
.
getAverage_control_delay
()
+
"\t"
+
t
.
getLast_car_inCross_time
()+
"\t"
+
t
.
getAverage_pass_time
()+
"\t"
+
t
.
getAverage_pass_speed
()+
"\t"
+
t
.
getAverage_control_delay
()
+
"\t"
+
t
.
getAverage_stop_delay
()+
"\t"
+
t
.
getAverage_stop_times
()+
"\t"
+
t
.
getAverage_car_head_time_gap
());
+
"\t"
+
t
.
getAverage_stop_delay
()+
"\t"
+
t
.
getAverage_stop_times
()+
"\t"
+
t
.
getAverage_car_head_time_gap
());
...
...
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