2017-08-08 9 views
2
table1 <- data.frame(user_id=c(1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 2, 2), 
       product_id = c(14, 24, 38, 40, 66, 2, 19, 30, 71, 98, 7, 16), 
       first_order = c(1, 2, 1, 4, 5, 3, 2, 4, 2, 4, 2, 3), 
       last_order = c(4, 7, 5, 8, 8, 3, 4, 7, 5, 9, 4, 5)) 
table2 <- data.frame(user_id=c(1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 2, 2, 2, 2, 2, 2), 
       order_number=c(1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 1, 2, 3, 4, 5, 6), 
       days_cumsum = c(0, 7, 15, 26, 34, 43, 53, 59, 66, 74, 82, 91, 5, 11, 17, 24, 29, 35)) 

table2を使用してtable1に新しい機能を追加したいと思います。 新機能は、各ユーザーの各製品の注文間隔です。2つのテーブルを使用して新機能を作成する

たとえば、表1を見てみましょう。最初の行は(user_id == 1)、(product_id == 14)、(first order == 1)、(last order == 4)です。これは、製品14が注文1,2,3,4で注文されたことを意味する。そして、この注文番号を表2に見つけることができる。 新機能は、1次注文と最後注文の注文間隔に関する。前の注文後の累積合計である「days_cumsum」を使用して、表2で派生させることができます。最初の行の新しいフィーチャ値は26(= 26-0)です。

は、私が参加して、それを行うことができると思うが、各テーブルには、実際には非常に大きいため私はに参加使用することはできません。

だから私はループのために、以下のこの機能を使用しています:

f <- function(i){ 
    a <- table2 %>% 
    filter(user_id==table1[i, 1]) %>% 
    filter(order_number==table1[i, 3] | order_number==table1[i, 4]) 

    ifelse(nrow(a)==2, a[2, 3] - a[1, 3], 999999) # first_order==last_order 
} 

をそれは、行によってそれぞれの新しい特徴値の行を計算し、それは非常に遅く、多くの計算を必要とします。私はしばしばこの問題に直面する(2つのテーブルを使って新しい機能を作る)が、難しいことがあるたびに。

良いコードはありますか?私はあなたの助けを待っています。

+0

与え例えば、予想される出力とは何ですか? –

+0

申し訳ありませんが、コードに誤りがあります。私は –

+0

@RonakShahのエラーを修正編集します。編集した表2を使用することができます。 コード内の関数を使用すると、新しいフィーチャ値を取得できます。 期待される出力:table1で新たに追加された各フィーチャ値[5] –

答えて

3

ループを使用してjoinとバージョンのランタイム/計算時間の比較を共有できますか?

以下は、結合を使用するソリューションです。

library(tidyverse) 

df1 <- as.data.frame(table1) 
df2 <- as.data.frame(table2) 


df1 %>% 
    left_join(df2, by = c("user_id"="user_id", "first_order" = "order_number")) %>% 
    rename(dayMin = days_cumsum) %>% 
    left_join(df2, by = c("user_id"="user_id", "last_order" = "order_number")) %>% 
    rename(dayMax = days_cumsum) %>% 
    mutate(newVar = dayMax-dayMin) %>% 
    select(user_id, product_id, first_order, last_order, newVar) 

います:comparaisonについては

user_id product_id first_order last_order newVar 
    <dbl>  <dbl>  <dbl>  <dbl> <dbl> 
1  1   14   1   4  26 
2  1   24   2   7  46 
3  1   38   1   5  34 
4  1   40   4   8  33 
5  1   66   5   8  25 
6  1   2   3   3  0 
7  1   19   2   4  19 
8  1   30   4   7  27 
9  1   71   2   5  27 
10  1   98   4   9  40 
11  2   7   2   4  13 
12  2   16   3   5  12 
+0

ありがとうございます!私は今awsのインスタンスで自分のコードを実行しています。私はそれをテストし、タスクが終了したときにお知らせします。 –

+1

私のawsインスタンスはまだ動作しています。だから私は上記のサンプルデータでパフォーマンスを測定します。あなたのコードは素晴らしいです!私はマイクロベンチマークを使って測定しました。あなたのコードは6.59になり、私の関数は50.42になります。 本当にありがとうございます。ありがとうございました! –

+0

喜んで助けてください。 2番目のデータフレームdf2のカラム数が多すぎる場合は、それぞれの 'left_join'の後に' select'文を挿入して不要なカラムを取り除くことができます。 :) – Aramis7d

2

を、data.tableを使用して、いくつかのソリューションを提供しています。

table1 <- data.frame(user_id=c(1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 2, 2), 
        product_id = c(14, 24, 38, 40, 66, 2, 19, 30, 71, 98, 7, 16), 
        first_order = c(1, 2, 1, 4, 5, 3, 2, 4, 2, 4, 2, 3), 
        last_order = c(4, 7, 5, 8, 8, 3, 4, 7, 5, 9, 4, 5)) 
table2 <- data.frame(user_id=c(1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 2, 2, 2, 2, 2, 2), 
        order_number=c(1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 1, 2, 3, 4, 5, 6), 
        days_cumsum = c(0, 7, 15, 26, 34, 43, 53, 59, 66, 74, 82, 91, 5, 11, 17, 24, 29, 35)) 

library(data.table) 

setDT(table1) 
setDT(table2) 

table1 
#>  user_id product_id first_order last_order 
#> 1:  1   14   1   4 
#> 2:  1   24   2   7 
#> 3:  1   38   1   5 
#> 4:  1   40   4   8 
#> 5:  1   66   5   8 
#> 6:  1   2   3   3 
#> 7:  1   19   2   4 
#> 8:  1   30   4   7 
#> 9:  1   71   2   5 
#> 10:  1   98   4   9 
#> 11:  2   7   2   4 
#> 12:  2   16   3   5 
table2 
#>  user_id order_number days_cumsum 
#> 1:  1   1   0 
#> 2:  1   2   7 
#> 3:  1   3   15 
#> 4:  1   4   26 
#> 5:  1   5   34 
#> 6:  1   6   43 
#> 7:  1   7   53 
#> 8:  1   8   59 
#> 9:  1   9   66 
#> 10:  1   10   74 
#> 11:  1   11   82 
#> 12:  1   12   91 
#> 13:  2   1   5 
#> 14:  2   2   11 
#> 15:  2   3   17 
#> 16:  2   4   24 
#> 17:  2   5   29 
#> 18:  2   6   35 

DayMin <- table1[table2, on = .(user_id, first_order = order_number), nomatch = 0] 
setnames(DayMin, "days_cumsum", "dayMin") 
DayMax <- table1[table2, on = .(user_id, last_order = order_number), nomatch = 0] 
setnames(DayMax, "days_cumsum", "dayMax") 
res <- DayMin[DayMax, on = .(user_id, product_id, first_order, last_order)] 
# calculate diff and delete column 
res[, c("diff", "dayMax", "dayMin") := list(dayMax - dayMin, NULL, NULL)] 
res[] 
#>  user_id product_id first_order last_order diff 
#> 1:  1   2   3   3 0 
#> 2:  1   14   1   4 26 
#> 3:  1   19   2   4 19 
#> 4:  1   38   1   5 34 
#> 5:  1   71   2   5 27 
#> 6:  1   24   2   7 46 
#> 7:  1   30   4   7 27 
#> 8:  1   40   4   8 33 
#> 9:  1   66   5   8 25 
#> 10:  1   98   4   9 40 
#> 11:  2   7   2   4 13 
#> 12:  2   16   3   5 12 

"パイプで連結されたような" バージョン1つのマージのために整形使用

table1[table2, on = .(user_id, first_order = order_number), nomatch = 0][ 
    table2, on = .(user_id , last_order = order_number), nomatch = 0][ 
     , `:=`(
     diff = i.days_cumsum - days_cumsum, 
     days_cumsum = NULL, 
     i.days_cumsum = NULL 
    )][] 
#>  user_id product_id first_order last_order diff 
#> 1:  1   2   3   3 0 
#> 2:  1   14   1   4 26 
#> 3:  1   19   2   4 19 
#> 4:  1   38   1   5 34 
#> 5:  1   71   2   5 27 
#> 6:  1   24   2   7 46 
#> 7:  1   30   4   7 27 
#> 8:  1   40   4   8 33 
#> 9:  1   66   5   8 25 
#> 10:  1   98   4   9 40 
#> 11:  2   7   2   4 13 
#> 12:  2   16   3   5 12 

の名前を変更せずにのみ

tab <- melt(table1, id = 1:2, value.name = "order_number")[table2, on = .(user_id, order_number), nomatch = 0] 
res <- dcast(tab, user_id + product_id ~ variable, value.var = c("order_number", "days_cumsum"), sep = "#") 
setnames(res, c("user_id", "product_id", "first_order", "last_order", "dayMin", "dayMax")) 
res[, c("diff", "dayMax", "dayMin") := list(dayMax - dayMin, NULL, NULL)] 
res 
#>  user_id product_id first_order last_order diff 
#> 1:  1   2   3   3 0 
#> 2:  1   14   1   4 26 
#> 3:  1   19   2   4 19 
#> 4:  1   24   2   7 46 
#> 5:  1   30   4   7 27 
#> 6:  1   38   1   5 34 
#> 7:  1   40   4   8 33 
#> 8:  1   66   5   8 25 
#> 9:  1   71   2   5 27 
#> 10:  1   98   4   9 40 
#> 11:  2   7   2   4 13 
#> 12:  2   16   3   5 12 
+0

私はdata.tableの基礎を知っています。私はあなたのコードでもっと勉強しなければならない。ありがとう! –

関連する問題