You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mahout.apache.org by ap...@apache.org on 2016/03/27 21:36:42 UTC
[03/10] mahout git commit: add unchace
add unchace
Project: http://git-wip-us.apache.org/repos/asf/mahout/repo
Commit: http://git-wip-us.apache.org/repos/asf/mahout/commit/ad4c32ce
Tree: http://git-wip-us.apache.org/repos/asf/mahout/tree/ad4c32ce
Diff: http://git-wip-us.apache.org/repos/asf/mahout/diff/ad4c32ce
Branch: refs/heads/flink-binding
Commit: ad4c32ce871df686267df1f1dbff76a883b8d3fc
Parents: 9c5ee59
Author: Andrew Palumbo <ap...@apache.org>
Authored: Fri Mar 25 18:31:51 2016 -0400
Committer: Andrew Palumbo <ap...@apache.org>
Committed: Fri Mar 25 18:31:51 2016 -0400
----------------------------------------------------------------------
.../apache/mahout/flinkbindings/drm/CheckpointedFlinkDrm.scala | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/mahout/blob/ad4c32ce/flink/src/main/scala/org/apache/mahout/flinkbindings/drm/CheckpointedFlinkDrm.scala
----------------------------------------------------------------------
diff --git a/flink/src/main/scala/org/apache/mahout/flinkbindings/drm/CheckpointedFlinkDrm.scala b/flink/src/main/scala/org/apache/mahout/flinkbindings/drm/CheckpointedFlinkDrm.scala
index 65acbd6..5246938 100644
--- a/flink/src/main/scala/org/apache/mahout/flinkbindings/drm/CheckpointedFlinkDrm.scala
+++ b/flink/src/main/scala/org/apache/mahout/flinkbindings/drm/CheckpointedFlinkDrm.scala
@@ -27,6 +27,7 @@ import org.apache.flink.core.fs.Path
import org.apache.flink.api.scala.hadoop.mapred.HadoopOutputFormat
import org.apache.hadoop.io.{IntWritable, LongWritable, Text, Writable}
import org.apache.hadoop.mapred.{FileOutputFormat, JobConf, SequenceFileOutputFormat}
+import org.apache.mahout.flinkbindings.io.Hadoop2HDFSUtil
import org.apache.mahout.flinkbindings.{DrmDataSet, _}
import org.apache.mahout.math._
import org.apache.mahout.math.drm.CacheHint._
@@ -92,7 +93,10 @@ class CheckpointedFlinkDrm[K: ClassTag:TypeInformation](val ds: DrmDataSet[K],
}
def uncache() = {
- // TODO
+ if (isCached) {
+ Hadoop2HDFSUtil.delete(cacheFileName)
+ isCached = false
+ }
this
}