Skip to content

Commit b5b3c47

Browse files
committed
fix: remove unused import and update default compression to ZSTD in rs' write_parquet method
1 parent f62a7a8 commit b5b3c47

File tree

2 files changed

+1
-2
lines changed

2 files changed

+1
-2
lines changed

python/datafusion/dataframe.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,6 @@
3636
from datafusion._internal import DataFrame as DataFrameInternal
3737
from datafusion.expr import Expr, SortExpr, sort_or_default
3838
from enum import Enum
39-
from typing import Tuple
4039

4140

4241
class Compression(Enum):

src/dataframe.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -463,7 +463,7 @@ impl PyDataFrame {
463463
/// Write a `DataFrame` to a Parquet file.
464464
#[pyo3(signature = (
465465
path,
466-
compression="uncompressed",
466+
compression="zstd",
467467
compression_level=None
468468
))]
469469
fn write_parquet(

0 commit comments

Comments
 (0)