MAHOUT-1828: Change the access of blas method in sparkbindings, this closes apache/mahout#217
Project: http://git-wip-us.apache.org/repos/asf/mahout/repo Commit: http://git-wip-us.apache.org/repos/asf/mahout/commit/4856d5fd Tree: http://git-wip-us.apache.org/repos/asf/mahout/tree/4856d5fd Diff: http://git-wip-us.apache.org/repos/asf/mahout/diff/4856d5fd Branch: refs/heads/master Commit: 4856d5fdf8010127e2e7951a0045b8cc2cae9ce3 Parents: 681d30e Author: smarthi <[email protected]> Authored: Sun Apr 10 14:44:09 2016 -0400 Committer: smarthi <[email protected]> Committed: Sun Apr 10 14:44:09 2016 -0400 ---------------------------------------------------------------------- .../scala/org/apache/mahout/flinkbindings/blas/package.scala | 4 ++-- .../scala/org/apache/mahout/sparkbindings/blas/package.scala | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/mahout/blob/4856d5fd/flink/src/main/scala/org/apache/mahout/flinkbindings/blas/package.scala ---------------------------------------------------------------------- diff --git a/flink/src/main/scala/org/apache/mahout/flinkbindings/blas/package.scala b/flink/src/main/scala/org/apache/mahout/flinkbindings/blas/package.scala index 265951c..553a422 100644 --- a/flink/src/main/scala/org/apache/mahout/flinkbindings/blas/package.scala +++ b/flink/src/main/scala/org/apache/mahout/flinkbindings/blas/package.scala @@ -46,7 +46,7 @@ package object blas { */ //TODO: Remove this when FLINK-3657 is merged into Flink codebase and // replace by call to DataSetUtils.countElementsPerPartition(DataSet[K]) - private[mahout] def countsPerPartition[K](drmDataSet: DataSet[K]): DataSet[(Int, Int)] = { + private[flinkbindings] def countsPerPartition[K](drmDataSet: DataSet[K]): DataSet[(Int, Int)] = { drmDataSet.mapPartition { new RichMapPartitionFunction[K, (Int, Int)] { override def mapPartition(iterable: Iterable[K], collector: Collector[(Int, Int)]) = { @@ -65,7 +65,7 @@ package object blas { * @tparam K existing key parameter * @return */ - private[mahout] def rekeySeqInts[K: ClassTag: TypeInformation](drmDataSet: FlinkDrm[K], + private[flinkbindings] def rekeySeqInts[K: ClassTag: TypeInformation](drmDataSet: FlinkDrm[K], computeMap: Boolean = true): (DrmLike[Int], Option[DataSet[(K, Int)]]) = { http://git-wip-us.apache.org/repos/asf/mahout/blob/4856d5fd/spark/src/main/scala/org/apache/mahout/sparkbindings/blas/package.scala ---------------------------------------------------------------------- diff --git a/spark/src/main/scala/org/apache/mahout/sparkbindings/blas/package.scala b/spark/src/main/scala/org/apache/mahout/sparkbindings/blas/package.scala index a78e68e..689f786 100644 --- a/spark/src/main/scala/org/apache/mahout/sparkbindings/blas/package.scala +++ b/spark/src/main/scala/org/apache/mahout/sparkbindings/blas/package.scala @@ -42,7 +42,7 @@ package object blas { * @tparam K existing key parameter * @return */ - private[mahout] def rekeySeqInts[K](rdd: DrmRdd[K], computeMap: Boolean = true): (DrmRdd[Int], + private[sparkbindings] def rekeySeqInts[K](rdd: DrmRdd[K], computeMap: Boolean = true): (DrmRdd[Int], Option[RDD[(K, Int)]]) = { // Spark context please.
