Skip to content

Commit bfa3e68

Browse files
committed
feat(meta): add lineage api
1 parent e5b53c2 commit bfa3e68

16 files changed

Lines changed: 712 additions & 1 deletion

File tree

src/meta/api/src/api_impl/auto_increment_api_test_suite.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -128,6 +128,7 @@ impl AutoIncrementApiTestSuite {
128128
table_name: tbl_name.to_string(),
129129
},
130130
table_meta: drop_table_meta(created_on),
131+
lineage_updates: vec![],
131132
as_dropped: true,
132133
table_properties: None,
133134
table_partition: None,

src/meta/api/src/api_impl/garbage_collection_api.rs

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -73,6 +73,7 @@ use log::info;
7373
use log::warn;
7474

7575
use super::index_api::IndexApi;
76+
use super::lineage_api::append_delete_lineage_for_table_id_txn_ops;
7677
use crate::kv_app_error::KVAppError;
7778
use crate::kv_pb_api::KVPbApi;
7879
use crate::kv_pb_crud_api::KVPbCrudApi;
@@ -662,6 +663,13 @@ async fn gc_dropped_table_by_id(
662663
// 3)
663664

664665
remove_index_for_dropped_table(kv_api, tenant, table_id_ident, &mut txn).await?;
666+
append_delete_lineage_for_table_id_txn_ops(
667+
kv_api,
668+
tenant,
669+
&mut txn,
670+
table_id_ident.table_id,
671+
)
672+
.await?;
665673

666674
// Count removed keys (approximate for DeleteByPrefix operations)
667675
let mut num_meta_keys_removed = 0;

0 commit comments

Comments
 (0)