样本数据
# Set seed for reproducibility
set.seed(123)
# Create a sample dataframe with 100 observations
n_obs <- 100
df <- data.frame(
serial_id = 1:n_obs,
code_1 = sample(c("yes", "no"), n_obs, replace = TRUE),
code_2 = sample(c("yes", "no"), n_obs, replace = TRUE),
code_3 = sample(c("yes", "no"), n_obs, replace = TRUE),
type_1 = sample(c("A", "B", "C", "D"), n_obs, replace = TRUE),
type_2 = sample(c("A", "B", "C", "D"), n_obs, replace = TRUE),
type_3 = sample(c("A", "B", "C", "D"), n_obs, replace = TRUE)
)
我正在尝试创建一个满足以下逻辑的变量:
我不知道如何根据最后一个字符(1,2,3,4,5,6.......)获取相应列的名称,然后对列执行行操作那个孤立的行。 原始数据大约有20对这样的code_*和type_*。所以,我正在尝试想出一些可迭代的东西。
转换为 long,将代码和类型配对转换为更宽的格式,应用
serial_id
和 any()
的规则,然后将新变量左连接回 serial_id
上的原始数据集。这应该适用于您拥有的尽可能多的代码/类型对。
# Set seed for reproducibility
set.seed(123)
# Create a sample dataframe with 100 observations
library(data.table)
n_obs <- 100
df <- data.table(
serial_id = 1:n_obs,
code_1 = sample(c("yes", "no"), n_obs, replace = TRUE),
code_2 = sample(c("yes", "no"), n_obs, replace = TRUE),
code_3 = sample(c("yes", "no"), n_obs, replace = TRUE),
type_1 = sample(c("A", "B", "C", "D"), n_obs, replace = TRUE),
type_2 = sample(c("A", "B", "C", "D"), n_obs, replace = TRUE),
type_3 = sample(c("A", "B", "C", "D"), n_obs, replace = TRUE)
)
# Convert to long format
df_long <- melt(df, id.vars = 'serial_id')
df_long[, type := tstrsplit(variable, "_", keep = 1)]
df_long[, index := tstrsplit(variable, "_", keep = 2)]
# Cast to a paired wide format.
df_wide <- dcast(df_long, serial_id + index ~ type,
value.var = "value")
# Apply rules
# Rule 1) Any yes + A => new_var = 1.
df_wide[, new_var := ifelse(any(code == "yes" & type == "A"), 1, NA_real_),
by = serial_id]
# Rule 2) Any yes + B => new_var = 0, Overwrite rule 1, not rule 2
df_wide[, new_var := ifelse(any(code == "yes" & type == "B"), 0, new_var),
by = serial_id]
# Rule 3) all(no + B, no + C, yes + C) => new_var = 1. Overwrite rule 2.
# Example, serial_id = 38.
df_wide[, new_var :=
ifelse(any(code == "no" & type == "B") &
any(code == "no" & type == "C") &
any(code == "yes" & type == "C"), 1, new_var),
by = serial_id]
# Join back to the original data frame
df[df_wide[, .SD[1], by = serial_id],
new_var := new_var, on = .(serial_id)]