Disabled checkpoint for PairwiseRDD (pySpark).

2013-01-16 10:55:26 -08:00 · 2013-01-16 10:55:26 -08:00 · a805ac4a7c
parent cd1521cfdb
commit a805ac4a7c
1 changed files with 1 additions and 0 deletions
--- a/core/src/main/scala/spark/api/python/PythonRDD.scala
+++ b/core/src/main/scala/spark/api/python/PythonRDD.scala
@ -138,6 +138,7 @@ private class PairwiseRDD(prev: RDD[Array[Byte]]) extends
      case Seq(a, b) => (a, b)
      case x          => throw new Exception("PairwiseRDD: unexpected value: " + x)
    }
+  override def checkpoint() { }
  val asJavaPairRDD : JavaPairRDD[Array[Byte], Array[Byte]] = JavaPairRDD.fromRDD(this)
 }