колонка падения в функции sparkR

Question

, я хочу, чтобы написать функцию, чтобы удалить столбец из SparkR DataFrame (версия 1.6.0):

dropColumn <- function(df, col) { 
    df[[col]] <- NULL 
    df 
} 
df <- dropColumn(df, 'Email') 

Но было бы без ошибок:

Error in `[[<-`(`*tmp*`, col, value = NULL) : 
[[<- defined for objects of type "S4" only for subclasses of environment 

Как я могу изменить свой код, исправьте его?

Answer 1

В настоящее время нет метода удобства в dataframe для удаления столбца. Я думаю, что это будет работать до тех пор, пока оно не сможет быть реализовано в SparkR:

dropColumn <- function(df, col) { 
    tempdf <- new("DataFrame", 
      sdf=SparkR:::callJMethod(df@sdf, "drop", col), 
      isCached=FALSE) 
    tempdf 
} 
newdf <- dropColumn(inputdf, 'Email')