relax parallelizable log replay processor

Author: OussamaSaoudi

kernel/src/log_replay.rs

@@ -21,6 +21,7 @@ use crate::{DeltaResult, EngineData};
 use delta_kernel_derive::internal_api;
 
 use std::collections::HashSet;
+use std::sync::Arc;
 
 use tracing::debug;
 
@@ -204,7 +205,8 @@ impl ActionsBatch {
     }
 }
 
-pub(crate) trait ParallelizableLogReplayProcessor: LogReplayProcessor {
+pub(crate) trait ParallelizableLogReplayProcessor {
+    type Output;
     fn process_actions_batch(&self, actions_batch: ActionsBatch) -> DeltaResult<Self::Output>;
 }
 

kernel/src/scan/log_replay.rs

@@ -484,6 +484,7 @@ pub(crate) fn get_scan_metadata_transform_expr() -> ExpressionRef {
 }
 
 impl ParallelizableLogReplayProcessor for ScanLogReplayProcessor {
+    type Output = <ScanLogReplayProcessor as LogReplayProcessor>::Output;
     fn process_actions_batch(&self, actions_batch: ActionsBatch) -> DeltaResult<Self::Output> {
         let ActionsBatch {
             actions,