clippy

Author: dqhl76

src/query/service/src/persistent_log/global_persistent_log.rs

@@ -434,7 +434,7 @@ impl GlobalPersistentLog {
     pub async fn set_version_to_meta(&self, version: usize) -> Result<()> {
         self.meta_store
             .upsert_kv(UpsertKV::new(
-                &format!("{}/persistent_log_work/version", self.tenant_id),
+                format!("{}/persistent_log_work/version", self.tenant_id),
                 MatchSeq::Any,
                 Operation::Update(serde_json::to_vec(&version)?),
                 None,

src/query/service/src/persistent_log/table_schemas.rs

@@ -68,6 +68,11 @@ impl QueryLogTable {
         }
     }
 }
+impl Default for QueryLogTable {
+    fn default() -> Self {
+        Self::new()
+    }
+}
 
 impl PersistentLogTable for QueryLogTable {
     fn table_name(&self) -> String {
@@ -163,6 +168,11 @@ impl QueryDetailsTable {
         }
     }
 }
+impl Default for QueryDetailsTable {
+    fn default() -> Self {
+        Self::new()
+    }
+}
 
 impl PersistentLogTable for QueryDetailsTable {
     fn table_name(&self) -> String {
@@ -429,6 +439,11 @@ impl QueryProfileTable {
         }
     }
 }
+impl Default for QueryProfileTable {
+    fn default() -> Self {
+        Self::new()
+    }
+}
 
 impl PersistentLogTable for QueryProfileTable {
     fn table_name(&self) -> String {

src/query/service/tests/it/persistent_log/testdata/persistent_log_tables_schema.txt

@@ -0,0 +1,66 @@
+query_details
+log_type:Int8 NULL
+log_type_name:String NULL
+handler_type:String NULL
+tenant_id:String NULL
+cluster_id:String NULL
+node_id:String NULL
+sql_user:String NULL
+sql_user_quota:String NULL
+sql_user_privileges:String NULL
+query_id:String NULL
+query_kind:String NULL
+query_text:String NULL
+query_hash:String NULL
+query_parameterized_hash:String NULL
+event_date:Date NULL
+event_time:Timestamp NULL
+query_start_time:Timestamp NULL
+query_duration_ms:Int64 NULL
+query_queued_duration_ms:Int64 NULL
+current_database:String NULL
+written_rows:UInt64 NULL
+written_bytes:UInt64 NULL
+join_spilled_rows:UInt64 NULL
+join_spilled_bytes:UInt64 NULL
+agg_spilled_rows:UInt64 NULL
+agg_spilled_bytes:UInt64 NULL
+group_by_spilled_rows:UInt64 NULL
+group_by_spilled_bytes:UInt64 NULL
+written_io_bytes:UInt64 NULL
+written_io_bytes_cost_ms:UInt64 NULL
+scan_rows:UInt64 NULL
+scan_bytes:UInt64 NULL
+scan_io_bytes:UInt64 NULL
+scan_io_bytes_cost_ms:UInt64 NULL
+scan_partitions:UInt64 NULL
+total_partitions:UInt64 NULL
+result_rows:UInt64 NULL
+result_bytes:UInt64 NULL
+bytes_from_remote_disk:UInt64 NULL
+bytes_from_local_disk:UInt64 NULL
+bytes_from_memory:UInt64 NULL
+client_address:String NULL
+user_agent:String NULL
+exception_code:Int32 NULL
+exception_text:String NULL
+server_version:String NULL
+query_tag:String NULL
+has_profile:Boolean NULL
+peek_memory_usage:Variant NULL
+query_profile
+timestamp:Timestamp NULL
+query_id:String NULL
+profiles:Variant NULL
+statistics_desc:Variant NULL
+query_log
+timestamp:Timestamp NULL
+path:String NULL
+target:String NULL
+log_level:String NULL
+cluster_id:String NULL
+node_id:String NULL
+warehouse_id:String NULL
+query_id:String NULL
+message:String NULL
+fields:Variant NULL