Skip to content

Commit b851136

Browse files
1 parent b099d39 commit b851136

File tree

1 file changed

+6
-2
lines changed

1 file changed

+6
-2
lines changed

src/dataframe.rs

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -409,7 +409,9 @@ impl PyDataFrame {
409409

410410
#[pyo3(signature = (column, preserve_nulls=true))]
411411
fn unnest_column(&self, column: &str, preserve_nulls: bool) -> PyResult<Self> {
412-
let unnest_options = UnnestOptions { preserve_nulls };
412+
// TODO: expose RecursionUnnestOptions
413+
// REF: https://github.com/apache/datafusion/pull/11577
414+
let unnest_options = UnnestOptions::default().with_preserve_nulls(preserve_nulls);
413415
let df = self
414416
.df
415417
.as_ref()
@@ -420,7 +422,9 @@ impl PyDataFrame {
420422

421423
#[pyo3(signature = (columns, preserve_nulls=true))]
422424
fn unnest_columns(&self, columns: Vec<String>, preserve_nulls: bool) -> PyResult<Self> {
423-
let unnest_options = UnnestOptions { preserve_nulls };
425+
// TODO: expose RecursionUnnestOptions
426+
// REF: https://github.com/apache/datafusion/pull/11577
427+
let unnest_options = UnnestOptions::default().with_preserve_nulls(preserve_nulls);
424428
let cols = columns.iter().map(|s| s.as_ref()).collect::<Vec<&str>>();
425429
let df = self
426430
.df

0 commit comments

Comments
 (0)