Skip to content

Commit f29c971

Browse files
authored
feat: return full key in state store get_keyed_row interface (#19345)
1 parent 4085f56 commit f29c971

File tree

16 files changed

+473
-105
lines changed

16 files changed

+473
-105
lines changed

src/storage/hummock_test/src/snapshot_tests.rs

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@ use risingwave_storage::store::{
3232
use risingwave_storage::StateStore;
3333

3434
use crate::local_state_store_test_utils::LocalStateStoreTestExt;
35-
use crate::test_utils::{gen_key_from_bytes, with_hummock_storage_v2, TestIngestBatch};
35+
use crate::test_utils::{gen_key_from_bytes, with_hummock_storage, TestIngestBatch};
3636

3737
macro_rules! assert_count_range_scan {
3838
(
@@ -402,36 +402,36 @@ async fn test_snapshot_range_scan_inner(
402402

403403
#[tokio::test]
404404
async fn test_snapshot_v2() {
405-
let (storage, meta_client) = with_hummock_storage_v2(Default::default()).await;
405+
let (storage, meta_client) = with_hummock_storage(Default::default()).await;
406406
test_snapshot_inner(storage, meta_client, false, false).await;
407407
}
408408

409409
#[tokio::test]
410410
async fn test_snapshot_with_sync_v2() {
411-
let (storage, meta_client) = with_hummock_storage_v2(Default::default()).await;
411+
let (storage, meta_client) = with_hummock_storage(Default::default()).await;
412412
test_snapshot_inner(storage, meta_client, true, false).await;
413413
}
414414

415415
#[tokio::test]
416416
async fn test_snapshot_with_commit_v2() {
417-
let (storage, meta_client) = with_hummock_storage_v2(Default::default()).await;
417+
let (storage, meta_client) = with_hummock_storage(Default::default()).await;
418418
test_snapshot_inner(storage, meta_client, true, true).await;
419419
}
420420

421421
#[tokio::test]
422422
async fn test_snapshot_range_scan_v2() {
423-
let (storage, meta_client) = with_hummock_storage_v2(Default::default()).await;
423+
let (storage, meta_client) = with_hummock_storage(Default::default()).await;
424424
test_snapshot_range_scan_inner(storage, meta_client, false, false).await;
425425
}
426426

427427
#[tokio::test]
428428
async fn test_snapshot_range_scan_with_sync_v2() {
429-
let (storage, meta_client) = with_hummock_storage_v2(Default::default()).await;
429+
let (storage, meta_client) = with_hummock_storage(Default::default()).await;
430430
test_snapshot_range_scan_inner(storage, meta_client, true, false).await;
431431
}
432432

433433
#[tokio::test]
434434
async fn test_snapshot_range_scan_with_commit_v2() {
435-
let (storage, meta_client) = with_hummock_storage_v2(Default::default()).await;
435+
let (storage, meta_client) = with_hummock_storage(Default::default()).await;
436436
test_snapshot_range_scan_inner(storage, meta_client, true, true).await;
437437
}

0 commit comments

Comments
 (0)