add tracing instruments
@@ -384,6 +384,7 @@ impl Table for FuseTable {
Ok(Box::pin(data_block_stream))
}
+ #[tracing::instrument(level = "debug", name = "fuse_table_commit_insertion", skip(self, ctx, operations), fields(ctx.id = ctx.get_id().as_str()))]
async fn commit_insertion(
&self,
ctx: Arc<QueryContext>,
@@ -401,6 +402,7 @@ impl Table for FuseTable {
.await
}
+ #[tracing::instrument(level = "debug", name = "fuse_table_truncate", skip(self, ctx), fields(ctx.id = ctx.get_id().as_str()))]
async fn truncate(
&self,
ctx: Arc<QueryContext>,
@@ -411,6 +413,7 @@ impl Table for FuseTable {
.await
}
+ #[tracing::instrument(level = "debug", name = "fuse_table_optimize", skip(self, ctx), fields(ctx.id = ctx.get_id().as_str()))]
async fn optimize(&self, ctx: Arc<QueryContext>, keep_last_snapshot: bool) -> Result<()> {
self.check_mutable()?;
self.do_gc(&ctx, keep_last_snapshot).await
@@ -426,6 +429,7 @@ impl Table for FuseTable {
}))
}
+ #[tracing::instrument(level = "debug", name = "fuse_table_navigate_to", skip(self, ctx), fields(ctx.id = ctx.get_id().as_str()))]
async fn navigate_to(
&self,
ctx: Arc<QueryContext>,
@@ -441,6 +445,7 @@ impl Table for FuseTable {
}
}
+ #[tracing::instrument(level = "debug", name = "fuse_table_delete", skip(self, ctx), fields(ctx.id = ctx.get_id().as_str()))]
async fn delete(&self, ctx: Arc<QueryContext>, delete_plan: DeletePlan) -> Result<()> {
self.do_delete(ctx, &delete_plan).await
}
