Fix refactoring bug

src/compaction/mod.rs

@@ -76,9 +76,15 @@ where
 
             let mutable = mem::replace(
                 &mut guard.mutable,
-                Mutable::new(&self.option, trigger_clone, self.manager.base_fs()).await?,
+                Mutable::new(
+                    &self.option,
+                    trigger_clone,
+                    self.manager.base_fs(),
+                    self.record_schema.clone(),
+                )
+                .await?,
             );
-            let (file_id, immutable) = mutable.into_immutable(&guard.record_instance).await?;
+            let (file_id, immutable) = mutable.into_immutable().await?;
             guard.immutables.push((file_id, immutable));
         } else if !is_manual {
             return Ok(());

src/option.rs

@@ -28,7 +28,6 @@ pub struct DbOption<R> {
     pub(crate) clean_channel_buffer: usize,
     pub(crate) base_path: Path,
     pub(crate) base_fs: FsOptions,
-    // TODO: DEBUG
     pub(crate) level_paths: Vec<Option<(Path, FsOptions)>>,
     pub(crate) immutable_chunk_num: usize,
     pub(crate) immutable_chunk_max_num: usize,

src/record/mod.rs

@@ -110,7 +110,16 @@ impl Schema for DynSchema {
     }
 
     fn primary_key_path(&self) -> (ColumnPath, Vec<SortingColumn>) {
-        unimplemented!()
+        (
+            ColumnPath::new(vec![
+                "_ts".to_string(),
+                self.schema[self.primary_index].name.clone(),
+            ]),
+            vec![
+                SortingColumn::new(1_i32, true, true),
+                SortingColumn::new(self.primary_key_index() as i32, false, true),
+            ],
+        )
     }
 }