robin-sparkless-core 4.4.0

Shared types, config, and error for robin-sparkless (no Polars).
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13

//! Engine-agnostic DataFrameReader backend trait.

use crate::engine::DataFrameBackend;
use crate::error::EngineError;
use std::path::Path;

/// Backend for reading files into a DataFrame.
pub trait DataFrameReaderBackend: Send + Sync {
    fn csv(&self, path: &Path) -> Result<Box<dyn DataFrameBackend>, EngineError>;
    fn parquet(&self, path: &Path) -> Result<Box<dyn DataFrameBackend>, EngineError>;
    fn json(&self, path: &Path) -> Result<Box<dyn DataFrameBackend>, EngineError>;
    fn table(&self, name: &str) -> Result<Box<dyn DataFrameBackend>, EngineError>;
}