refactor by cr.

apache · Oct 13, 2022 · c33751a · c33751a
1 parent b1b94df
commit c33751a
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 3 deletions.
diff --git a/analytic_engine/src/instance/open.rs b/analytic_engine/src/instance/open.rs
@@ -224,7 +224,7 @@ impl Instance {
         Ok(table_data)
     }
 
-    /// Apply manifest data to instance
+    /// Recover `TableData` by applying manifest data to instance
     async fn recover_table_data(
         self: &Arc<Self>,
         manifest_data: TableManifestData,

diff --git a/analytic_engine/src/table/data.rs b/analytic_engine/src/table/data.rs
@@ -718,6 +718,7 @@ pub mod tests {
         let table_data = TableDataMocker::default()
             .table_id(table_id)
             .table_name(table_name.clone())
+            .shard_id(shard_id)
             .build();
 
         assert_eq!(table_id, table_data.id);

diff --git a/analytic_engine/src/wal_synchronizer.rs b/analytic_engine/src/wal_synchronizer.rs
@@ -3,7 +3,7 @@
 //! WAL Synchronizer implementation.
 
 use std::{
-    collections::{BTreeMap, VecDeque},
+    collections::{HashMap, VecDeque},
     sync::{
         atomic::{AtomicU64, Ordering},
         Arc,
@@ -149,7 +149,7 @@ impl WalSynchronizer {
 pub struct Inner {
     wal: WalManagerRef,
     config: WalSynchronizerConfig,
-    tables: RwLock<BTreeMap<Location, SynchronizeState>>,
+    tables: RwLock<HashMap<Location, SynchronizeState>>,
 }
 
 impl Inner {