@@ -5,17 +5,17 @@ use std::sync::{Arc, LazyLock};
55use itertools:: Itertools ;
66use url:: Url ;
77
8- use crate :: actions:: { get_all_actions_schema, visitors:: SidecarVisitor , SIDECAR_NAME } ;
9- use crate :: actions:: { get_commit_schema, Sidecar , ADD_NAME } ;
10- use crate :: expressions:: Transform ;
8+ use crate :: actions:: { get_commit_schema, ADD_NAME } ;
9+ use crate :: actions:: { visitors:: SidecarVisitor , SIDECAR_NAME } ;
1110use crate :: log_replay:: ActionsBatch ;
12- use crate :: schema:: { Schema , SchemaRef , StructField , ToSchema } ;
11+ use crate :: schema:: SchemaRef ;
1312use crate :: utils:: require;
14- use crate :: { DeltaResult , Engine , Error , Expression , ExpressionEvaluator , FileMeta , RowVisitor } ;
13+ use crate :: { DeltaResult , Engine , Error , FileMeta , RowVisitor } ;
1514
1615/// Phase that processes single-part checkpoint manifest files.
1716///
1817/// Extracts sidecar references while processing the manifest.
18+ #[ allow( unused) ]
1919pub ( crate ) struct ManifestPhase {
2020 actions : Box < dyn Iterator < Item = DeltaResult < ActionsBatch > > + Send > ,
2121 sidecar_visitor : SidecarVisitor ,
@@ -25,6 +25,7 @@ pub(crate) struct ManifestPhase {
2525}
2626
2727/// Possible transitions after ManifestPhase completes.
28+ #[ allow( unused) ]
2829pub ( crate ) enum AfterManifest {
2930 /// Has sidecars → return sidecar files
3031 Sidecars { sidecars : Vec < FileMeta > } ,
@@ -42,7 +43,8 @@ impl ManifestPhase {
4243 /// - `manifest_file`: The checkpoint manifest file to process
4344 /// - `log_root`: Root URL for resolving sidecar paths
4445 /// - `engine`: Engine for reading files
45- pub fn new (
46+ #[ allow( unused) ]
47+ pub ( crate ) fn new (
4648 manifest_file : FileMeta ,
4749 log_root : Url ,
4850 engine : Arc < dyn Engine > ,
@@ -99,6 +101,7 @@ impl ManifestPhase {
99101 /// Returns an enum indicating what comes next:
100102 /// - `Sidecars`: Extracted sidecar files
101103 /// - `Done`: No sidecars found
104+ #[ allow( unused) ]
102105 pub ( crate ) fn finalize ( self ) -> DeltaResult < AfterManifest > {
103106 require ! (
104107 self . is_complete,
0 commit comments