这将相当快
f1 = function(df, column_name) {
## pre-process words
words = strsplit(df[[column_name]], ",")
uwords = unlist(words)
colnames = unique(uwords)
## pre-allocate result matrix of 'FALSE' values
m = matrix(FALSE, nrow(df), length(colnames), dimnames = list(NULL, colnames))
## update rows and columns of result matrix containing matches to TRUE
row = rep(seq_len(nrow(df)), lengths(words))
col = match(uwords, colnames)
m[cbind(row, col)] = TRUE
## return the final result
cbind(df, m)
}
最棘手的部分是双列矩阵的矩阵子集将双列矩阵的第一列作为行索引,将第二列作为列索引。所以你要设置的行和列TRUE
是
row = rep(seq_len(nrow(df)), lengths(words))
col = match(uwords, colnames)
并且矩阵更新为
m[ cbind(row, col) ] = TRUE
没有迭代(例如,sapply()
),因此该match()
函数被调用一次而不是nrow(df)
多次。
对于 3M 行,我有
> idx = rep(1:3, 1000000)
> df1 = df[idx,]
> system.time(f1(df1, "items"))
user system elapsed
13.304 0.112 13.421
对于 Christoph 的另一个解决方案(在撰写本文时):
f0 = function(df, column_name) {
categories_per_row <- strsplit(df[[column_name]], split=",")
categories <- unique(unlist(categories_per_row))
categoryM <- t(sapply(categories_per_row, function(y) categories %in% y))
colnames(categoryM) <- categories
cbind(df, categoryM)
}
和 Uwe 的 data.table 解决方案(注意,引用语义会改变 dt 的值!另外,我不知道如何将列名作为函数参数传递):
library(data.table)
dt = df1
dt$no = seq_len(nrow(dt))
f2 = function(dt) {
setDT(dt)
dt1 = dt[, strsplit(items, ","), by = .(no, items)]
dt1[, dcast(.SD, no + items ~ V1, function(x) length(x) > 0)]
}
与时俱进
> system.time(res0 <- f0(df1, "items"))
user system elapsed
23.776 0.000 23.786
> system.time(res2 <- f2(dt, "items"))
Using 'V1' as value column. Use 'value.var' to override
user system elapsed
45.668 0.072 45.593
大约 1/2 的时间f1()
被strsplit()
; stringr::str_split()
大约快两倍,但由于用于拆分的模式是固定的(不是正则表达式),因此使用 是有意义的strsplit(fixed=TRUE)
,大约快 3 倍。可能一些 data.table pro 会想出一个非常快速的解决方案(但是你需要成为一个 data.table pro ......)。
做类似“将它们[项目共享的单词]折叠到列表[实际上是一个向量!]”之类的事情很诱人,但将单词留在列表中通常是明智的
> df1$items = strsplit(df1$items, ",", fixed=TRUE)
> head(df1)
no items
1 1 fish, cat, dog
2 2 horse, elephant, dog
3 3 hamster, pig
4 4 fish, cat, dog
5 5 horse, elephant, dog
6 6 hamster, pig
并节省重新拆分所需的时间/麻烦。tidyverse 方法是创建表的扩展版本
tidyr::unnest(df1)
(或所谓的“重复”问题中的其他方法)。这可能会导致人们重新思考逻辑列在后续操作中的作用。