Skip to content

Commit 6a64c37

Browse files
committed
fixup
1 parent 89c3817 commit 6a64c37

File tree

3 files changed

+3
-3
lines changed

3 files changed

+3
-3
lines changed

python/pyspark/ml/tests/connect/test_connect_function.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@
1919

2020
from pyspark.util import is_remote_only
2121
from pyspark.sql import SparkSession as PySparkSession
22-
from pyspark.sql.dataframe import DataFrame as SDF
22+
from pyspark.sql.classic.dataframe import DataFrame as SDF
2323
from pyspark.ml import functions as SF
2424
from pyspark.testing.sqlutils import SQLTestUtils
2525
from pyspark.testing.connectutils import (

python/pyspark/sql/tests/connect/test_connect_column.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -65,7 +65,7 @@
6565

6666
class SparkConnectColumnTests(SparkConnectSQLTestCase):
6767
def compare_by_show(self, df1, df2, n: int = 20, truncate: int = 20):
68-
from pyspark.sql.dataframe import DataFrame as SDF
68+
from pyspark.sql.classic.dataframe import DataFrame as SDF
6969
from pyspark.sql.connect.dataframe import DataFrame as CDF
7070

7171
assert isinstance(df1, (SDF, CDF))

python/pyspark/sql/tests/connect/test_connect_function.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@
3232
from pyspark.sql.connect.column import Column
3333
from pyspark.sql import functions as SF
3434
from pyspark.sql.window import Window as SW
35-
from pyspark.sql.dataframe import DataFrame as SDF
35+
from pyspark.sql.classic.dataframe import DataFrame as SDF
3636
from pyspark.sql.connect import functions as CF
3737
from pyspark.sql.connect.window import Window as CW
3838
from pyspark.sql.connect.dataframe import DataFrame as CDF

0 commit comments

Comments
 (0)