working

witgo · Apr 15, 2014 · 043ca85 · 043ca85
1 parent 5496f9f
commit 043ca85
Showing 1 changed file with 1 addition and 0 deletions.
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():