Commit 6e641327 by mengdongxing

Update BootStarpMedian.R

parent 22455beb
# BootStarpMedian function # BootStarpMedian function
BootStarpMedian <- function(x) { BootStarpMedian <- function(x) {
x <- as.vector(x) x <- as.vector(x)
...@@ -11,9 +9,7 @@ BootStarpMedian <- function(x) { ...@@ -11,9 +9,7 @@ BootStarpMedian <- function(x) {
#---------------------- #----------------------
# app std # app std
#---------------------- #----------------------
# loading data # loading data
app_query_sql <- "select appid, app_query_sql <- "select appid,
category_id, category_id,
isgame , isgame ,
...@@ -23,7 +19,6 @@ app_query_sql <- "select appid, ...@@ -23,7 +19,6 @@ app_query_sql <- "select appid,
where ds between '2017-02-20' and '2017-02-26' where ds between '2017-02-20' and '2017-02-26'
group by appid,category_id,isgame,ds group by appid,category_id,isgame,ds
" "
# app_query_result # app_query_result
app_query_result <- sql(app_query_sql) app_query_result <- sql(app_query_sql)
# #
...@@ -37,15 +32,12 @@ app <- gapply(x=app_query_result, ...@@ -37,15 +32,12 @@ app <- gapply(x=app_query_result,
data.frame(key,BootStarpMedian(x$ins_rate),stringsAsFactors = FALSE ) data.frame(key,BootStarpMedian(x$ins_rate),stringsAsFactors = FALSE )
}, },
schema=app_schema) schema=app_schema)
# collect(yy) # collect(yy)
app_output <- join(x=app_query_result, app_output <- join(x=app_query_result,
y=app, y=app,
joinExpr=app_query_result$category_id==app$category_id_app & app_query_result$isgame==app$isgame_app, joinExpr=app_query_result$category_id==app$category_id_app & app_query_result$isgame==app$isgame_app,
joinType='inner' joinType='inner'
) )
app_output <- select(app_output,'appid','category_id','isgame','ins_rate_std','ds') app_output <- select(app_output,'appid','category_id','isgame','ins_rate_std','ds')
#---------------------- #----------------------
...@@ -60,7 +52,6 @@ cid_query_sql <- "select appid, ...@@ -60,7 +52,6 @@ cid_query_sql <- "select appid,
ins_rate ins_rate
from tkdm.tkdm_data_active_detial_day from tkdm.tkdm_data_active_detial_day
where ds between '2017-02-20' and '2017-02-26' where ds between '2017-02-20' and '2017-02-26'
" "
# result of query sql # result of query sql
aa <- sql(cid_query_sql) aa <- sql(cid_query_sql)
...@@ -76,13 +67,9 @@ cid <- gapply(x=aa, ...@@ -76,13 +67,9 @@ cid <- gapply(x=aa,
data.frame(key,BootStarpMedian(x$ins_rate),stringsAsFactors = FALSE ) data.frame(key,BootStarpMedian(x$ins_rate),stringsAsFactors = FALSE )
}, },
schema=cid_schema) schema=cid_schema)
# collect(cid) # collect(cid)
cid_output <- join(x=aa,y=cid, cid_output <- join(x=aa,y=cid,
joinExpr=aa$category_id==cid$category_id_cid & aa$isgame==cid$isgame_cid & aa$cid==cid$cid_cid, joinExpr=aa$category_id==cid$category_id_cid & aa$isgame==cid$isgame_cid & aa$cid==cid$cid_cid,
joinType='inner' joinType='inner'
) )
# cid_output <- cid_output[,c('appid','cid','category_id','isgame','ins_rate_std')]
cid_output <- select(cid_output,'appid','cid','category_id','isgame','ins_rate_std','ds') cid_output <- select(cid_output,'appid','cid','category_id','isgame','ins_rate_std','ds')
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment