pyspark.streaming.DStream.partitionBy

DStream.partitionBy(numPartitions, partitionFunc=<function portable_hash>)[source]

Return a copy of the DStream in which each RDD are partitioned using the specified partitioner.

previous

pyspark.streaming.DStream.mapValues

next

pyspark.streaming.DStream.persist