Struct datafusion::datasource::file_format::csv::CsvSink
source · pub struct CsvSink { /* private fields */ }
Expand description
Implements DataSink
for writing to a CSV file.
Implementations§
source§impl CsvSink
impl CsvSink
sourcepub fn new(config: FileSinkConfig, writer_options: CsvWriterOptions) -> Self
pub fn new(config: FileSinkConfig, writer_options: CsvWriterOptions) -> Self
Create from config.
sourcepub fn config(&self) -> &FileSinkConfig
pub fn config(&self) -> &FileSinkConfig
Retrieve the inner FileSinkConfig
.
sourcepub fn writer_options(&self) -> &CsvWriterOptions
pub fn writer_options(&self) -> &CsvWriterOptions
Retrieve the writer options
Trait Implementations§
source§impl DataSink for CsvSink
impl DataSink for CsvSink
source§fn as_any(&self) -> &dyn Any
fn as_any(&self) -> &dyn Any
Returns the data sink as
Any
so that it can be
downcast to a specific implementation.source§fn metrics(&self) -> Option<MetricsSet>
fn metrics(&self) -> Option<MetricsSet>
source§fn write_all<'life0, 'life1, 'async_trait>(
&'life0 self,
data: SendableRecordBatchStream,
context: &'life1 Arc<TaskContext>,
) -> Pin<Box<dyn Future<Output = Result<u64>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn write_all<'life0, 'life1, 'async_trait>(
&'life0 self,
data: SendableRecordBatchStream,
context: &'life1 Arc<TaskContext>,
) -> Pin<Box<dyn Future<Output = Result<u64>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Writes the data to the sink, returns the number of values written Read more
Auto Trait Implementations§
impl Freeze for CsvSink
impl !RefUnwindSafe for CsvSink
impl Send for CsvSink
impl Sync for CsvSink
impl Unpin for CsvSink
impl !UnwindSafe for CsvSink
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
source§impl<T> IntoEither for T
impl<T> IntoEither for T
source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self
into a Left
variant of Either<Self, Self>
if into_left
is true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moresource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self
into a Left
variant of Either<Self, Self>
if into_left(&self)
returns true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read more