如何将多个RDD [(字符串,double,double)]组合到一个RDD中


for(i <- 1 to 20) {
    val tmp = rdd.sample(true, 1)
    val rdd2 = resampledData(tmp)
    }

我想将每个RDD2组合在单个RDD中。rdd2的类型是rdd [(字符串,double,double(],如果需要,我该如何初始化新的vrable?

val combined =(1至20(.map(x => resampleddata(rdd.sample(true,1(((。降低(_ UNIOM _(

最新更新