如何在R中重命名Sparkyr中的列?

更名惯例正好相反( new name = old name )

您正在寻找以下内容:

mydata %>% 
    select(V1 = customer,
           V2 = device_subscriber_id,
           V3 = user_subscriber_id,
           V4 = user_id,
           V5 = location_id) 

如果您想要特定的名称,只需在读取时提供一个名称向量:

columns <- c("customer", "device_subscriber_id", 
             "user_subscriber_id", "user_id", "location_id")

spark_read_csv(
   spark_cluster, name = "rd_1",path = "IAF_Extracted_Data_Zipped.csv",
   header = FALSE, columns = columns, delimiter = "|"
)

人数 columns 应与输入中的列数匹配。

在我的头顶你可以试试 customer = mydata$V1 其他变量也类似(假设 V1,... 是的列名 mydata ).