fix warnings

Author: OussamaSaoudi

kernel/src/log_replay.rs

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

kernel/src/scan/log_replay.rs

@@ -12,7 +12,7 @@ use crate::actions::get_log_add_schema;
 use crate::engine_data::{GetData, RowVisitor, TypedGetData as _};
 use crate::expressions::{column_name, ColumnName, Expression, ExpressionRef, PredicateRef};
 use crate::kernel_predicates::{DefaultKernelPredicateEvaluator, KernelPredicateEvaluator as _};
-use crate::log_replay::deduplicator::{self, CheckpointDeduplicator, Deduplicator};
+use crate::log_replay::deduplicator::{CheckpointDeduplicator, Deduplicator};
 use crate::log_replay::{
     ActionsBatch, FileActionDeduplicator, FileActionKey, LogReplayProcessor,
     ParallelizableLogReplayProcessor,
@@ -498,8 +498,8 @@ impl ParallelizableLogReplayProcessor for ScanLogReplayProcessor {
 
         let deduplicator = CheckpointDeduplicator::try_new(
             &self.seen_file_keys,
-            ADD_PATH_INDEX,
-            ADD_DV_START_INDEX,
+            Self::ADD_PATH_INDEX,
+            Self::ADD_DV_START_INDEX,
         )?;
         let mut visitor = AddRemoveDedupVisitor::new(
             deduplicator,