Skip to content

Commit fb4b6d2

Browse files
committed
rename Evaluator to Metrics and add more metrics
1 parent b1b7dab commit fb4b6d2

File tree

4 files changed

+229
-215
lines changed

4 files changed

+229
-215
lines changed

mllib/src/main/scala/org/apache/spark/mllib/evaluation/binary/BinaryClassificationEvaluator.scala

Lines changed: 0 additions & 181 deletions
This file was deleted.
Lines changed: 57 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,57 @@
1+
/*
2+
* Licensed to the Apache Software Foundation (ASF) under one or more
3+
* contributor license agreements. See the NOTICE file distributed with
4+
* this work for additional information regarding copyright ownership.
5+
* The ASF licenses this file to You under the Apache License, Version 2.0
6+
* (the "License"); you may not use this file except in compliance with
7+
* the License. You may obtain a copy of the License at
8+
*
9+
* http://www.apache.org/licenses/LICENSE-2.0
10+
*
11+
* Unless required by applicable law or agreed to in writing, software
12+
* distributed under the License is distributed on an "AS IS" BASIS,
13+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14+
* See the License for the specific language governing permissions and
15+
* limitations under the License.
16+
*/
17+
18+
package org.apache.spark.mllib.evaluation.binary
19+
20+
/**
21+
* Trait for a binary classification evaluation metric computer.
22+
*/
23+
private[evaluation] trait BinaryClassificationMetricComputer extends Serializable {
24+
def apply(c: BinaryConfusionMatrix): Double
25+
}
26+
27+
/** Precision. */
28+
private[evaluation] object Precision extends BinaryClassificationMetricComputer {
29+
override def apply(c: BinaryConfusionMatrix): Double =
30+
c.tp.toDouble / (c.tp + c.fp)
31+
}
32+
33+
/** False positive rate. */
34+
private[evaluation] object FalsePositiveRate extends BinaryClassificationMetricComputer {
35+
override def apply(c: BinaryConfusionMatrix): Double =
36+
c.fp.toDouble / c.n
37+
}
38+
39+
/** Recall. */
40+
private[evaluation] object Recall extends BinaryClassificationMetricComputer {
41+
override def apply(c: BinaryConfusionMatrix): Double =
42+
c.tp.toDouble / c.p
43+
}
44+
45+
/**
46+
* F-Measure.
47+
* @param beta the beta constant in F-Measure
48+
* @see http://en.wikipedia.org/wiki/F1_score
49+
*/
50+
private[evaluation] case class FMeasure(beta: Double) extends BinaryClassificationMetricComputer {
51+
private val beta2 = beta * beta
52+
override def apply(c: BinaryConfusionMatrix): Double = {
53+
val precision = Precision(c)
54+
val recall = Recall(c)
55+
(1.0 + beta2) * (precision * recall) / (beta2 * precision + recall)
56+
}
57+
}

0 commit comments

Comments
 (0)