From ad7512c3705deca667839f74637513d7844c2699 Mon Sep 17 00:00:00 2001 From: shaoting-huang Date: Thu, 27 Jun 2024 15:00:09 +0800 Subject: [PATCH] clean up Signed-off-by: shaoting-huang --- internal/storage/serde_events.go | 6 +++--- internal/storage/serde_events_test.go | 2 +- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/internal/storage/serde_events.go b/internal/storage/serde_events.go index af1d9ef00a2da..910e6e41c1908 100644 --- a/internal/storage/serde_events.go +++ b/internal/storage/serde_events.go @@ -753,7 +753,7 @@ func (dsw *MultiFieldDeltalogStreamWriter) writeDeltalogHeaders(w io.Writer) err return nil } -func NewDeltalogSerializeWriterV2(partitionID, segmentID UniqueID, eventWriter *MultiFieldDeltalogStreamWriter, batchSize int, +func NewDeltalogMultiFieldWriter(partitionID, segmentID UniqueID, eventWriter *MultiFieldDeltalogStreamWriter, batchSize int, ) (*SerializeWriter[*DeleteLog], error) { rw, err := eventWriter.GetRecordWriter() if err != nil { @@ -797,7 +797,7 @@ func NewDeltalogSerializeWriterV2(partitionID, segmentID UniqueID, eventWriter * }, batchSize), nil } -func NewDeltalogDeserializeReaderV2(blobs []*Blob) (*DeserializeReader[*DeleteLog], error) { +func NewDeltalogMultiFieldReader(blobs []*Blob) (*DeserializeReader[*DeleteLog], error) { reader, err := newSimpleArrowRecordReader(blobs) if err != nil { return nil, err @@ -832,7 +832,7 @@ func NewDeltalogDeserializeReaderV2(blobs []*Blob) (*DeserializeReader[*DeleteLo func NewDeltalogDeserializeReaderUnified(blobs []*Blob) (*DeserializeReader[*DeleteLog], error) { if supportMultiFieldFormat(blobs) { - return NewDeltalogDeserializeReaderV2(blobs) + return NewDeltalogMultiFieldReader(blobs) } return NewDeltalogDeserializeReader(blobs) } diff --git a/internal/storage/serde_events_test.go b/internal/storage/serde_events_test.go index 933689bee68c8..6523834cf111f 100644 --- a/internal/storage/serde_events_test.go +++ b/internal/storage/serde_events_test.go @@ -355,7 +355,7 @@ func TestDeltalogV2(t *testing.T) { t.Run("test serialize deserialize", func(t *testing.T) { eventWriter := NewMultiFieldDeltalogStreamWriter(0, 0, 0) - writer, err := NewDeltalogSerializeWriterV2(0, 0, eventWriter, 7) + writer, err := NewDeltalogMultiFieldWriter(0, 0, eventWriter, 7) assert.NoError(t, err) size := 10