Объедините уникальные строки из нескольких data.tables и добавьте детали атрибута - PullRequest
0 голосов
/ 28 января 2019

У меня есть две таблицы data.table в этом формате (в каждой таблице по миллиону строк):

library(data.table)

dt1 <- data.table(
  code=c("A001", "A002","A003","A004","A005"),
  x=c(65,92,25,450,12), 
  y=c(98,506,72,76,15),
  no1=c(010101, 010156, 028756, 372576,367383),
  no2=c(876362,"",682973,78269,"")
)


dt2 <- data.table(
  code=c("A003", "A004","A005","A006","A007","A008","A009"),
  x=c(25,126,12,55,34,134,55), 
  y=c(72,76,890,568,129,675,989),
  no1=c(028756, 372576,367383,234876, 287156, 123348, 198337),
  no2=c(682973,78269,65378,"","","",789165)
)

Я хотел бы объединить две таблицы и сохранить только уникальные строки на основе всехЗаписи в столбцах уникальны.Это то, что у меня есть, но я предполагаю, что есть лучший способ сделать это:

dt3 <- rbindlist(list(dt1, dt2))
dt3 <- unique(dt3, by = c("code", "x", "y", "no1", "no2"))

Как только у меня есть этот единственный набор данных, я хотел бы дать любым дублирующим записям «кода» некоторую информацию об атрибутах (номер версии икомментарий о том, что отличается в этой версии от предыдущей).Вывод, который я ищу, будет таким:

dt4 <- data.table(
  code=c("A001", "A002","A003","A004","A005", "A004","A005","A006","A007","A008","A009"),
  x=c(65,92,25,450,12,126,12,55,34,134,55), 
  y=c(98,506,72,76,15,76,890,568,129,675,989),
  no1=c(010101, 010156, 028756, 372576,367383, 372576,367383,234876, 287156, 123348, 198337),
  no2=c(876362,"",682973,78269,"",78269,65378,"","","",789165),
  version = c("V1","V1","V1","V1","V1","V2","V2","V1","V1","V1","V1"),
  unique_version=c("A001_V1", "A002_V1","A003_V1","A004_V1","A005_V1", "A004_V2","A005_V2","A006_V1","A007_V1","A008_V1","A009_V1"),
  comment = c("First_entry","First_entry","First_entry","First_entry","First_entry","New_x", "New_y_and_no2","First_entry","First_entry","First_entry","First_entry")
  )

Я не уверен, как достичь dt4 (и эффективно, учитывая, что размер реального набора данных будет более миллиона строк).

Редактировать

Применив решение @ Chase к моим реальным данным, я заметил, что мой пример dt3 немного отличается от типа получаемого результата.Это больше похоже на мои реальные данные:

dt6 <- data.table(
  code=c("A111", "A111","A111","A111","A111", "A111","A111","A234", "A234","A234","A234","A234", "A234","A234"),
  x=c("",126,126,"",836,843,843,126,126,"",127,836,843,843), 
  y=c("",76,76,"",456,465,465,76,76,"",77,456,465,465),
  no1=c(028756, 028756,028756,057756, 057756, 057756, 057756,028756, 028756,057756,057756, 057756, 057756, 057756),
  no2=c("","",034756,"","","",789165,"",034756,"","","","",789165)
)

comp_cols <- c("x", "y", "no1", "no2")

#grabs the names of the mismatching values and formats them how you did
f <- function(x,y) {
  n_x <- names(x)
  diff <- x != y
  paste0("New_", paste0(n_x[diff], collapse = "_and_"))
}


dt6[, version := paste0("V", 1:.N), by = code]
dt6[, unique_version := paste(code, version, sep = "_")]
dt6[, comment := ifelse(version == "V1", "First_entry", f(.SD[1], .SD[2])), by = code, .SDcols = comp_cols]

Как видите, предлагаемое решение для создания столбца комментариев, похоже, возвращает только первое изменение между первой и второй версиями (а не изменения лучше V2и V3 и т. д.)

1 Ответ

0 голосов
/ 28 января 2019

Вот одно решение - первые два тривиальны, комментарий требует немного больше размышлений:

dt5 <- copy(dt3)

comp_cols <- c("x", "y", "no1", "no2")

#grabs the names of the mismatching values and formats them how you did
f <- function(x,y) {
  n_x <- names(x)
  diff <- x != y
  paste0("New_", paste0(n_x[diff], collapse = "_and"))
}


dt5[, version := paste0("V", 1:.N), by = code]
dt5[, unique_version := paste(code, version, sep = "_")]
dt5[, comment := ifelse(version == "V1", "First_entry", f(.SD[1], .SD[2])), by = code, .SDcols = comp_cols]

В итоге получим следующее:

> dt5
    code   x   y    no1    no2 version unique_version      comment
 1: A001  65  98  10101 876362      V1        A001_V1  First_entry
 2: A002  92 506  10156             V1        A002_V1  First_entry
 3: A003  25  72  28756 682973      V1        A003_V1  First_entry
 4: A004 450  76 372576  78269      V1        A004_V1  First_entry
 5: A005  12  15 367383             V1        A005_V1  First_entry
 6: A004 126  76 372576  78269      V2        A004_V2        New_x
 7: A005  12 890 367383  65378      V2        A005_V2 New_y_andno2
 8: A006  55 568 234876             V1        A006_V1  First_entry
 9: A007  34 129 287156             V1        A007_V1  First_entry
10: A008 134 675 123348             V1        A008_V1  First_entry
11: A009  55 989 198337 789165      V1        A009_V1  First_entry
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...