Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in / Register
Toggle navigation
A
appsflyer_advert_ck
Project overview
Project overview
Details
Activity
Releases
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Issues
0
Issues
0
List
Boards
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Analytics
Analytics
CI / CD
Repository
Value Stream
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
sheteng
appsflyer_advert_ck
Commits
2f7a86e1
Commit
2f7a86e1
authored
Apr 28, 2022
by
sheteng
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
时间截取
parent
5f9a82bd
Changes
3
Hide whitespace changes
Inline
Side-by-side
Showing
3 changed files
with
6 additions
and
8 deletions
+6
-8
src/main/java/com/fshark/overseas/advert/AppsflyerAnalyze.java
...ain/java/com/fshark/overseas/advert/AppsflyerAnalyze.java
+4
-4
src/main/java/com/fshark/overseas/advert/modle/AppsFlyerEvent.java
...java/com/fshark/overseas/advert/modle/AppsFlyerEvent.java
+2
-2
src/main/java/com/fshark/overseas/advert/util/AppConfig.java
src/main/java/com/fshark/overseas/advert/util/AppConfig.java
+0
-2
No files found.
src/main/java/com/fshark/overseas/advert/AppsflyerAnalyze.java
View file @
2f7a86e1
...
...
@@ -31,7 +31,7 @@ public class AppsflyerAnalyze {
appConfig
.
setSourceKafkaBootstrapServers
(
parameters
.
get
(
"source-kafka-bootstrap-servers"
));
appConfig
.
setSourceKafkaGroupId
(
parameters
.
get
(
"source-kafka-group-id"
));
appConfig
.
setSourceKafkaTopic
(
parameters
.
get
(
"source-kafka-topic"
));
appConfig
.
setStartOffsetTime
(
Long
.
valueOf
(
parameters
.
get
(
"start-offset-time"
)));
//
appConfig.setStartOffsetTime(Long.valueOf(parameters.get("start-offset-time")));
appConfig
.
setSinkKafkaBootstrapServers
(
parameters
.
get
(
"sink-kafka-bootstrap-servers"
));
appConfig
.
setSinkKafkaTopic
(
parameters
.
get
(
"sink-kafka-topic"
));
...
...
@@ -70,9 +70,9 @@ public class AppsflyerAnalyze {
properties
.
setProperty
(
"auto.offset.reset"
,
"earliest"
);
FlinkKafkaConsumer
<
String
>
dataConsumer
=
new
FlinkKafkaConsumer
<>(
appConfig
.
getSourceKafkaTopic
(),
new
SimpleStringSchema
(),
properties
);
// TODO: 2021/8/10 设置消费开始的时间戳1632326555000
if
(
appConfig
.
getStartOffsetTime
()
>
0
)
{
dataConsumer
.
setStartFromTimestamp
(
appConfig
.
getStartOffsetTime
());
}
//
if (appConfig.getStartOffsetTime() > 0) {
//
dataConsumer.setStartFromTimestamp(appConfig.getStartOffsetTime());
//
}
Properties
props2
=
new
Properties
();
props2
.
setProperty
(
"bootstrap.servers"
,
appConfig
.
getSinkKafkaBootstrapServers
());
...
...
src/main/java/com/fshark/overseas/advert/modle/AppsFlyerEvent.java
View file @
2f7a86e1
...
...
@@ -415,8 +415,8 @@ public class AppsFlyerEvent implements Serializable {
String
event
=
getEvent
(
jsonObject
,
eventType
,
eventName
);
appsFlyerEvent
.
setEvent_type
(
eventType
);
String
[]
timeZoneParts
=
eventTimeWithZone
.
split
(
"\\+"
)
;
LocalDateTime
eventTime
=
DateUtils
.
formatHMSSAsDate
(
timeZoneParts
[
0
]
);
// String[] timeZoneParts =
;
LocalDateTime
eventTime
=
DateUtils
.
formatHMSSAsDate
(
eventTimeWithZone
.
substring
(
0
,
23
)
);
// 如果有错,直接视为错误; +0900
String
timeZone
=
eventTimeWithZone
.
substring
(
23
);
...
...
src/main/java/com/fshark/overseas/advert/util/AppConfig.java
View file @
2f7a86e1
...
...
@@ -46,6 +46,4 @@ public class AppConfig implements Serializable {
private
String
sinkType
;
private
Long
startOffsetTime
;
}
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