This is an automated email from the ASF dual-hosted git repository.

hanahmily pushed a commit to branch perf/trace-vs-stream
in repository https://gitbox.apache.org/repos/asf/skywalking-banyandb.git

commit 6ea2967fc4a50a4556877196048f25e387954911
Author: Gao Hongtao <[email protected]>
AuthorDate: Mon Sep 8 04:51:56 2025 +0000

    refactor: simplify SIDX interface and improve part handling
    
    - Updated SIDX and Merger interfaces to remove unnecessary parameters, 
enhancing clarity and usability.
    - Refactored related implementations and tests to align with the new 
interface signatures.
    - Introduced partWrapper for better part management in the 
flusherIntroduction structure.
    - Improved validation logic in WriteRequest to streamline error handling.
---
 banyand/internal/sidx/sidx.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/banyand/internal/sidx/sidx.go b/banyand/internal/sidx/sidx.go
index b2aa29df..352df8f3 100644
--- a/banyand/internal/sidx/sidx.go
+++ b/banyand/internal/sidx/sidx.go
@@ -453,8 +453,8 @@ func (s *sidx) Flush() error {
                }
                partPath := partPath(s.root, pw.ID())
                pw.mp.mustFlush(s.fileSystem, partPath)
-               newPW := newPartWrapper(nil, mustOpenPart(partPath, 
s.fileSystem))
-               flushIntro.flushed[newPW.ID()] = newPW
+               p := mustOpenPart(partPath, s.fileSystem)
+               flushIntro.flushed[p.partMetadata.ID] = pw
        }
 
        if len(flushIntro.flushed) == 0 {

Reply via email to