From 39fe4537991b7172a4e66d48e248fa90ccedddcc Mon Sep 17 00:00:00 2001 From: gouhongshen Date: Wed, 15 Jan 2025 21:02:58 +0800 Subject: [PATCH] update --- pkg/vm/engine/disttae/logtailreplay/rows_iter.go | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/pkg/vm/engine/disttae/logtailreplay/rows_iter.go b/pkg/vm/engine/disttae/logtailreplay/rows_iter.go index 8efacdd590554..0c13a336a77aa 100644 --- a/pkg/vm/engine/disttae/logtailreplay/rows_iter.go +++ b/pkg/vm/engine/disttae/logtailreplay/rows_iter.go @@ -29,7 +29,7 @@ import ( type RowsIter interface { Next() bool Close() error - Entry() RowEntry + Entry() *RowEntry } type rowsIter struct { @@ -90,8 +90,8 @@ func (p *rowsIter) Next() bool { } } -func (p *rowsIter) Entry() RowEntry { - return *p.iter.Item() +func (p *rowsIter) Entry() *RowEntry { + return p.iter.Item() } func (p *rowsIter) Close() error { @@ -106,7 +106,7 @@ type primaryKeyIter struct { rows *btree.BTreeG[*RowEntry] primaryIndex *btree.BTreeG[*PrimaryIndexEntry] tombstoneRowIdIdx *btree.BTreeG[*PrimaryIndexEntry] - curRow RowEntry + curRow *RowEntry specHint struct { isDelIter bool @@ -532,7 +532,7 @@ func (p *primaryKeyIter) isPKItemValid(pkItem PrimaryIndexEntry) bool { } if row.ID == pkItem.RowEntryID { - p.curRow = *row + p.curRow = row return true } @@ -556,7 +556,7 @@ func (p *primaryKeyIter) Next() bool { } } -func (p *primaryKeyIter) Entry() RowEntry { +func (p *primaryKeyIter) Entry() *RowEntry { return p.curRow }