Searched refs:rdd5 (Results 1 – 3 of 3) sorted by relevance
879 val rdd5 = rdd4.mapValues(_ + 1).mapValues(_ + 2).mapValues(_ + 3) constant884 val ancestors5 = rdd5.getNarrowAncestors908 val rdd5 = rdd2.map(i => (i, i)) constant912 val rdd9 = rdd4.join(rdd5)953 val rdd5 = rdd4.map(_ + 2).filter(_ > 20) constant954 val rdd6 = sc.union(rdd1, rdd2, rdd3).map(_ + 4).union(rdd5).union(rdd4)982 val ancestors5 = rdd5.getNarrowAncestors
285 val rdd5 = testStateUpdates( constant
729 rdd5 <- parallelize(sc, l, 2L) globalVar730 sortedRdd5 <- sortByKey(rdd5, numPartitions = 1L)