From a3fbc505b2548fe8b44ed1faf15b6488946966e2 Mon Sep 17 00:00:00 2001
From: etiennebacher <etienne.bacher@protonmail.com>
Date: Mon, 10 Jun 2024 21:25:14 +0100
Subject: [PATCH] init

---
 R/dataframe__frame.R | 5 +++++
 R/io_csv.R           | 1 +
 R/io_ipc.R           | 1 +
 R/io_parquet.R       | 1 +
 R/lazyframe__lazy.R  | 4 ++++
 5 files changed, 12 insertions(+)

diff --git a/R/dataframe__frame.R b/R/dataframe__frame.R
index 819a47efe..c0dbd335e 100644
--- a/R/dataframe__frame.R
+++ b/R/dataframe__frame.R
@@ -1961,6 +1961,7 @@ DataFrame_write_csv = function(
     float_precision = NULL,
     null_values = "",
     quote_style = "necessary") {
+  file = path.expand(file)
   .pr$DataFrame$write_csv(
     self,
     file, include_bom, include_header, separator, line_terminator, quote,
@@ -1998,6 +1999,7 @@ DataFrame_write_ipc = function(
     compression = c("uncompressed", "zstd", "lz4"),
     ...,
     future = FALSE) {
+  file = path.expand(file)
   if (isTRUE(future)) {
     warning("The `future` parameter of `$write_ipc()` is considered unstable.")
   }
@@ -2034,6 +2036,7 @@ DataFrame_write_parquet = function(
     statistics = FALSE,
     row_group_size = NULL,
     data_pagesize_limit = NULL) {
+  file = path.expand(file)
   .pr$DataFrame$write_parquet(
     self,
     file,
@@ -2073,6 +2076,7 @@ DataFrame_write_json = function(
     ...,
     pretty = FALSE,
     row_oriented = FALSE) {
+  file = path.expand(file)
   .pr$DataFrame$write_json(self, file, pretty, row_oriented) |>
     unwrap("in $write_json():")
 
@@ -2094,6 +2098,7 @@ DataFrame_write_json = function(
 #'
 #' pl$read_ndjson(destination)
 DataFrame_write_ndjson = function(file) {
+  file = path.expand(file)
   .pr$DataFrame$write_ndjson(self, file) |>
     unwrap("in $write_ndjson():")
 
diff --git a/R/io_csv.R b/R/io_csv.R
index fc70b3397..536bb5d36 100644
--- a/R/io_csv.R
+++ b/R/io_csv.R
@@ -195,6 +195,7 @@ check_is_link = function(path, reuse_downloaded, raise_error = FALSE) {
   if (is.na(path)) {
     return(NULL)
   }
+  path = path.expand(path)
   if (!file.exists(path)) {
     con = NULL
 
diff --git a/R/io_ipc.R b/R/io_ipc.R
index 7c53832e0..fd4cc590a 100644
--- a/R/io_ipc.R
+++ b/R/io_ipc.R
@@ -37,6 +37,7 @@ pl_scan_ipc = function(
     row_index_offset = 0L,
     rechunk = FALSE,
     cache = TRUE) {
+  source = path.expand(source)
   import_arrow_ipc(
     source,
     n_rows,
diff --git a/R/io_parquet.R b/R/io_parquet.R
index ba7836d71..fa864e660 100644
--- a/R/io_parquet.R
+++ b/R/io_parquet.R
@@ -72,6 +72,7 @@ pl_scan_parquet = function(
     storage_options = NULL,
     use_statistics = TRUE,
     cache = TRUE) {
+  source = path.expand(source)
   new_from_parquet(
     path = source,
     n_rows = n_rows,
diff --git a/R/lazyframe__lazy.R b/R/lazyframe__lazy.R
index 4a5cf474b..43ba664e5 100644
--- a/R/lazyframe__lazy.R
+++ b/R/lazyframe__lazy.R
@@ -672,6 +672,7 @@ LazyFrame_sink_parquet = function(
     slice_pushdown = TRUE,
     no_optimization = FALSE,
     inherit_optimization = FALSE) {
+  path = path.expand(path)
   if (isTRUE(no_optimization)) {
     predicate_pushdown = FALSE
     projection_pushdown = FALSE
@@ -750,6 +751,7 @@ LazyFrame_sink_ipc = function(
     slice_pushdown = TRUE,
     no_optimization = FALSE,
     inherit_optimization = FALSE) {
+  path = path.expand(path)
   if (isTRUE(no_optimization)) {
     predicate_pushdown = FALSE
     projection_pushdown = FALSE
@@ -832,6 +834,7 @@ LazyFrame_sink_csv = function(
     slice_pushdown = TRUE,
     no_optimization = FALSE,
     inherit_optimization = FALSE) {
+  path = path.expand(path)
   if (isTRUE(no_optimization)) {
     predicate_pushdown = FALSE
     projection_pushdown = FALSE
@@ -909,6 +912,7 @@ LazyFrame_sink_ndjson = function(
     slice_pushdown = TRUE,
     no_optimization = FALSE,
     inherit_optimization = FALSE) {
+  path = path.expand(path)
   if (isTRUE(no_optimization)) {
     predicate_pushdown = FALSE
     projection_pushdown = FALSE