We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
repartition
1 parent 70c8116 commit 32dfc62Copy full SHA for 32dfc62
docs/streaming-programming-guide.md
@@ -950,7 +950,7 @@ is 200 milliseconds.
950
951
An alternative to receiving data with multiple input streams / receivers is to explicitly repartition
952
the input data stream (using `inputStream.repartition(<number of partitions>)`).
953
-This distributes the received batches of data across all the machines in the cluster
+This distributes the received batches of data across specified number of machines in the cluster
954
before further processing.
955
956
### Level of Parallelism in Data Processing
0 commit comments