Repository: mahout Updated Branches: refs/heads/flink-binding fd0112dcf -> b52036cc9
MAHOUT-1808: Some cleanup of unused operations in sparkbindings closes apache/mahout#190 Project: http://git-wip-us.apache.org/repos/asf/mahout/repo Commit: http://git-wip-us.apache.org/repos/asf/mahout/commit/f2aef44c Tree: http://git-wip-us.apache.org/repos/asf/mahout/tree/f2aef44c Diff: http://git-wip-us.apache.org/repos/asf/mahout/diff/f2aef44c Branch: refs/heads/flink-binding Commit: f2aef44cd592904a1baba5e798b3b0d84c089930 Parents: fd0112d Author: Andrew Palumbo <[email protected]> Authored: Tue Mar 15 12:59:20 2016 -0400 Committer: Andrew Palumbo <[email protected]> Committed: Tue Mar 15 16:34:12 2016 -0400 ---------------------------------------------------------------------- .../scala/org/apache/mahout/sparkbindings/drm/DrmRddInput.scala | 3 --- 1 file changed, 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/mahout/blob/f2aef44c/spark/src/main/scala/org/apache/mahout/sparkbindings/drm/DrmRddInput.scala ---------------------------------------------------------------------- diff --git a/spark/src/main/scala/org/apache/mahout/sparkbindings/drm/DrmRddInput.scala b/spark/src/main/scala/org/apache/mahout/sparkbindings/drm/DrmRddInput.scala index 5c9319a..65d5d66 100644 --- a/spark/src/main/scala/org/apache/mahout/sparkbindings/drm/DrmRddInput.scala +++ b/spark/src/main/scala/org/apache/mahout/sparkbindings/drm/DrmRddInput.scala @@ -38,7 +38,4 @@ class DrmRddInput[K: ClassTag](private val input: Either[DrmRdd[K], BlockifiedDr def sparkContext: SparkContext = backingRdd.sparkContext - def persist(sl: StorageLevel) = backingRdd.persist(newLevel = sl) - - def unpersist(blocking: Boolean = true) = backingRdd.unpersist(blocking) }
