diff options
Diffstat (limited to 'sqlglot/dataframe/sql/session.py')
| -rw-r--r-- | sqlglot/dataframe/sql/session.py | 10 |
1 files changed, 4 insertions, 6 deletions
diff --git a/sqlglot/dataframe/sql/session.py b/sqlglot/dataframe/sql/session.py index f518ac2..bfc022b 100644 --- a/sqlglot/dataframe/sql/session.py +++ b/sqlglot/dataframe/sql/session.py @@ -70,12 +70,10 @@ class SparkSession: column_mapping = {f"_{i}": None for i in range(1, len(data[0]) + 1)} data_expressions = [ - exp.Tuple( - expressions=list( - map( - lambda x: F.lit(x).expression, - row if not isinstance(row, dict) else row.values(), - ) + exp.tuple_( + *map( + lambda x: F.lit(x).expression, + row if not isinstance(row, dict) else row.values(), ) ) for row in data |