Struct CsvSource 

pub struct CsvSource { /* private fields */ }

A CSV file data source with schema inference and compression support.

Examples

use term_guard::sources::{CsvSource, CsvOptions};

// Simple CSV file
let source = CsvSource::new("data/users.csv")?;

// CSV with custom options
let options = CsvOptions {
    delimiter: b'\t',
    has_header: false,
    ..Default::default()
};
let source = CsvSource::with_options("data/users.tsv", options)?;

// Multiple files with glob pattern
let source = CsvSource::from_glob("data/*.csv")?;

Implementations

impl CsvSource

pub fn new(path: impl Into<String>) -> Result<Self>

Creates a new CSV source from a single file path.

pub fn with_options( path: impl Into<String>, options: CsvOptions, ) -> Result<Self>

Creates a new CSV source with custom options.

pub fn from_paths(paths: Vec<String>) -> Result<Self>

Creates a CSV source from multiple file paths.

pub async fn from_glob(pattern: impl Into<String>) -> Result<Self>

Creates a CSV source from a glob pattern.

pub async fn from_globs(patterns: Vec<String>) -> Result<Self>

Creates a CSV source from multiple glob patterns.

pub fn with_custom_options(self, options: CsvOptions) -> Self

Sets custom options for this CSV source.

Trait Implementations

impl Clone for CsvSource

fn clone(&self) -> CsvSource

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl DataSource for CsvSource

fn register_with_telemetry<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, ctx: &'life1 SessionContext, table_name: &'life2 str, telemetry: Option<&'life3 Arc<TermTelemetry>>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Registers this data source with telemetry support.

fn schema(&self) -> Option<&Arc<Schema>>

Returns the schema of this data source if known.

fn description(&self) -> String

Returns a human-readable description of this data source.

fn register<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, ctx: &'life1 SessionContext, table_name: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Registers this data source with the given session context.

impl Debug for CsvSource

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.