From 327a4db9f7546c58d93e0ccd38a6d131aee98c78 Mon Sep 17 00:00:00 2001
From: "Joseph E. Gonzalez" <joseph.e.gonzalez@gmail.com>
Date: Thu, 15 Aug 2013 16:36:26 -0700
Subject: [PATCH] changing caching behavior on indexedrdds

---
 core/src/main/scala/spark/rdd/IndexedRDD.scala | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/core/src/main/scala/spark/rdd/IndexedRDD.scala b/core/src/main/scala/spark/rdd/IndexedRDD.scala
index 7d8e0d3938..6b1cb7608b 100644
--- a/core/src/main/scala/spark/rdd/IndexedRDD.scala
+++ b/core/src/main/scala/spark/rdd/IndexedRDD.scala
@@ -58,6 +58,12 @@ class IndexedRDD[K: ClassManifest, V: ClassManifest](
   override def getPartitions: Array[Partition] = tuples.getPartitions 
   override def getPreferredLocations(s: Partition): Seq[String] = tuples.getPreferredLocations(s)
 
+  override def cache: IndexedRDD[K,V] = {
+    index.cache
+    valuesRDD.cache
+    return this
+  }
+
 
   /**
    * Construct a new IndexedRDD that is indexed by only the keys in the RDD