如何将多个RDD [(String,Double,Double)]组合成一个RDD?

问题描述 投票:1回答:1
for(i <- 1 to 20) {
    val tmp = rdd.sample(true, 1)
    val rdd2 = resampledData(tmp)
    }

我想在单个rdd中将每个rdd2组合在循环中。 rdd2的类型是RDD [(String,Double,Double)]如何在需要时初始化新的vriable?

scala
1个回答
0
投票

val combined =(1到20).map(x => resampledData(rdd.sample(true,1)))。reduce(_ union _)

© www.soinside.com 2019 - 2024. All rights reserved.