| /dports/devel/spark/spark-2.1.1/mllib/src/main/scala/org/apache/spark/mllib/evaluation/ |
| H A D | MultilabelMetrics.scala | 102 }.countByValue()
106 }.countByValue()
110 }.countByValue()
|
| H A D | MulticlassMetrics.scala | 42 private lazy val labelCountByClass: Map[Double, Long] = predictionAndLabels.values.countByValue()
|
| /dports/devel/spark/spark-2.1.1/streaming/src/main/scala/org/apache/spark/streaming/api/java/ |
| H A D | JavaDStreamLike.scala | 86 def countByValue(): JavaPairDStream[T, jl.Long] = { method
87 JavaPairDStream.scalaToJavaLong(dstream.countByValue())
96 def countByValue(numPartitions: Int): JavaPairDStream[T, jl.Long] = { method
97 JavaPairDStream.scalaToJavaLong(dstream.countByValue(numPartitions))
|
| /dports/devel/spark/spark-2.1.1/external/kafka-0-8/src/test/scala/org/apache/spark/streaming/kafka/ |
| H A D | KafkaStreamSuite.scala | 69 stream.map(_._2).countByValue().foreachRDD { r =>
|
| /dports/devel/spark/spark-2.1.1/examples/src/main/scala/org/apache/spark/examples/streaming/clickstream/ |
| H A D | PageViewStream.scala | 60 val pageCounts = pageViews.map(view => view.url).countByValue()
|
| /dports/devel/spark/spark-2.1.1/examples/src/main/scala/org/apache/spark/examples/graphx/ |
| H A D | SynthBenchmark.scala | 105 .map(p => p._2).countByValue()
|
| /dports/devel/spark/spark-2.1.1/external/kafka-0-8/src/test/java/org/apache/spark/streaming/kafka/ |
| H A D | JavaKafkaStreamSuite.java | 107 words.countByValue().foreachRDD(new VoidFunction<JavaPairRDD<String, Long>>() { in testKafkaStream()
|
| /dports/devel/spark/spark-2.1.1/mllib/src/main/scala/org/apache/spark/mllib/stat/test/ |
| H A D | ChiSqTest.scala | 120 }.countByValue()
|
| /dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/api/java/ |
| H A D | JavaRDDLike.scala | 487 def countByValue(): JMap[T, jl.Long] = method
488 mapAsSerializableJavaMap(rdd.countByValue()).asInstanceOf[JMap[T, jl.Long]]
|
| /dports/devel/spark/spark-2.1.1/mllib/src/main/scala/org/apache/spark/ml/feature/ |
| H A D | StringIndexer.scala | 92 .countByValue()
|
| /dports/devel/spark/spark-2.1.1/examples/src/main/scala/org/apache/spark/examples/mllib/ |
| H A D | DecisionTreeRunner.scala | 184 val classCounts = origExamples.map(_.label).countByValue()
|
| /dports/devel/spark/spark-2.1.1/mllib/src/main/scala/org/apache/spark/mllib/clustering/ |
| H A D | KMeans.scala | 399 val countMap = data.map(KMeans.findClosest(bcCenters.value, _)._1).countByValue()
|
| /dports/devel/spark/spark-2.1.1/R/pkg/R/ |
| H A D | pairRDD.R | 77 countByValue(keys)
|
| /dports/devel/spark/spark-2.1.1/python/pyspark/streaming/ |
| H A D | dstream.py | 245 def countByValue(self): member in DStream
|
| H A D | tests.py | 283 return dstream.countByValue()
|
| /dports/devel/spark/spark-2.1.1/python/pyspark/ |
| H A D | rdd.py | 1228 def countByValue(self): member in RDD
1643 return self.map(lambda x: x[0]).countByValue()
|
| /dports/devel/spark/spark-2.1.1/streaming/src/main/scala/org/apache/spark/streaming/dstream/ |
| H A D | DStream.scala | 616 def countByValue(numPartitions: Int = ssc.sc.defaultParallelism)(implicit ord: Ordering[T] = null) method
|
| /dports/devel/spark/spark-2.1.1/streaming/src/test/scala/org/apache/spark/streaming/ |
| H A D | BasicOperationsSuite.scala | 162 (s: DStream[Int]) => s.countByValue(),
|
| /dports/devel/spark/spark-2.1.1/R/pkg/inst/tests/testthat/ |
| H A D | test_rdd.R | 49 actual <- countByValue(mods)
|
| /dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/rdd/ |
| H A D | RDD.scala | 1203 def countByValue()(implicit ord: Ordering[T] = null): Map[T, Long] = withScope { method
|
| /dports/devel/spark/spark-2.1.1/streaming/src/test/java/org/apache/spark/streaming/ |
| H A D | JavaAPISuite.java | 1243 JavaPairDStream<String, Long> counted = stream.countByValue(); in testCountByValue()
|
| /dports/devel/spark/spark-2.1.1/core/src/test/java/org/apache/spark/ |
| H A D | JavaAPISuite.java | 666 Map<Integer, Long> countsByValue = rdd.countByValue(); in approximateResults()
|
| /dports/devel/spark/spark-2.1.1/docs/ |
| H A D | streaming-programming-guide.md | 761 <td> <b>countByValue</b>() </td>
|