feldera-types: avro: set default workers to 4

abhizer · abhizer · commit d0103ac9248f · 2026-02-09T20:28:51.000Z
Signed-off-by: Abhinav Gyawali &lt;22275402+abhizer@users.noreply.github.com&gt;
diff --git a/crates/adapters/benches/avro_encoder.rs b/crates/adapters/benches/avro_encoder.rs
@@ -207,7 +207,9 @@ fn build_indexed_batch(data: &[BenchTestStruct]) -> Arc<dyn SerBatch> {
         .map(|v| Tup2(Tup2(BenchKeyStruct { id: v.id }, v.clone()), 1i64))
         .collect();
     let zset = OrdIndexedZSet::from_tuples((), tuples);
-    Arc::new(<SerBatchImpl<_, BenchKeyStruct, BenchTestStruct>>::new(zset))
+    Arc::new(<SerBatchImpl<_, BenchKeyStruct, BenchTestStruct>>::new(
+        zset,
+    ))
 }
 
 fn build_plain_batch(data: &[BenchTestStruct]) -> Arc<dyn SerBatch> {
@@ -276,9 +278,7 @@ fn bench_indexed_encode(c: &mut Criterion) {
                 let mut encoder = create_indexed_encoder(workers);
                 b.iter(|| {
                     encoder.consumer().batch_start(0);
-                    encoder
-                        .encode(batch.clone().arc_as_batch_reader())
-                        .unwrap();
+                    encoder.encode(batch.clone().arc_as_batch_reader()).unwrap();
                     encoder.consumer().batch_end();
                 });
             },
@@ -305,9 +305,7 @@ fn bench_indexed_encode_scaling(c: &mut Criterion) {
                     let mut encoder = create_indexed_encoder(workers);
                     b.iter(|| {
                         encoder.consumer().batch_start(0);
-                        encoder
-                            .encode(batch.clone().arc_as_batch_reader())
-                            .unwrap();
+                        encoder.encode(batch.clone().arc_as_batch_reader()).unwrap();
                         encoder.consumer().batch_end();
                     });
                 },
@@ -318,9 +316,5 @@ fn bench_indexed_encode_scaling(c: &mut Criterion) {
     group.finish();
 }
 
-criterion_group!(
-    benches,
-    bench_indexed_encode,
-    bench_indexed_encode_scaling,
-);
+criterion_group!(benches, bench_indexed_encode, bench_indexed_encode_scaling,);
 criterion_main!(benches);
diff --git a/crates/adapters/src/format/avro/serializer.rs b/crates/adapters/src/format/avro/serializer.rs
@@ -443,7 +443,7 @@ where
 ///
 /// Assumes that the `Serialize` implementation driving this serializer is generated by
 /// the [`serialize_table_record`](feldera_types::serialize_table_record) macro and configured
-/// using [`avro_serde_config`].
+/// using [`avro_ser_config`].
 ///
 /// Performs the following transformations on data:
 /// - Converts input timestamps and times in microseconds to microseconds or millisecond,
diff --git a/crates/feldera-types/src/format/avro.rs b/crates/feldera-types/src/format/avro.rs
@@ -254,7 +254,7 @@ pub struct AvroEncoderConfig {
     ///
     /// Avro encoder supports encoding multiple records in parallel. This configuration specifies
     /// the number of workers to run in parallel.
-    /// Default: 1
+    /// Default: 4
     #[serde(default = "default_encoder_workers")]
     pub workers: usize,
 }
@@ -276,5 +276,5 @@ impl Default for AvroEncoderConfig {
 }
 
 fn default_encoder_workers() -> usize {
-    8
+    4
 }

Original file line number	Diff line number	Diff line change
`@@ -254,7 +254,7 @@ pub struct AvroEncoderConfig {`
`254`	`254`	`///`
`255`	`255`	`/// Avro encoder supports encoding multiple records in parallel. This configuration specifies`
`256`	`256`	`/// the number of workers to run in parallel.`
`257`		`- /// Default: 1`
	`257`	`+ /// Default: 4`
`258`	`258`	`#[serde(default = "default_encoder_workers")]`
`259`	`259`	`pub workers: usize,`
`260`	`260`	`}`
`@@ -276,5 +276,5 @@ impl Default for AvroEncoderConfig {`
`276`	`276`	`}`
`277`	`277`
`278`	`278`	`fn default_encoder_workers() -> usize {`
`279`		`- 8`
	`279`	`+ 4`
`280`	`280`	`}`