SPARK-5361, add in test case

tmyklebu · Jan 22, 2015 · 126be6b · 126be6b
1 parent 4cf1187
commit 126be6b
Showing 1 changed file with 7 additions and 7 deletions.
diff --git a/python/pyspark/tests.py b/python/pyspark/tests.py
@@ -1125,19 +1125,19 @@ def test_oldhadoop(self):
 
     def test_newhadoop(self):
         basepath = self.tempdir.name
-        ints = sorted(self.sc.newAPIHadoopFile(\
-            basepath + "/sftestdata/sfint/",\
-            "org.apache.hadoop.mapreduce.lib.input.SequenceFileInputFormat",\
-            "org.apache.hadoop.io.IntWritable",\
+        ints = sorted(self.sc.newAPIHadoopFile(
+            basepath + "/sftestdata/sfint/",
+            "org.apache.hadoop.mapreduce.lib.input.SequenceFileInputFormat",
+            "org.apache.hadoop.io.IntWritable",
             "org.apache.hadoop.io.Text").collect())
         ei = [(1, u'aa'), (1, u'aa'), (2, u'aa'), (2, u'bb'), (2, u'bb'), (3, u'cc')]
         self.assertEqual(ints, ei)
 
         hellopath = os.path.join(SPARK_HOME, "python/test_support/hello.txt")
         newconf = {"mapred.input.dir": hellopath}
-        hello = self.sc.newAPIHadoopRDD("org.apache.hadoop.mapreduce.lib.input.TextInputFormat",\
-                                        "org.apache.hadoop.io.LongWritable",\
-                                        "org.apache.hadoop.io.Text",\
+        hello = self.sc.newAPIHadoopRDD("org.apache.hadoop.mapreduce.lib.input.TextInputFormat",
+                                        "org.apache.hadoop.io.LongWritable",
+                                        "org.apache.hadoop.io.Text",
                                         conf=newconf).collect()
         result = [(0, u'Hello World!')]
         self.assertEqual(hello, result)