feldera_types/format/
parquet.rs

1use serde::{Deserialize, Serialize};
2use utoipa::ToSchema;
3
4/// Configuration for the parquet parser.
5#[derive(Deserialize, Serialize, ToSchema)]
6pub struct ParquetParserConfig {}
7
8#[derive(Deserialize, Serialize, ToSchema)]
9#[serde(default)]
10pub struct ParquetEncoderConfig {
11    /// Number of records before a new parquet file is written.
12    ///
13    /// The default is 100_000.
14    pub buffer_size_records: usize,
15}
16
17impl Default for ParquetEncoderConfig {
18    fn default() -> Self {
19        Self {
20            buffer_size_records: 100_000,
21        }
22    }
23}