repartition(numPartitions)
repartition(numPartitions)
Changes the level of parallelism in this DStream by creating more or fewer partitions.
Last updated
Changes the level of parallelism in this DStream by creating more or fewer partitions.
Last updated