You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mahout.apache.org by sm...@apache.org on 2016/04/11 10:10:03 UTC
[36/50] [abbrv] mahout git commit: MAHOUT-1828: Change the access of
blas method in sparkbindings, this closes apache/mahout#217
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 <sm...@apache.org>
Authored: Sun Apr 10 14:44:09 2016 -0400
Committer: smarthi <sm...@apache.org>
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.