Fix Python style errors.

ptkool · ptkool · commit e0b5cc68297f · 2017-10-29T09:57:56.000-04:00
diff --git a/python/pyspark/sql/functions.py b/python/pyspark/sql/functions.py
@@ -355,6 +355,7 @@ def countDistinct(col, *cols):
     jc = sc._jvm.functions.countDistinct(_to_java_column(col), _to_seq(sc, cols, _to_java_column))
     return Column(jc)
 
+
 def every(col):
     """Aggregate function: returns true if all values in a group are true.
     """
@@ -432,6 +433,7 @@ def grouping_id(*cols):
     jc = sc._jvm.functions.grouping_id(_to_seq(sc, cols, _to_java_column))
     return Column(jc)
 
+
 @since(1.6)
 def input_file_name():
     """Creates a string column for the file name of the current Spark task.
diff --git a/python/pyspark/sql/tests.py b/python/pyspark/sql/tests.py
@@ -2660,7 +2660,9 @@ def test_window_functions_every_any(self):
             ("d", True),
             ("d", None)
         ], ["key", "value"])
-        w = Window.partitionBy("key").orderBy("value").rowsBetween(Window.unboundedPreceding, Window.unboundedFollowing)
+        w = Window \
+            .partitionBy("key").orderBy("value") \
+            .rowsBetween(Window.unboundedPreceding, Window.unboundedFollowing)
         from pyspark.sql import functions as F
         sel = df.select(df.key,
                         df.value,
