Skip to content

Commit

Permalink
refactor: Renames robj_to_cloud_options
Browse files Browse the repository at this point in the history
  • Loading branch information
andyquinterom committed Apr 23, 2024
1 parent 38981e2 commit fa14b7f
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
4 changes: 2 additions & 2 deletions src/rust/src/rdataframe/read_parquet.rs
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
use crate::lazy::dataframe::RPolarsLazyFrame;
use crate::rdatatype::robj_to_cloudoptions;
use crate::rdatatype::robj_to_cloud_options;
use crate::robj_to;
use crate::rpolarserr::{polars_to_rpolars_err, RResult};

Expand All @@ -26,7 +26,7 @@ pub fn new_from_parquet(
//retries: Robj // not supported yet, with CloudOptions
) -> RResult<RPolarsLazyFrame> {
let path = robj_to!(String, path)?;
let cloud_options = robj_to_cloudoptions(&path, &cloud_options)?;
let cloud_options = robj_to_cloud_options(&path, &cloud_options)?;
let offset = robj_to!(Option, u32, row_index)?.unwrap_or(0);
let opt_row_index = robj_to!(Option, String, row_name)?.map(|name| RowIndex { name, offset });
let args = pl::ScanArgsParquet {
Expand Down
2 changes: 1 addition & 1 deletion src/rust/src/rdatatype.rs
Original file line number Diff line number Diff line change
Expand Up @@ -361,7 +361,7 @@ pub fn robj_to_interpolation_method(robj: Robj) -> RResult<pl::InterpolationMeth
}
}

pub fn robj_to_cloudoptions<'a>(
pub fn robj_to_cloud_options<'a>(
url: &'a str,
robj: &'a Robj,
) -> RResult<Option<pl::cloud::CloudOptions>> {
Expand Down

0 comments on commit fa14b7f

Please sign in to comment.