Skip to content

Commit

Permalink
Address comments
Browse files Browse the repository at this point in the history
  • Loading branch information
HyukjinKwon committed Mar 19, 2019
1 parent 7f78cc4 commit ccbe51e
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion python/pyspark/sql/functions.py
Original file line number Diff line number Diff line change
Expand Up @@ -82,7 +82,7 @@ def _create_binary_mathfunction(name, doc=""):
def _(col1, col2):
sc = SparkContext._active_spark_context
# For legacy reasons, the arguments here can be implicitly converted into floats,
# if they are not columns.
# if they are not columns or strings.
if isinstance(col1, Column):
arg1 = col1._jc
elif isinstance(col1, basestring):
Expand Down
2 changes: 1 addition & 1 deletion python/pyspark/sql/tests/test_functions.py
Original file line number Diff line number Diff line change
Expand Up @@ -158,7 +158,7 @@ def test_rand_functions(self):

def test_string_functions(self):
from pyspark.sql import functions
from pyspark.sql.functions import col, lit, upper, _string_functions
from pyspark.sql.functions import col, lit, _string_functions
df = self.spark.createDataFrame([['nick']], schema=['name'])
self.assertRaisesRegexp(
TypeError,
Expand Down

0 comments on commit ccbe51e

Please sign in to comment.