awesome row objects

witgo · Apr 15, 2014 · 725c91e · 725c91e
1 parent 55d1c76
commit 725c91e
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/python/pyspark/rdd.py b/python/pyspark/rdd.py
@@ -1387,10 +1387,12 @@ def _jrdd(self):
     def _is_pipelinable(self):
         return not (self.is_cached or self.is_checkpointed)
 
-class Row:
+class Row(dict):
 
     def __init__(self, d):
-        self.__dict__ = dict(self.__dict__.items() + d.items())
+        d.update(self.__dict__)
+        self.__dict__ = d
+        dict.__init__(self, d)
 
 class SchemaRDD: