| /dports/devel/spark/spark-2.1.1/mllib/src/test/java/org/apache/spark/mllib/random/ |
| H A D | JavaRandomRDDsSuite.java | 41 JavaDoubleRDD rdd3 = uniformJavaRDD(jsc, m, p, seed); in testUniformRDD() local
54 JavaDoubleRDD rdd3 = normalJavaRDD(jsc, m, p, seed); in testNormalRDD() local
69 JavaDoubleRDD rdd3 = logNormalJavaRDD(jsc, mean, std, m, p, seed); in testLNormalRDD() local
83 JavaDoubleRDD rdd3 = poissonJavaRDD(jsc, mean, m, p, seed); in testPoissonRDD() local
97 JavaDoubleRDD rdd3 = exponentialJavaRDD(jsc, mean, m, p, seed); in testExponentialRDD() local
112 JavaDoubleRDD rdd3 = gammaJavaRDD(jsc, shape, jscale, m, p, seed); in testGammaRDD() local
128 JavaRDD<Vector> rdd3 = uniformJavaVectorRDD(jsc, m, n, p, seed); in testUniformVectorRDD() local
144 JavaRDD<Vector> rdd3 = normalJavaVectorRDD(jsc, m, n, p, seed); in testNormalVectorRDD() local
179 JavaRDD<Vector> rdd3 = poissonJavaVectorRDD(jsc, mean, m, n, p, seed); in testPoissonVectorRDD() local
196 JavaRDD<Vector> rdd3 = exponentialJavaVectorRDD(jsc, mean, m, n, p, seed); in testExponentialVectorRDD() local
[all …]
|
| /dports/devel/spark/spark-2.1.1/core/src/test/scala/org/apache/spark/rdd/ |
| H A D | RDDOperationScopeSuite.scala | 70 var rdd3: MyCoolRDD = null variable
93 var rdd3: MyCoolRDD = null variable
118 var rdd3: MyCoolRDD = null variable
|
| H A D | LocalCheckpointSuite.scala | 232 val rdd3 = rdd2.map { i => i + "3" } constant
287 val rdd3 = rdd2.repartition(1000) constant
|
| H A D | RDDSuite.scala | 867 val rdd3 = rdd2.map(_ + 1) constant
877 val rdd3 = rdd2.map(_ - 1).filter(_ < 50).map(i => (i, i)) constant
906 val rdd3 = sc.parallelize(1 to 300, 15).filter(_ > 50) constant
951 val rdd3 = new CyclicalDependencyRDD[Int] constant
|
| H A D | PairRDDFunctionsSuite.scala | 378 val rdd3 = sc.parallelize(Array((1, 'a'), (3, 'b'), (4, 'c'), (4, 'd'))) constant
394 val rdd3 = sc.parallelize(Array((1, 'a'), (3, 'b'), (4, 'c'), (4, 'd'))) constant
|
| /dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/rdd/ |
| H A D | ZippedPartitionsRDD.scala | 106 var rdd3: RDD[C], variable
132 var rdd3: RDD[C], variable
|
| /dports/devel/spark/spark-2.1.1/core/src/test/scala/org/apache/spark/ui/storage/ |
| H A D | StoragePageSuite.scala | 48 val rdd3 = new RDDInfo(3, constant
|
| /dports/devel/spark/spark-2.1.1/external/kafka-0-8/src/test/java/org/apache/spark/streaming/kafka/ |
| H A D | JavaKafkaRDDSuite.java | 123 JavaRDD<String> rdd3 = KafkaUtils.createRDD( in testKafkaRDD() local
|
| /dports/devel/spark/spark-2.1.1/external/kafka-0-8/src/test/scala/org/apache/spark/streaming/kafka/ |
| H A D | KafkaRDDSuite.scala | 138 val rdd3 = getRdd(kc, Set(topic)) constant
|
| /dports/devel/spark/spark-2.1.1/external/kafka-0-10/src/test/scala/org/apache/spark/streaming/kafka010/ |
| H A D | KafkaRDDSuite.scala | 139 val rdd3 = KafkaUtils.createRDD[String, String](sc, kafkaParams, constant
|
| /dports/devel/spark/spark-2.1.1/streaming/src/test/scala/org/apache/spark/streaming/rdd/ |
| H A D | MapWithStateRDDSuite.scala | 277 val rdd3 = testStateUpdates( constant
|
| /dports/devel/spark/spark-2.1.1/R/pkg/inst/tests/testthat/ |
| H A D | test_binary_function.R | 74 rdd3 <- parallelize(sc, 1:6, 2L) # 1:3, 4:6 globalVar
|
| H A D | test_context.R | 87 rdd3 <- parallelize(sc, 1:20, 2L) # rdd3 should get id 1 now globalVar
|
| H A D | test_rdd.R | 715 rdd3 <- parallelize(sc, l, 2L) globalVar
|
| /dports/devel/spark/spark-2.1.1/core/src/test/scala/org/apache/spark/scheduler/ |
| H A D | SparkListenerSuite.scala | 169 val rdd3 = rdd2.reduceByKey(_ + _) constant
|
| H A D | DAGSchedulerSuite.scala | 1968 val rdd3 = new MyRDD(sc, 2, List(dep2), tracker = mapOutputTracker) constant
|
| /dports/devel/spark/spark-2.1.1/external/java8-tests/src/test/java/test/org/apache/spark/java8/ |
| H A D | Java8RDDAPISuite.java | 316 JavaPairRDD<Integer, Integer> rdd3 = in mapOnPairRDD() local
|
| /dports/devel/spark/spark-2.1.1/core/src/test/java/org/apache/spark/ |
| H A D | JavaAPISuite.java | 990 JavaPairRDD<String, Integer> rdd3 = sc.parallelizePairs(Arrays.asList( in getNumPartitions() local
1538 JavaPairRDD<Integer, Integer> rdd3 = rdd2.mapToPair( in mapOnPairRDD() local
|
| /dports/devel/spark/spark-2.1.1/streaming/src/test/java/org/apache/spark/streaming/ |
| H A D | JavaAPISuite.java | 384 JavaRDD<Integer> rdd3 = jsc.parallelize(Arrays.asList(7,8,9)); in testQueueStream() local
|