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
a79c6296
Commit
a79c6296
authored
Oct 12, 2019
by
张彦钊
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
change
parent
4895ca0b
Show whitespace changes
Inline
Side-by-side
Showing
1 changed file
with
2 additions
and
2 deletions
+2
-2
meigou.py
local/meigou.py
+2
-2
No files found.
local/meigou.py
View file @
a79c6296
...
@@ -56,7 +56,7 @@ def all_click(x):
...
@@ -56,7 +56,7 @@ def all_click(x):
.
format
(
date
))
.
rdd
.
map
(
lambda
x
:
x
[
0
])
.
collect
()[
0
]
.
format
(
date
))
.
rdd
.
map
(
lambda
x
:
x
[
0
])
.
collect
()[
0
]
meigou_homepage_sum
=
meigou_homepage_sum
+
tmp
meigou_homepage_sum
=
meigou_homepage_sum
+
tmp
print
ln
(
"美购首页icon美购点击"
)
print
(
"美购首页icon美购点击"
)
tmp
=
spark
.
sql
(
"select count(*) from online.bl_hdfs_maidian_updates where partition_date='{}' "
tmp
=
spark
.
sql
(
"select count(*) from online.bl_hdfs_maidian_updates where partition_date='{}' "
"and action = 'goto_welfare_detail' and app['version'] in ('7.15.0','7.14.0') "
"and action = 'goto_welfare_detail' and app['version'] in ('7.15.0','7.14.0') "
"and params['from'] = 'welfare_list' and params['cpc_referer'] = '18'"
"and params['from'] = 'welfare_list' and params['cpc_referer'] = '18'"
...
@@ -123,7 +123,7 @@ def cpc_click(x):
...
@@ -123,7 +123,7 @@ def cpc_click(x):
.
format
(
date
))
.
rdd
.
map
(
lambda
x
:
x
[
0
])
.
collect
()[
0
]
.
format
(
date
))
.
rdd
.
map
(
lambda
x
:
x
[
0
])
.
collect
()[
0
]
meigou_home_sum
=
meigou_home_sum
+
tmp
meigou_home_sum
=
meigou_home_sum
+
tmp
print
ln
(
"美购首页icon美购点击"
)
print
(
"美购首页icon美购点击"
)
tmp
=
spark
.
sql
(
"select count(*) from online.bl_hdfs_maidian_updates where partition_date='{}' "
tmp
=
spark
.
sql
(
"select count(*) from online.bl_hdfs_maidian_updates where partition_date='{}' "
"and action = 'goto_welfare_detail' and app['version'] in ('7.15.0','7.14.0') "
"and action = 'goto_welfare_detail' and app['version'] in ('7.15.0','7.14.0') "
"and params['from'] = 'welfare_list' and params['cpc_referer'] = '18' "
"and params['from'] = 'welfare_list' and params['cpc_referer'] = '18' "
...
...
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