diff --git a/python/pyspark/sql/streaming.py b/python/pyspark/sql/streaming.py index b7e54d0e6135f..43d771337eb0f 100644 --- a/python/pyspark/sql/streaming.py +++ b/python/pyspark/sql/streaming.py @@ -272,7 +272,7 @@ def timestamp(self): @since(2.1) def inputRate(self): """ - Current rate (rows/sec) at which data is being generated by all the sources. + Current total rate (rows/sec) at which data is being generated by all the sources. >>> sqs.inputRate 15.5