pub struct CsvOptions {Show 16 fields
pub has_header: Option<bool>,
pub delimiter: u8,
pub quote: u8,
pub terminator: Option<u8>,
pub escape: Option<u8>,
pub double_quote: Option<bool>,
pub newlines_in_values: Option<bool>,
pub compression: CompressionTypeVariant,
pub schema_infer_max_rec: usize,
pub date_format: Option<String>,
pub datetime_format: Option<String>,
pub timestamp_format: Option<String>,
pub timestamp_tz_format: Option<String>,
pub time_format: Option<String>,
pub null_value: Option<String>,
pub comment: Option<u8>,
}
Expand description
Options controlling CSV format
Fields§
§has_header: Option<bool>
Specifies whether there is a CSV header (i.e. the first line
consists of is column names). The value None
indicates that
the configuration should be consulted.
delimiter: u8
§quote: u8
§terminator: Option<u8>
§escape: Option<u8>
§double_quote: Option<bool>
§newlines_in_values: Option<bool>
Specifies whether newlines in (quoted) values are supported.
Parsing newlines in quoted values may be affected by execution behaviour such as
parallel file scanning. Setting this to true
ensures that newlines in values are
parsed successfully, which may reduce performance.
The default behaviour depends on the datafusion.catalog.newlines_in_values
setting.
compression: CompressionTypeVariant
§schema_infer_max_rec: usize
§date_format: Option<String>
§datetime_format: Option<String>
§timestamp_format: Option<String>
§timestamp_tz_format: Option<String>
§time_format: Option<String>
§null_value: Option<String>
§comment: Option<u8>
Implementations§
Source§impl CsvOptions
impl CsvOptions
Sourcepub fn with_compression(
self,
compression_type_variant: CompressionTypeVariant,
) -> Self
pub fn with_compression( self, compression_type_variant: CompressionTypeVariant, ) -> Self
Set a limit in terms of records to scan to infer the schema
- default to
DEFAULT_SCHEMA_INFER_MAX_RECORD
Sourcepub fn with_schema_infer_max_rec(self, max_rec: usize) -> Self
pub fn with_schema_infer_max_rec(self, max_rec: usize) -> Self
Set a limit in terms of records to scan to infer the schema
- default to
DEFAULT_SCHEMA_INFER_MAX_RECORD
Sourcepub fn with_has_header(self, has_header: bool) -> Self
pub fn with_has_header(self, has_header: bool) -> Self
Set true to indicate that the first line is a header.
- default to true
Sourcepub fn has_header(&self) -> Option<bool>
pub fn has_header(&self) -> Option<bool>
Returns true if the first line is a header. If format options does not
specify whether there is a header, returns None
(indicating that the
configuration should be consulted).
Sourcepub fn with_delimiter(self, delimiter: u8) -> Self
pub fn with_delimiter(self, delimiter: u8) -> Self
The character separating values within a row.
- default to ‘,’
Sourcepub fn with_quote(self, quote: u8) -> Self
pub fn with_quote(self, quote: u8) -> Self
The quote character in a row.
- default to ‘“’
Sourcepub fn with_terminator(self, terminator: Option<u8>) -> Self
pub fn with_terminator(self, terminator: Option<u8>) -> Self
The character that terminates a row.
- default to None (CRLF)
Sourcepub fn with_escape(self, escape: Option<u8>) -> Self
pub fn with_escape(self, escape: Option<u8>) -> Self
The escape character in a row.
- default is None
Sourcepub fn with_double_quote(self, double_quote: bool) -> Self
pub fn with_double_quote(self, double_quote: bool) -> Self
Set true to indicate that the CSV quotes should be doubled.
- default to true
Sourcepub fn with_newlines_in_values(self, newlines_in_values: bool) -> Self
pub fn with_newlines_in_values(self, newlines_in_values: bool) -> Self
Specifies whether newlines in (quoted) values are supported.
Parsing newlines in quoted values may be affected by execution behaviour such as
parallel file scanning. Setting this to true
ensures that newlines in values are
parsed successfully, which may reduce performance.
The default behaviour depends on the datafusion.catalog.newlines_in_values
setting.
Sourcepub fn with_file_compression_type(
self,
compression: CompressionTypeVariant,
) -> Self
pub fn with_file_compression_type( self, compression: CompressionTypeVariant, ) -> Self
Set a CompressionTypeVariant
of CSV
- defaults to
CompressionTypeVariant::UNCOMPRESSED
Sourcepub fn terminator(&self) -> Option<u8>
pub fn terminator(&self) -> Option<u8>
The terminator character.
Trait Implementations§
Source§impl Clone for CsvOptions
impl Clone for CsvOptions
Source§fn clone(&self) -> CsvOptions
fn clone(&self) -> CsvOptions
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moreSource§impl ConfigField for CsvOptions
impl ConfigField for CsvOptions
Source§impl Debug for CsvOptions
impl Debug for CsvOptions
Source§impl Default for CsvOptions
impl Default for CsvOptions
Source§impl PartialEq for CsvOptions
impl PartialEq for CsvOptions
Source§impl TryFrom<&CsvOptions> for CsvWriterOptions
impl TryFrom<&CsvOptions> for CsvWriterOptions
Source§type Error = DataFusionError
type Error = DataFusionError
Source§fn try_from(value: &CsvOptions) -> Result<Self>
fn try_from(value: &CsvOptions) -> Result<Self>
impl StructuralPartialEq for CsvOptions
Auto Trait Implementations§
impl Freeze for CsvOptions
impl RefUnwindSafe for CsvOptions
impl Send for CsvOptions
impl Sync for CsvOptions
impl Unpin for CsvOptions
impl UnwindSafe for CsvOptions
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
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§unsafe fn clone_to_uninit(&self, dst: *mut T)
unsafe fn clone_to_uninit(&self, dst: *mut T)
clone_to_uninit
)