mahout-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From smar...@apache.org
Subject [07/50] [abbrv] mahout git commit: Small change addressing DL's comment on apache/mahout#200, also a small fix
Date Mon, 11 Apr 2016 08:09:34 GMT
Small change addressing DL's comment on apache/mahout#200, also a small fix


Project: http://git-wip-us.apache.org/repos/asf/mahout/repo
Commit: http://git-wip-us.apache.org/repos/asf/mahout/commit/a1cf7cf5
Tree: http://git-wip-us.apache.org/repos/asf/mahout/tree/a1cf7cf5
Diff: http://git-wip-us.apache.org/repos/asf/mahout/diff/a1cf7cf5

Branch: refs/heads/master
Commit: a1cf7cf56e036ce12d616f8aea0af1e9dcdf2cb6
Parents: e3c8db5
Author: Andrew Palumbo <apalumbo@apache.org>
Authored: Fri Mar 25 16:56:20 2016 -0400
Committer: Andrew Palumbo <apalumbo@apache.org>
Committed: Fri Mar 25 16:56:20 2016 -0400

----------------------------------------------------------------------
 .../scala/org/apache/mahout/flinkbindings/FlinkEngine.scala    | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/mahout/blob/a1cf7cf5/flink/src/main/scala/org/apache/mahout/flinkbindings/FlinkEngine.scala
----------------------------------------------------------------------
diff --git a/flink/src/main/scala/org/apache/mahout/flinkbindings/FlinkEngine.scala b/flink/src/main/scala/org/apache/mahout/flinkbindings/FlinkEngine.scala
index c355cae..af508b3 100644
--- a/flink/src/main/scala/org/apache/mahout/flinkbindings/FlinkEngine.scala
+++ b/flink/src/main/scala/org/apache/mahout/flinkbindings/FlinkEngine.scala
@@ -127,6 +127,7 @@ object FlinkEngine extends DistributedEngine {
     newcp.cache()
   }
 
+
   private def flinkTranslate[K](oper: DrmLike[K]): FlinkDrm[K] = {
     implicit val kTag = oper.keyClassTag
     implicit val typeInformation = generateTypeInformation[K]
@@ -358,7 +359,7 @@ object FlinkEngine extends DistributedEngine {
   }
 
   def generateTypeInformation[K: ClassTag]: TypeInformation[K] = {
-    val tag = implicitly[ClassTag[K]]
+    implicit val tag = ClassTag[K]
 
     generateTypeInformationFromTag(tag)
   }
@@ -374,7 +375,4 @@ object FlinkEngine extends DistributedEngine {
       throw new IllegalArgumentException(s"index type $tag is not supported")
     }
   }
-  object FlinkEngine {
-
-  }
 }
\ No newline at end of file


Mime
View raw message