Skip to content
Projects
Groups
Snippets
Help
Loading...
Sign in
Toggle navigation
F
ffm-baseline
Project
Project
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
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
ML
ffm-baseline
Commits
2af16a4a
Commit
2af16a4a
authored
Nov 01, 2018
by
王志伟
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
fix bug
parent
6bd4d66e
Show whitespace changes
Inline
Side-by-side
Showing
1 changed file
with
2 additions
and
6 deletions
+2
-6
testt.scala
eda/feededa/src/main/scala/com/gmei/testt.scala
+2
-6
No files found.
eda/feededa/src/main/scala/com/gmei/testt.scala
View file @
2af16a4a
...
@@ -29,7 +29,7 @@ object testt {
...
@@ -29,7 +29,7 @@ object testt {
"""
"""
|For example, the following command runs this app on a tidb dataset:
|For example, the following command runs this app on a tidb dataset:
|
|
| spark-submit --class com.gmei.
WeafareSta
t ./target/scala-2.11/feededa-assembly-0.1.jar \
| spark-submit --class com.gmei.
test
t ./target/scala-2.11/feededa-assembly-0.1.jar \
"""
.
stripMargin
+
"""
.
stripMargin
+
s
"| --env ${defaultParams.env}"
s
"| --env ${defaultParams.env}"
)
)
...
@@ -48,11 +48,9 @@ object testt {
...
@@ -48,11 +48,9 @@ object testt {
ti
.
tidbMapTable
(
dbName
=
"jerry_test"
,
tableName
=
"bl_device_list"
)
ti
.
tidbMapTable
(
dbName
=
"jerry_test"
,
tableName
=
"bl_device_list"
)
ti
.
tidbMapTable
(
dbName
=
"jerry_prod"
,
tableName
=
"data_feed_exposure"
)
ti
.
tidbMapTable
(
dbName
=
"jerry_prod"
,
tableName
=
"data_feed_exposure"
)
import
sc.implicits._
// val stat_date = GmeiConfig.getMinusNDate(1)
val
strategies
=
Seq
(
"3$"
,
"4$"
,
"5$"
,
"6$"
,
"7$"
,
"8$"
,
"a$"
,
"b$"
,
"c$"
,
"d$"
,
"e$"
,
"A$"
,
"B$"
,
"C$"
,
"D$"
)
val
strategies
=
Seq
(
"3$"
,
"4$"
,
"5$"
,
"6$"
,
"7$"
,
"8$"
,
"a$"
,
"b$"
,
"c$"
,
"d$"
,
"e$"
,
"A$"
,
"B$"
,
"C$"
,
"D$"
)
for
(
strategy
<-
strategies
){
for
(
strategy
<-
strategies
){
println
(
strategy
)
val
get_data_dura
=
sc
.
sql
(
val
get_data_dura
=
sc
.
sql
(
s
"""
s
"""
|select partition_date, sum(params['duration']) as total_dur,count(distinct(cl_id)) as num
|select partition_date, sum(params['duration']) as total_dur,count(distinct(cl_id)) as num
...
@@ -70,8 +68,6 @@ object testt {
...
@@ -70,8 +68,6 @@ object testt {
}
}
}
}
...
...
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