We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 1d84142 commit 583e66dCopy full SHA for 583e66d
2 files changed
python/pyspark/streaming/dstream.py
@@ -216,7 +216,7 @@ def getNumPartitions(self):
216
"""
217
Return the number of partitions in RDD
218
219
- # TODO: remove hardcoding. RDD has NumPartitions. How do we get the number of partition
+ # TODO: remove hard coding. RDD has NumPartitions. How do we get the number of partition
220
# through DStream?
221
return 2
222
python/pyspark/streaming_tests.py python/pyspark/streaming/tests.pypython/pyspark/streaming_tests.py renamed to python/pyspark/streaming/tests.py
0 commit comments