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}