working

ahirreddy · ahirreddy · commit 043ca85adcf4 · 2014-04-14T17:05:18.000-07:00
diff --git a/python/pyspark/rdd.py b/python/pyspark/rdd.py
@@ -1394,6 +1394,7 @@ def __init__(self, pyRDD):
         self.ctx = pyRDD.ctx
         self.sql_ctx = self.ctx._jvm.JavaSQLContext(self.ctx._jsc)
         self._jrdd = self.ctx._pythonToJava(pyRDD._jrdd)
+        self._srdd = self.sql_ctx.applySchema(self._jrdd)
 
 
 def _test():
