1 files changed, 0 insertions, 101 deletions
diff --git a/tests/dataframe/unit/test_session.py b/tests/dataframe/unit/test_session.py
deleted file mode 100644
index 848c603..0000000
--- a/tests/dataframe/unit/test_session.py
+++ /dev/null
@@ -1,101 +0,0 @@
-import sqlglot
-from sqlglot.dataframe.sql import functions as F, types
-from sqlglot.dataframe.sql.session import SparkSession
-from tests.dataframe.unit.dataframe_sql_validator import DataFrameSQLValidator
-
-
-class TestDataframeSession(DataFrameSQLValidator):
-    def test_cdf_one_row(self):
-        df = self.spark.createDataFrame([[1, 2]], ["cola", "colb"])
-        expected = "SELECT `a2`.`cola` AS `cola`, `a2`.`colb` AS `colb` FROM VALUES (1, 2) AS `a2`(`cola`, `colb`)"
-        self.compare_sql(df, expected)
-
-    def test_cdf_multiple_rows(self):
-        df = self.spark.createDataFrame([[1, 2], [3, 4], [None, 6]], ["cola", "colb"])
-        expected = "SELECT `a2`.`cola` AS `cola`, `a2`.`colb` AS `colb` FROM VALUES (1, 2), (3, 4), (NULL, 6) AS `a2`(`cola`, `colb`)"
-        self.compare_sql(df, expected)
-
-    def test_cdf_no_schema(self):
-        df = self.spark.createDataFrame([[1, 2], [3, 4], [None, 6]])
-        expected = "SELECT `a2`.`_1` AS `_1`, `a2`.`_2` AS `_2` FROM VALUES (1, 2), (3, 4), (NULL, 6) AS `a2`(`_1`, `_2`)"
-        self.compare_sql(df, expected)
-
-    def test_cdf_row_mixed_primitives(self):
-        df = self.spark.createDataFrame([[1, 10.1, "test", False, None]])
-        expected = "SELECT `a2`.`_1` AS `_1`, `a2`.`_2` AS `_2`, `a2`.`_3` AS `_3`, `a2`.`_4` AS `_4`, `a2`.`_5` AS `_5` FROM VALUES (1, 10.1, 'test', FALSE, NULL) AS `a2`(`_1`, `_2`, `_3`, `_4`, `_5`)"
-        self.compare_sql(df, expected)
-
-    def test_cdf_dict_rows(self):
-        df = self.spark.createDataFrame([{"cola": 1, "colb": "test"}, {"cola": 2, "colb": "test2"}])
-        expected = "SELECT `a2`.`cola` AS `cola`, `a2`.`colb` AS `colb` FROM VALUES (1, 'test'), (2, 'test2') AS `a2`(`cola`, `colb`)"
-        self.compare_sql(df, expected)
-
-    def test_cdf_str_schema(self):
-        df = self.spark.createDataFrame([[1, "test"]], "cola: INT, colb: STRING")
-        expected = "SELECT `a2`.`cola` AS `cola`, CAST(`a2`.`colb` AS STRING) AS `colb` FROM VALUES (1, 'test') AS `a2`(`cola`, `colb`)"
-        self.compare_sql(df, expected)
-
-    def test_typed_schema_basic(self):
-        schema = types.StructType(
-            [
-                types.StructField("cola", types.IntegerType()),
-                types.StructField("colb", types.StringType()),
-            ]
-        )
-        df = self.spark.createDataFrame([[1, "test"]], schema)
-        expected = "SELECT `a2`.`cola` AS `cola`, CAST(`a2`.`colb` AS STRING) AS `colb` FROM VALUES (1, 'test') AS `a2`(`cola`, `colb`)"
-        self.compare_sql(df, expected)
-
-    def test_typed_schema_nested(self):
-        schema = types.StructType(
-            [
-                types.StructField(
-                    "cola",
-                    types.StructType(
-                        [
-                            types.StructField("sub_cola", types.IntegerType()),
-                            types.StructField("sub_colb", types.StringType()),
-                        ]
-                    ),
-                )
-            ]
-        )
-        df = self.spark.createDataFrame([[{"sub_cola": 1, "sub_colb": "test"}]], schema)
-        expected = "SELECT `a2`.`cola` AS `cola` FROM VALUES (STRUCT(1 AS `sub_cola`, 'test' AS `sub_colb`)) AS `a2`(`cola`)"
-
-        self.compare_sql(df, expected)
-
-    def test_sql_select_only(self):
-        query = "SELECT cola, colb FROM table"
-        sqlglot.schema.add_table("table", {"cola": "string", "colb": "string"}, dialect="spark")
-        df = self.spark.sql(query)
-        self.assertEqual(
-            "SELECT `table`.`cola` AS `cola`, `table`.`colb` AS `colb` FROM `table` AS `table`",
-            df.sql(pretty=False)[0],
-        )
-
-    def test_sql_with_aggs(self):
-        query = "SELECT cola, colb FROM table"
-        sqlglot.schema.add_table("table", {"cola": "string", "colb": "string"}, dialect="spark")
-        df = self.spark.sql(query).groupBy(F.col("cola")).agg(F.sum("colb"))
-        self.assertEqual(
-            "WITH t26614 AS (SELECT `table`.`cola` AS `cola`, `table`.`colb` AS `colb` FROM `table` AS `table`), t23454 AS (SELECT cola, colb FROM t26614) SELECT cola, SUM(colb) FROM t23454 GROUP BY cola",
-            df.sql(pretty=False, optimize=False)[0],
-        )
-
-    def test_sql_create(self):
-        query = "CREATE TABLE new_table AS WITH t1 AS (SELECT cola, colb FROM table) SELECT cola, colb, FROM t1"
-        sqlglot.schema.add_table("table", {"cola": "string", "colb": "string"}, dialect="spark")
-        df = self.spark.sql(query)
-        expected = "CREATE TABLE `new_table` AS SELECT `table`.`cola` AS `cola`, `table`.`colb` AS `colb` FROM `table` AS `table`"
-        self.compare_sql(df, expected)
-
-    def test_sql_insert(self):
-        query = "WITH t1 AS (SELECT cola, colb FROM table) INSERT INTO new_table SELECT cola, colb FROM t1"
-        sqlglot.schema.add_table("table", {"cola": "string", "colb": "string"}, dialect="spark")
-        df = self.spark.sql(query)
-        expected = "INSERT INTO `new_table` SELECT `table`.`cola` AS `cola`, `table`.`colb` AS `colb` FROM `table` AS `table`"
-        self.compare_sql(df, expected)
-
-    def test_session_create_builder_patterns(self):
-        self.assertEqual(SparkSession.builder.appName("abc").getOrCreate(), SparkSession())