We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 34234d4 commit d250692Copy full SHA for d250692
python/pyspark/sql.py
@@ -2599,7 +2599,7 @@ def __call__(self, *cols):
2599
sc = SparkContext._active_spark_context
2600
jcols = ListConverter().convert([_to_java_column(c) for c in cols],
2601
sc._gateway._gateway_client)
2602
- jc = self._judf.apply(sc._jvm.Dsl.toColumns(jcols))
+ jc = self._judf.apply(sc._jvm.PythonUtils.toSeq(jcols))
2603
return Column(jc)
2604
2605
0 commit comments