From c9fc12429f617e527363494a1322238619d5be2c Mon Sep 17 00:00:00 2001 From: Tathagata Das Date: Fri, 1 Aug 2014 14:40:37 -0700 Subject: [PATCH] Added extra line. --- python/pyspark/streaming/utils.py | 1 + 1 file changed, 1 insertion(+) diff --git a/python/pyspark/streaming/utils.py b/python/pyspark/streaming/utils.py index 84f1dadeba03d..c60ecd1ed607a 100644 --- a/python/pyspark/streaming/utils.py +++ b/python/pyspark/streaming/utils.py @@ -17,6 +17,7 @@ from pyspark.rdd import RDD + class RDDFunction(): def __init__(self, ctx, jrdd_deserializer, func): self.ctx = ctx