code: def saveAsTextFile(self, path, compressionCodecClass=None):
          def func(split, iterator):
              for x in iterator:
                  if not isinstance(x, (unicode, bytes)):
                      x = unicode(x)
                  if isinstance(x, unicode):
                      x = x.encode("utf-8")
                  yield x
          keyed = self.mapPartitionsWithIndex(func)
          keyed._bypass_serializer = True
          if compressionCodecClass:
              compressionCodec = self.ctx._jvm.java.lang.Class.forName(compressionCodecClass)
              keyed._jrdd.map(self.ctx._jvm.BytesToString()).saveAsTextFile(path, compressionCodec)
          else:
              keyed._jrdd.map(self.ctx._jvm.BytesToString()).saveAsTextFile(path)