added comment in dstream._test_output

YanTangZhai · Sep 20, 2014 · b0f2015 · b0f2015
1 parent bebb3f3
commit b0f2015
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/python/pyspark/streaming/dstream.py b/python/pyspark/streaming/dstream.py
@@ -397,6 +397,10 @@ def _test_output(self, result):
         Store data in a DStream to result to verify the result in test case
         """
         def get_output(rdd, time):
+            """
+            Closure to get element in RDD in the DStream.
+            This closure is called by py4j callback server.
+            """
             collected = rdd.collect()
             result.append(collected)