swiftide-integrations 0.34.0

Composable LLM agents, typed task graphs, and streaming RAG pipelines in Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30

//! Stream data from parquet files
use std::path::PathBuf;

use derive_builder::Builder;

pub mod loader;

/// Stream data from parquet files on a single column
///
/// Provide a path, column and optional batch size. The column must be of type `StringArray`. Then
/// the column is loaded into the chunks of the Node.
///
/// # Panics
///
/// The loader can panic during initialization if anything with parquet or arrow fails before
/// starting the stream.
#[derive(Debug, Clone, Builder)]
#[builder(setter(into, strip_option))]
pub struct Parquet {
    path: PathBuf,
    column_name: String,
    #[builder(default = "1024")]
    batch_size: usize,
}

impl Parquet {
    pub fn builder() -> ParquetBuilder {
        ParquetBuilder::default()
    }
}