enhance: optimize retrieve on dynamic field

Signed-off-by: zhenshan.cao <[email protected]>
czs007 · Aug 16, 2024 · 5a0c2ff · 5a0c2ff
1 parent 80dbe87
commit 5a0c2ff
Show file tree

Hide file tree

Showing 12 changed files with 384 additions and 370 deletions.
diff --git a/internal/datanode/channel/channel_manager_test.go b/internal/datanode/channel/channel_manager_test.go
@@ -181,9 +181,7 @@ func (s *ChannelManagerSuite) TearDownTest() {
 }
 
 func (s *ChannelManagerSuite) TestReleaseStuck() {
-	var (
-		channel = "by-dev-rootcoord-dml-2"
-	)
+	channel := "by-dev-rootcoord-dml-2"
 	s.manager.releaseFunc = func(channel string) {
 		time.Sleep(1 * time.Second)
 	}

diff --git a/internal/datanode/compaction/clustering_compactor.go b/internal/datanode/compaction/clustering_compactor.go
@@ -1247,7 +1247,8 @@ func (t *clusteringCompactionTask) checkBuffersAfterCompaction() error {
 }
 
 func (t *clusteringCompactionTask) generatePkStats(ctx context.Context, segmentID int64,
-	numRows int64, binlogPaths [][]string) (*datapb.FieldBinlog, error) {
+	numRows int64, binlogPaths [][]string,
+) (*datapb.FieldBinlog, error) {
 	stats, err := storage.NewPrimaryKeyStats(t.primaryKeyField.GetFieldID(), int64(t.primaryKeyField.GetDataType()), numRows)
 	if err != nil {
 		return nil, err

diff --git a/internal/datanode/compaction/compactor_common.go b/internal/datanode/compaction/compactor_common.go
@@ -178,7 +178,8 @@ func statSerializeWrite(ctx context.Context, io io.BinlogIO, allocator allocator
 }
 
 func uploadStatsBlobs(ctx context.Context, collectionID, partitionID, segmentID, pkID, numRows int64,
-	io io.BinlogIO, allocator allocator.Interface, blob *storage.Blob) (*datapb.FieldBinlog, error) {
+	io io.BinlogIO, allocator allocator.Interface, blob *storage.Blob,
+) (*datapb.FieldBinlog, error) {
 	logID, err := allocator.AllocOne()
 	if err != nil {
 		return nil, err

diff --git a/internal/mocks/distributed/mock_streaming/mock_WALAccesser.go b/internal/mocks/distributed/mock_streaming/mock_WALAccesser.go