From 341eae195bdbf22bcef666eb7a39f280194ec026 Mon Sep 17 00:00:00 2001 From: ritchie Date: Sun, 17 Sep 2023 14:24:29 +0200 Subject: [PATCH] more features --- crates/polars-pipe/src/executors/sinks/file_sink.rs | 4 ++-- crates/polars-pipe/src/executors/sinks/mod.rs | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/crates/polars-pipe/src/executors/sinks/file_sink.rs b/crates/polars-pipe/src/executors/sinks/file_sink.rs index 69e3e6c830b3..7452fdf243ff 100644 --- a/crates/polars-pipe/src/executors/sinks/file_sink.rs +++ b/crates/polars-pipe/src/executors/sinks/file_sink.rs @@ -9,7 +9,7 @@ use polars_io::csv::CsvWriter; use polars_io::parquet::ParquetWriter; #[cfg(feature = "ipc")] use polars_io::prelude::IpcWriter; -#[cfg(feature = "ipc")] +#[cfg(any(feature = "ipc", feature = "csv"))] use polars_io::SerWriter; use polars_plan::prelude::*; @@ -212,7 +212,7 @@ impl CsvSink { } } -#[cfg(any(feature = "parquet", feature = "ipc"))] +#[cfg(any(feature = "parquet", feature = "ipc", feature = "csv"))] fn init_writer_thread( receiver: Receiver>, mut writer: Box, diff --git a/crates/polars-pipe/src/executors/sinks/mod.rs b/crates/polars-pipe/src/executors/sinks/mod.rs index 328ab178a9e6..8c9b46366da7 100644 --- a/crates/polars-pipe/src/executors/sinks/mod.rs +++ b/crates/polars-pipe/src/executors/sinks/mod.rs @@ -1,4 +1,4 @@ -#[cfg(any(feature = "parquet", feature = "ipc"))] +#[cfg(any(feature = "parquet", feature = "ipc", feature = "csv"))] mod file_sink; pub(crate) mod group_by; mod io; @@ -10,7 +10,7 @@ mod slice; mod sort; mod utils; -#[cfg(any(feature = "parquet", feature = "ipc"))] +#[cfg(any(feature = "parquet", feature = "ipc", feature = "csv"))] pub(crate) use file_sink::*; pub(crate) use joins::*; pub(crate) use ordered::*;