code: def partitionBy(self, numPartitions, partitionFunc=portable_hash):
          
          return self.transform(lambda rdd: rdd.partitionBy(numPartitions, partitionFunc))
docs: Return a copy of the DStream in which each RDD are partitioned
          using the specified partitioner.