From a2fa0b7aa46d3cdd7672a2a960c595046c911069 Mon Sep 17 00:00:00 2001 From: Shixiong Zhu Date: Mon, 12 Jun 2017 11:57:25 -0700 Subject: [PATCH] Fix comments --- .../spark/sql/execution/streaming/RateSourceProvider.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/RateSourceProvider.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/RateSourceProvider.scala index 7093cabdc2ebc..1550de5c87b1f 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/RateSourceProvider.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/RateSourceProvider.scala @@ -38,12 +38,12 @@ import org.apache.spark.util.{ManualClock, SystemClock} * with 0L. * * This source supports the following options: - * - `rowsPerSecond` (e.g. 100, default: 1): How many tuples should be generated per second. + * - `rowsPerSecond` (e.g. 100, default: 1): How many rows should be generated per second. * - `rampUpTime` (e.g. 5s, default: 0s): How long to ramp up before the generating speed * becomes `rowsPerSecond`. Using finer granularities than seconds will be truncated to integer * seconds. * - `numPartitions` (e.g. 10, default: Spark's default parallelism): The partition number for the - * generated tuples. The source will try its best to reach `rowsPerSecond`, but the query may + * generated rows. The source will try its best to reach `rowsPerSecond`, but the query may * be resource constrained, and `numPartitions` can be tweaked to help reach the desired speed. */ class RateSourceProvider extends StreamSourceProvider with DataSourceRegister {