Function BenchmarkMergeWithHintFile

hintfile_bench_test.go:343–398

BenchmarkMergeWithHintFile benchmarks merge operation with hint files enabled

(b *testing.B)

// BenchmarkMergeWithHintFile benchmarks merge operation with hint files enabled
func BenchmarkMergeWithHintFile(b *testing.B) {
	tmpDir, err := os.MkdirTemp("", "hintfile-bench-merge")
	if err != nil {
		b.Fatalf("Failed to create temp dir: %v", err)
	}
	defer func() { _ = os.RemoveAll(tmpDir) }()

	opts := DefaultOptions
	opts.Dir = tmpDir
	opts.SegmentSize = 64 * KB
	opts.EnableHintFile = true

	b.ResetTimer()
	for i := 0; i < b.N; i++ {
		// Create fresh database for each iteration
		iterDir := fmt.Sprintf("%s/iter%d", tmpDir, i)
		opts.Dir = iterDir

		db, err := Open(opts)
		if err != nil {
			b.Fatalf("Failed to open database: %v", err)
		}

		bucket := "bucket"
		txCreateBucket(&testing.T{}, db, DataStructureBTree, bucket, nil)

		// Add data and delete some to trigger merge
		for j := 0; j < 2000; j++ {
			txPut(&testing.T{}, db, bucket, testutils.GetTestBytes(j), testutils.GetTestBytes(j), Persistent, nil, nil)
		}

		for j := 0; j < 500; j++ {
			txDel(&testing.T{}, db, bucket, testutils.GetTestBytes(j), nil)
		}

		// Perform merge with hint file creation
		b.StopTimer()
		start := time.Now()
		b.StartTimer()

		err = db.Merge()
		if err != nil {
			b.Fatalf("Failed to merge: %v", err)
		}

		b.StopTimer()
		mergeTime := time.Since(start)
		b.ReportMetric(float64(mergeTime.Nanoseconds())/1e6, "ms")
		b.StartTimer()

		err = db.Close()
		if err != nil {
			b.Fatalf("Failed to close database: %v", err)
		}
	}
}

// BenchmarkMergeWithoutHintFile benchmarks merge operation without hint files enabled