feldera_types/format/
csv.rs

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
use serde::{Deserialize, Serialize};
use utoipa::ToSchema;

#[derive(Deserialize, Serialize, ToSchema)]
pub struct CsvParserConfig {}

const fn default_buffer_size_records() -> usize {
    10_000
}

#[derive(Deserialize, Serialize, ToSchema)]
pub struct CsvEncoderConfig {
    #[serde(default = "default_buffer_size_records")]
    pub buffer_size_records: usize,
}