나는 XDF 파일에서 다른 덩어리에 존재하는 값을 집계 찾아 봤는데,하지만 난 그게 작동시킬 수 없어요 RevoScaleR 패키지

Question

에 rxDataStep를 사용하여 기능을 "적용".

당신의 어떤 rxDataStep에 변환 (A)의 내부에 함수를 적용하면 사용했던 코드 조각이겠습니까?

Answer 1

transformFunc를 사용하여 변환 함수를 적용하십시오. 필요한 패키지를 작업자 노드에 설치해야합니다. transformObject를 사용하여 transformFunc에 함수를 제공하십시오.

xformFunction <- function(data) { 
    require(dplyr) 
    df <- as.data.frame(data) 
    df <- dplyr::summarise(dplyr::group_by(df, z)) 
    return(df) 
} 

rxDataStep(inData = input_xdf, outFile = t_xdf, transformFunc = xformFunction, transformPackages = c("dplyr"), overwrite = TRUE) 

집합은 노드에 있으므로 Spark ComputeContext를 사용할 때 중복 된 z 값을 갖게됩니다.