Skip to content

Commit

Permalink
move tests for streaming inside streaming directory
Browse files Browse the repository at this point in the history
  • Loading branch information
giwa committed Aug 21, 2014
1 parent 1d84142 commit 583e66d
Show file tree
Hide file tree
Showing 2 changed files with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion python/pyspark/streaming/dstream.py
Original file line number Diff line number Diff line change
Expand Up @@ -216,7 +216,7 @@ def getNumPartitions(self):
"""
Return the number of partitions in RDD
"""
# 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
# through DStream?
return 2

Expand Down
File renamed without changes.

0 comments on commit 583e66d

Please sign in to comment.