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 <[email protected]> Authored: Fri Mar 25 16:56:20 2016 -0400 Committer: Andrew Palumbo <[email protected]> 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
