diff --git a/lib/codecs/src/encoding/format/parquet.rs b/lib/codecs/src/encoding/format/parquet.rs index 9b5fdf5f2174b..bf62381865b1c 100644 --- a/lib/codecs/src/encoding/format/parquet.rs +++ b/lib/codecs/src/encoding/format/parquet.rs @@ -299,7 +299,7 @@ impl Encoder> for ParquetSerializer { let mut row_group_writer = parquet_writer.next_row_group()?; while let Some(mut column_writer) = row_group_writer.next_column()? { match column_writer.untyped() { - BoolColumnWriter(ref mut writer) => { + BoolColumnWriter(writer) => { let desc = writer.get_descriptor().clone(); self.process( &events, diff --git a/lib/codecs/src/encoding/serializer.rs b/lib/codecs/src/encoding/serializer.rs index 925bf7a8145b7..d60c3d5e69e62 100644 --- a/lib/codecs/src/encoding/serializer.rs +++ b/lib/codecs/src/encoding/serializer.rs @@ -10,8 +10,9 @@ use super::format::{ CefSerializerConfig, CsvSerializer, CsvSerializerConfig, GelfSerializer, GelfSerializerConfig, JsonSerializer, JsonSerializerConfig, LogfmtSerializer, LogfmtSerializerConfig, NativeJsonSerializer, NativeJsonSerializerConfig, NativeSerializer, NativeSerializerConfig, - ProtobufSerializer, ProtobufSerializerConfig, RawMessageSerializer, RawMessageSerializerConfig, - TextSerializer, TextSerializerConfig, + ParquetSerializer, ParquetSerializerConfig, ParquetSerializerOptions, ProtobufSerializer, + ProtobufSerializerConfig, RawMessageSerializer, RawMessageSerializerConfig, TextSerializer, + TextSerializerConfig, }; #[cfg(feature = "opentelemetry")] use super::format::{OtlpSerializer, OtlpSerializerConfig}; @@ -256,7 +257,7 @@ impl SerializerConfig { ))), SerializerConfig::Avro { .. } | SerializerConfig::Csv(..) - | SerializerConfig::Gelf + | SerializerConfig::Gelf(..) | SerializerConfig::Json(..) | SerializerConfig::Logfmt | SerializerConfig::Native