«spark_write_csv» применяется к объекту класса «c (« data.table »,« data.frame »)» - PullRequest
0 голосов
/ 24 апреля 2020

Я хочу отправить вывод на s3 в формате csv, как показано ниже

int_data[, (invites_cols_to_mask) := lapply(.SD, anonymize), .SDcols = invites_cols_to_mask]
class(int_data)

spark_write_csv(int_data, "s3://xxx/sunny/test_888.csv", mode = "overwrite")

Но код завершается ошибкой с ошибкой ниже

error in UseMethod("spark_write_csv") : 
  no applicable method for 'spark_write_csv' applied to an object of class "c('data.table', 'data.frame')"

Ниже приведен выходной результат класса

> class(int_data)
[1] "data.table" "data.frame"

Нужно ли преобразовывать что-то еще ниже, отправить его в функцию spark_write_csv?

...