Searched refs:_reserialize (Results 1 – 7 of 7) sorted by relevance
300 rdds[i] = rdds[i]._reserialize()325 default = default._reserialize(rdds[0]._jrdd_deserializer)
600 initialRDD = initialRDD._reserialize(self._jrdd_deserializer)
189 return self._reserialize(AutoBatchedSerializer(PickleSerializer()))558 self_copy = self._reserialize()559 other_copy = other._reserialize()584 def _reserialize(self, serializer=None): member in RDD1501 self._reserialize(ser)._jrdd.saveAsObjectFile(path)2073 selfCopy = self._reserialize(ser)2100 return rdd._reserialize(BatchedSerializer(PickleSerializer(), batchSize))
763 rdds = [x._reserialize() for x in rdds]
808 a = a._reserialize(BatchedSerializer(PickleSerializer(), 2))809 b = b._reserialize(MarshalSerializer())
66 rdd = rdd._reserialize(AutoBatchedSerializer(PickleSerializer()))
68 rdd = rdd._reserialize(AutoBatchedSerializer(PickleSerializer()))