Skip to content

Commit ab54b64

Browse files
committed
feat: support scan metrics of FileStoreScan to align with ScanMetrics
1 parent 5dc22e7 commit ab54b64

1 file changed

Lines changed: 12 additions & 0 deletions

File tree

src/paimon/core/operation/key_value_file_store_scan_test.cpp

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -147,9 +147,21 @@ TEST_F(KeyValueFileStoreScanTest, TestMaxSequenceNumber) {
147147
ASSERT_OK_AND_ASSIGN(std::shared_ptr<FileStoreScan::RawPlan> raw_plan, scan->CreatePlan());
148148
std::shared_ptr<Metrics> metrics = scan->GetScanMetrics();
149149
ASSERT_TRUE(metrics);
150+
ASSERT_OK_AND_ASSIGN(uint64_t last_scan_duration,
151+
metrics->GetCounter(ScanMetrics::LAST_SCAN_DURATION));
152+
ASSERT_TRUE(last_scan_duration > 0);
150153
ASSERT_OK_AND_ASSIGN(uint64_t last_scanned_snapshot_id,
151154
metrics->GetCounter(ScanMetrics::LAST_SCANNED_SNAPSHOT_ID));
152155
ASSERT_EQ(2u, last_scanned_snapshot_id);
156+
ASSERT_OK_AND_ASSIGN(uint64_t last_scanned_manifests,
157+
metrics->GetCounter(ScanMetrics::LAST_SCANNED_MANIFESTS));
158+
ASSERT_EQ(2u, last_scanned_manifests);
159+
ASSERT_OK_AND_ASSIGN(uint64_t last_scan_skipped_table_files,
160+
metrics->GetCounter(ScanMetrics::LAST_SCAN_SKIPPED_TABLE_FILES));
161+
ASSERT_EQ(0u, last_scan_skipped_table_files);
162+
ASSERT_OK_AND_ASSIGN(uint64_t last_scan_resulted_table_files,
163+
metrics->GetCounter(ScanMetrics::LAST_SCAN_RESULTED_TABLE_FILES));
164+
ASSERT_EQ(2u, last_scan_resulted_table_files);
153165
int64_t max_sequence_num = GetMaxSequenceNumberOfRawPlan(raw_plan);
154166
ASSERT_EQ(max_sequence_num, 1);
155167
// test multiple scan

0 commit comments

Comments
 (0)