You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hivemall.apache.org by my...@apache.org on 2017/09/14 05:46:32 UTC
incubator-hivemall git commit: Fixed CI error about f1score in Spark
again
Repository: incubator-hivemall
Updated Branches:
refs/heads/master 5cb3c1666 -> 06f2f8220
Fixed CI error about f1score in Spark again
Project: http://git-wip-us.apache.org/repos/asf/incubator-hivemall/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-hivemall/commit/06f2f822
Tree: http://git-wip-us.apache.org/repos/asf/incubator-hivemall/tree/06f2f822
Diff: http://git-wip-us.apache.org/repos/asf/incubator-hivemall/diff/06f2f822
Branch: refs/heads/master
Commit: 06f2f822008de1990948ffdd81022910e987d548
Parents: 5cb3c16
Author: Makoto Yui <my...@apache.org>
Authored: Thu Sep 14 14:46:23 2017 +0900
Committer: Makoto Yui <my...@apache.org>
Committed: Thu Sep 14 14:46:23 2017 +0900
----------------------------------------------------------------------
.../scala/org/apache/spark/sql/hive/HivemallGroupedDataset.scala | 4 ++--
.../scala/org/apache/spark/sql/hive/HivemallGroupedDataset.scala | 4 ++--
2 files changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-hivemall/blob/06f2f822/spark/spark-2.0/src/main/scala/org/apache/spark/sql/hive/HivemallGroupedDataset.scala
----------------------------------------------------------------------
diff --git a/spark/spark-2.0/src/main/scala/org/apache/spark/sql/hive/HivemallGroupedDataset.scala b/spark/spark-2.0/src/main/scala/org/apache/spark/sql/hive/HivemallGroupedDataset.scala
index a68f88f..7d2cd83 100644
--- a/spark/spark-2.0/src/main/scala/org/apache/spark/sql/hive/HivemallGroupedDataset.scala
+++ b/spark/spark-2.0/src/main/scala/org/apache/spark/sql/hive/HivemallGroupedDataset.scala
@@ -221,7 +221,7 @@ final class HivemallGroupedDataset(groupBy: RelationalGroupedDataset) {
}
/**
- * @see hivemall.evaluation.FMeasureUDAF
+ * @see hivemall.evaluation.F1ScoreUDAF
* @group evaluation
*/
def f1score(predict: String, target: String): DataFrame = {
@@ -229,7 +229,7 @@ final class HivemallGroupedDataset(groupBy: RelationalGroupedDataset) {
// checkType(predict, ArrayType(IntegerType))
val udaf = HiveUDAFFunction(
"f1score",
- new HiveFunctionWrapper("hivemall.evaluation.FMeasureUDAF"),
+ new HiveFunctionWrapper("hivemall.evaluation.F1ScoreUDAF"),
Seq(predict, target).map(df.col(_).expr),
isUDAFBridgeRequired = true)
.toAggregateExpression()
http://git-wip-us.apache.org/repos/asf/incubator-hivemall/blob/06f2f822/spark/spark-2.2/src/main/scala/org/apache/spark/sql/hive/HivemallGroupedDataset.scala
----------------------------------------------------------------------
diff --git a/spark/spark-2.2/src/main/scala/org/apache/spark/sql/hive/HivemallGroupedDataset.scala b/spark/spark-2.2/src/main/scala/org/apache/spark/sql/hive/HivemallGroupedDataset.scala
index 75f4bfc..a012efd 100644
--- a/spark/spark-2.2/src/main/scala/org/apache/spark/sql/hive/HivemallGroupedDataset.scala
+++ b/spark/spark-2.2/src/main/scala/org/apache/spark/sql/hive/HivemallGroupedDataset.scala
@@ -222,7 +222,7 @@ final class HivemallGroupedDataset(groupBy: RelationalGroupedDataset) {
}
/**
- * @see hivemall.evaluation.FMeasureUDAF
+ * @see hivemall.evaluation.F1ScoreUDAF
* @group evaluation
*/
def f1score(predict: String, target: String): DataFrame = {
@@ -230,7 +230,7 @@ final class HivemallGroupedDataset(groupBy: RelationalGroupedDataset) {
// checkType(predict, ArrayType(IntegerType))
val udaf = HiveUDAFFunction(
"f1score",
- new HiveFunctionWrapper("hivemall.evaluation.FMeasureUDAF"),
+ new HiveFunctionWrapper("hivemall.evaluation.F1ScoreUDAF"),
Seq(predict, target).map(df.col(_).expr),
isUDAFBridgeRequired = true)
.toAggregateExpression()