Skip to content
This repository was archived by the owner on Feb 5, 2025. It is now read-only.

Commit 2f82a0b

Browse files
committed
Fix a missing definition level bug
1 parent 1b5a39b commit 2f82a0b

File tree

1 file changed

+4
-2
lines changed
  • Source/santad/Logs/EndpointSecurity/ParquetLogger

1 file changed

+4
-2
lines changed

Source/santad/Logs/EndpointSecurity/ParquetLogger/cpp_api.rs

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@ use parquet2::{
55
compression::{BrotliLevel, CompressionOptions},
66
error::Error,
77
metadata::SchemaDescriptor,
8-
schema::types::{ParquetType, PhysicalType},
8+
schema::{types::{ParquetType, PhysicalType, PrimitiveType}, Repetition},
99
write::WriteOptions,
1010
};
1111

@@ -92,8 +92,10 @@ fn table_args_add_column(
9292
match cxx_column_type_to_physical_type(column_type) {
9393
None => Err(Error::InvalidParameter("invalid column type".to_string())),
9494
Some(physical_type) => {
95+
let mut field = PrimitiveType::from_physical(name.to_string(), physical_type);
96+
field.field_info.repetition = Repetition::Required;
9597
args.fields
96-
.push(ParquetType::from_physical(name.to_string(), physical_type));
98+
.push(ParquetType::PrimitiveType(field));
9799
Ok(())
98100
}
99101
}

0 commit comments

Comments
 (0)