From 583e66dab70e892f8eeaa4ec96c868d0e2cbef20 Mon Sep 17 00:00:00 2001 From: giwa Date: Wed, 20 Aug 2014 17:28:12 -0700 Subject: [PATCH] move tests for streaming inside streaming directory --- python/pyspark/streaming/dstream.py | 2 +- python/pyspark/{streaming_tests.py => streaming/tests.py} | 0 2 files changed, 1 insertion(+), 1 deletion(-) rename python/pyspark/{streaming_tests.py => streaming/tests.py} (100%) diff --git a/python/pyspark/streaming/dstream.py b/python/pyspark/streaming/dstream.py index fc15309679c2a..e1fc95db09eea 100644 --- a/python/pyspark/streaming/dstream.py +++ b/python/pyspark/streaming/dstream.py @@ -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 diff --git a/python/pyspark/streaming_tests.py b/python/pyspark/streaming/tests.py similarity index 100% rename from python/pyspark/streaming_tests.py rename to python/pyspark/streaming/tests.py