Skip to content
Closed
Show file tree
Hide file tree
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
further style fixes
  • Loading branch information
benjaminp committed Mar 2, 2018
commit 4dac3a7e2fe3fd058b4c771039da02e2565108a1
3 changes: 2 additions & 1 deletion python/pyspark/heapq3.py
Original file line number Diff line number Diff line change
Expand Up @@ -883,7 +883,8 @@ def nlargest(n, iterable, key=None):


if __name__ == "__main__":
import doctest, sys
import doctest
import sys
(failure_count, test_count) = doctest.testmod()
if failure_count:
sys.exit(-1)
1 change: 1 addition & 0 deletions python/pyspark/ml/stat.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
#

import sys
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Shall we add a newline below?


from pyspark import since, SparkContext
from pyspark.ml.common import _java2py, _py2java
from pyspark.ml.wrapper import _jvm
Expand Down
3 changes: 2 additions & 1 deletion python/pyspark/ml/tuning.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,9 +16,10 @@
#
import itertools
import sys
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Could we

import itertools
import sys
from multiprocessing.pool import ThreadPool

import numpy as np
...

?

import numpy as np
from multiprocessing.pool import ThreadPool

import numpy as np

from pyspark import since, keyword_only
from pyspark.ml import Estimator, Model
from pyspark.ml.common import _py2java
Expand Down
1 change: 0 additions & 1 deletion python/pyspark/mllib/random.py
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,6 @@
"""

import sys

from functools import wraps

from pyspark import since
Expand Down
3 changes: 2 additions & 1 deletion python/pyspark/mllib/regression.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,9 +16,10 @@
#

import sys
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Let's reoprder this too

import sys
import warings

import numpy as np
...

import warnings

import numpy as np
from numpy import array
import warnings

from pyspark import RDD, since
from pyspark.streaming.dstream import DStream
Expand Down
1 change: 1 addition & 0 deletions python/pyspark/sql/conf.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
#

import sys
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Let's add a newline below


from pyspark import since
from pyspark.rdd import ignore_unicode_prefix

Expand Down