misc changes

Author: Eshanatnight

server/src/migration.rs

@@ -155,7 +155,7 @@ async fn migration_stream(stream: &str, storage: &dyn ObjectStorage) -> anyhow::
 }
 
 #[inline(always)]
-fn to_bytes(any: &(impl ?Sized + Serialize)) -> Bytes {
+pub fn to_bytes(any: &(impl ?Sized + Serialize)) -> Bytes {
     serde_json::to_vec(any)
         .map(|any| any.into())
         .expect("serialize cannot fail")

server/src/query.rs

@@ -186,6 +186,9 @@ impl TableScanVisitor {
     pub fn into_inner(self) -> Vec<String> {
         self.tables
     }
+    pub fn top(&self) -> &str {
+        self.tables[0].as_ref()
+    }
 }
 
 impl TreeNodeVisitor for TableScanVisitor {

server/src/storage/staging.rs

@@ -293,7 +293,7 @@ pub fn convert_disk_files_to_parquet(
     }
 }
 
-fn parquet_writer_props(
+pub fn parquet_writer_props(
     time_partition: Option<String>,
     index_time_partition: usize,
     custom_partition_fields: HashMap<String, usize>,

server/src/utils.rs

@@ -280,7 +280,7 @@ pub fn get_ingestor_id() -> String {
     let result = format!("{:x}", hasher.finalize());
     let result = result.split_at(15).0.to_string();
     log::debug!("Ingestor ID: {}", &result);
-    result.to_string()
+    result
 }
 
 #[cfg(test)]