Skip to content

Commit ad32a7f

Browse files
committed
Update comments
1 parent 479582b commit ad32a7f

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/RateSourceProvider.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,8 @@ import org.apache.spark.util.{ManualClock, SystemClock}
4343
* becomes `tuplesPerSecond`. Using finer granularities than seconds will be truncated to integer
4444
* seconds.
4545
* - `numPartitions` (e.g. 10, default: Spark's default parallelism): The partition number for the
46-
* generated tuples.
46+
* generated tuples. The source will try its best to reach `tuplesPerSecond`, but the query may
47+
* be resource constrained, and `numPartitions` can be tweaked to help reach the desired speed.
4748
*/
4849
class RateSourceProvider extends StreamSourceProvider with DataSourceRegister {
4950

0 commit comments

Comments
 (0)