WIP, Flink-Mahout integration, created a decorator; this closes apache/mahout#167
Project: http://git-wip-us.apache.org/repos/asf/mahout/repo Commit: http://git-wip-us.apache.org/repos/asf/mahout/commit/854a2893 Tree: http://git-wip-us.apache.org/repos/asf/mahout/tree/854a2893 Diff: http://git-wip-us.apache.org/repos/asf/mahout/diff/854a2893 Branch: refs/heads/flink-binding Commit: 854a2893c9b30fea78f9f93d59848f0eb62b175b Parents: 38d0808 Author: smarthi <[email protected]> Authored: Tue Oct 27 00:19:46 2015 -0400 Committer: smarthi <[email protected]> Committed: Tue Oct 27 00:19:46 2015 -0400 ---------------------------------------------------------------------- .../main/scala/org/apache/mahout/flinkbindings/FlinkEngine.scala | 2 -- 1 file changed, 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/mahout/blob/854a2893/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 0bc12aa..3db0319 100644 --- a/flink/src/main/scala/org/apache/mahout/flinkbindings/FlinkEngine.scala +++ b/flink/src/main/scala/org/apache/mahout/flinkbindings/FlinkEngine.scala @@ -20,8 +20,6 @@ package org.apache.mahout.flinkbindings import java.util.Collection -import org.apache.flink.api.java.utils.DataSetUtils - import scala.collection.JavaConverters._ import scala.collection.JavaConversions._ import scala.reflect.ClassTag
