feldera-types 0.287.0

Public API types for Feldera
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

use serde::{Deserialize, Serialize};
use utoipa::ToSchema;

/// Configuration for the parquet parser.
#[derive(Deserialize, Serialize, ToSchema)]
pub struct ParquetParserConfig {}

#[derive(Deserialize, Serialize, ToSchema)]
#[serde(default)]
pub struct ParquetEncoderConfig {
    /// Number of records before a new parquet file is written.
    ///
    /// The default is 100_000.
    pub buffer_size_records: usize,
}

impl Default for ParquetEncoderConfig {
    fn default() -> Self {
        Self {
            buffer_size_records: 100_000,
        }
    }
}