aboutsummaryrefslogtreecommitdiff
path: root/python/pyspark/streaming
diff options
context:
space:
mode:
authorRolando Espinoza <rndmax84@gmail.com>2017-02-17 15:10:29 +0000
committerSean Owen <sowen@cloudera.com>2017-02-17 15:10:29 +0000
commit9d2d2204cb27dce8c4ede1bd8a6399763a4bd589 (patch)
tree30d307f7c733e9c3afdf45c9aba4d69544130333 /python/pyspark/streaming
parented338f72771f9556a15d9e59599d27ab9f72f58b (diff)
downloadspark-9d2d2204cb27dce8c4ede1bd8a6399763a4bd589.tar.gz
spark-9d2d2204cb27dce8c4ede1bd8a6399763a4bd589.tar.bz2
spark-9d2d2204cb27dce8c4ede1bd8a6399763a4bd589.zip
[MINOR][PYTHON] Fix typo docstring: 'top' -> 'topic'
## What changes were proposed in this pull request? Fix typo in docstring. Author: Rolando Espinoza <rndmax84@gmail.com> Closes #16967 from rolando/pyspark-doc-typo.
Diffstat (limited to 'python/pyspark/streaming')
-rw-r--r--python/pyspark/streaming/kafka.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/python/pyspark/streaming/kafka.py b/python/pyspark/streaming/kafka.py
index 134424add3..9d1a6ecf2c 100644
--- a/python/pyspark/streaming/kafka.py
+++ b/python/pyspark/streaming/kafka.py
@@ -262,7 +262,7 @@ class OffsetRange(object):
class TopicAndPartition(object):
"""
- Represents a specific top and partition for Kafka.
+ Represents a specific topic and partition for Kafka.
"""
def __init__(self, topic, partition):