Several Changes about Index and Document

CHANGES.md

@@ -7,6 +7,7 @@ Release Notes.
 ### Features
 
 - Add the `bydbctl analyze series` command to analyze the series data.
+- Index: Remove sortable field from the stored field. If a field is sortable only, it won't be stored.
 
 ### Bug Fixes
 
@@ -15,6 +16,7 @@ Release Notes.
 ### Documentation
 
 - Improve the description of the memory in observability doc.
+- Update kubernetes install document to align the banyandb helm v0.3.0.
 
 ### Chores
 

banyand/internal/storage/index.go

@@ -245,7 +245,7 @@ func (s *seriesIndex) Search(ctx context.Context, series []*pbv1.Series, opts In
 	if err != nil {
 		return nil, nil, err
 	}
-	iter, err := s.store.Iterator(ctx, fieldKey, rangeOpts,
+	iter, err := s.store.SeriesSort(ctx, fieldKey, rangeOpts,
 		opts.Order.Sort, opts.PreloadSize, query, opts.Projection)
 	if err != nil {
 		return nil, nil, err

banyand/measure/write.go

@@ -163,8 +163,9 @@ func (w *writeCallback) handle(dst map[string]*dataPointsInGroup, writeEvent *me
 							IndexRuleID: r.GetMetadata().GetId(),
 							Analyzer:    r.Analyzer,
 						},
-						Term:  encodeTagValue.value,
-						Store: true,
+						Term:   encodeTagValue.value,
+						Store:  true,
+						NoSort: r.GetNoSort(),
 					})
 				} else {
 					for _, val := range encodeTagValue.valueArr {
@@ -173,8 +174,9 @@ func (w *writeCallback) handle(dst map[string]*dataPointsInGroup, writeEvent *me
 								IndexRuleID: r.GetMetadata().GetId(),
 								Analyzer:    r.Analyzer,
 							},
-							Term:  val,
-							Store: true,
+							Term:   val,
+							Store:  true,
+							NoSort: r.GetNoSort(),
 						})
 					}
 				}

docs/installation/kubernetes.md

@@ -35,8 +35,8 @@ kubectl create ns sw
 ```shell
 helm install banyandb \
     oci://registry-1.docker.io/apache/skywalking-banyandb-helm \
-    --version 0.2.0 \
-    --set image.tag=0.6.1 \
+    --version 0.3.0 \
+    --set image.tag=0.7.0 \
     --set standalone.enabled=true \
     --set cluster.enabled=false \
     --set etcd.enabled=false \
@@ -84,8 +84,8 @@ At the same time, the BanyanDB server would be listening on the `0.0.0.0:17913`
 ```shell
 helm install banyandb \
     oci://registry-1.docker.io/apache/skywalking-banyandb-helm \
-    --version 0.2.0 \
-    --set image.tag=0.6.1 \
+    --version 0.3.0 \
+    --set image.tag=0.7.0 \
     --set standalone.enabled=false \
     --set cluster.enabled=true \
     --set etcd.enabled=true \

pkg/index/index.go

@@ -175,7 +175,7 @@ type Writer interface {
 type FieldIterable interface {
 	BuildQuery(seriesMatchers []SeriesMatcher, secondaryQuery Query) (Query, error)
 	Iterator(ctx context.Context, fieldKey FieldKey, termRange RangeOpts, order modelv1.Sort,
-		preLoadSize int, query Query, fieldKeys []FieldKey) (iter FieldIterator[*DocumentResult], err error)
+		preLoadSize int) (iter FieldIterator[*DocumentResult], err error)
 	Sort(ctx context.Context, sids []common.SeriesID, fieldKey FieldKey,
 		order modelv1.Sort, timeRange *timestamp.TimeRange, preLoadSize int) (FieldIterator[*DocumentResult], error)
 }
@@ -229,6 +229,8 @@ type SeriesStore interface {
 	// Search returns a list of series that match the given matchers.
 	Search(context.Context, []FieldKey, Query) ([]SeriesDocument, error)
 	SeriesIterator(context.Context) (FieldIterator[Series], error)
+	SeriesSort(ctx context.Context, fieldKey FieldKey, termRange RangeOpts, order modelv1.Sort,
+		preLoadSize int, query Query, fieldKeys []FieldKey) (iter FieldIterator[*DocumentResult], err error)
 }
 
 // SeriesMatcherType represents the type of series matcher.

pkg/index/inverted/inverted.go

@@ -121,7 +121,7 @@ func (s *store) Batch(batch index.Batch) error {
 		for _, f := range d.Fields {
 			tf := bluge.NewKeywordFieldBytes(f.Key.Marshal(), f.Term)
 			if !f.NoSort {
-				tf.StoreValue().Sortable()
+				tf.Sortable()
 			}
 			if f.Store {
 				tf.StoreValue()
@@ -178,7 +178,7 @@ func (s *store) Close() error {
 }
 
 func (s *store) Iterator(ctx context.Context, fieldKey index.FieldKey, termRange index.RangeOpts, order modelv1.Sort,
-	preLoadSize int, indexQuery index.Query, fieldKeys []index.FieldKey,
+	preLoadSize int,
 ) (iter index.FieldIterator[*index.DocumentResult], err error) {
 	if termRange.Lower != nil &&
 		termRange.Upper != nil &&
@@ -229,25 +229,14 @@ func (s *store) Iterator(ctx context.Context, fieldKey index.FieldKey, termRange
 	if order == modelv1.Sort_SORT_DESC {
 		sortedKey = "-" + sortedKey
 	}
-	query := bluge.NewBooleanQuery().AddMust(rangeQuery)
-	node := newMustNode()
-	node.Append(rangeNode)
-	if indexQuery != nil && indexQuery.(*queryNode).query != nil {
-		query.AddMust(indexQuery.(*queryNode).query)
-		node.Append(indexQuery.(*queryNode).node)
-	}
-	fields := make([]string, 0, len(fieldKeys))
-	for i := range fieldKeys {
-		fields = append(fields, fieldKeys[i].Marshal())
-	}
 	result := &sortIterator{
-		query:     &queryNode{query, node},
-		fields:    fields,
-		reader:    reader,
-		sortedKey: sortedKey,
-		size:      preLoadSize,
-		closer:    s.closer,
-		ctx:       ctx,
+		query:       &queryNode{rangeQuery, rangeNode},
+		reader:      reader,
+		sortedKey:   sortedKey,
+		size:        preLoadSize,
+		closer:      s.closer,
+		ctx:         ctx,
+		newIterator: newBlugeMatchIterator,
 	}
 	return result, nil
 }
@@ -333,7 +322,7 @@ func getMatchOptions(analyzerOnIndexRule string, opts *modelv1.Condition_MatchOp
 }
 
 func (s *store) Range(fieldKey index.FieldKey, opts index.RangeOpts) (list posting.List, err error) {
-	iter, err := s.Iterator(context.TODO(), fieldKey, opts, modelv1.Sort_SORT_ASC, defaultRangePreloadSize, nil, nil)
+	iter, err := s.Iterator(context.TODO(), fieldKey, opts, modelv1.Sort_SORT_ASC, defaultRangePreloadSize)
 	if err != nil {
 		return roaring.DummyPostingList, err
 	}
@@ -346,25 +335,22 @@ func (s *store) Range(fieldKey index.FieldKey, opts index.RangeOpts) (list posti
 }
 
 type blugeMatchIterator struct {
-	delegated        search.DocumentMatchIterator
-	err              error
-	closer           io.Closer
-	needToLoadFields []string
-	current          index.DocumentResult
-	hit              int
+	delegated search.DocumentMatchIterator
+	err       error
+	closer    io.Closer
+	ctx       *search.Context
+	current   index.DocumentResult
+	hit       int
 }
 
 func newBlugeMatchIterator(delegated search.DocumentMatchIterator, closer io.Closer,
-	needToLoadFields []string,
-) blugeMatchIterator {
-	bmi := blugeMatchIterator{
-		delegated:        delegated,
-		closer:           closer,
-		needToLoadFields: needToLoadFields,
-		current:          index.DocumentResult{Values: make(map[string][]byte, len(needToLoadFields))},
-	}
-	for _, f := range needToLoadFields {
-		bmi.current.Values[f] = nil
+	_ []string,
+) blugeIterator {
+	bmi := &blugeMatchIterator{
+		delegated: delegated,
+		closer:    closer,
+		current:   index.DocumentResult{},
+		ctx:       search.NewSearchContext(1, 0),
 	}
 	return bmi
 }
@@ -391,32 +377,30 @@ func (bmi *blugeMatchIterator) Next() bool {
 	if len(match.SortValue) > 0 {
 		bmi.current.SortedValue = match.SortValue[0]
 	}
-	err := match.VisitStoredFields(func(field string, value []byte) bool {
-		switch field {
-		case entityField:
-			bmi.current.EntityValues = value
-		case docIDField:
-			bmi.current.DocID = convert.BytesToUint64(value)
-		case seriesIDField:
-			bmi.current.SeriesID = common.SeriesID(convert.BytesToUint64(value))
-		case timestampField:
-			ts, err := bluge.DecodeDateTime(value)
-			if err != nil {
-				bmi.err = err
-				return false
-			}
-			bmi.current.Timestamp = ts.UnixNano()
-		default:
-			if _, ok := bmi.current.Values[field]; ok {
-				bmi.current.Values[field] = bytes.Clone(value)
-			}
-		}
-		return true
-	})
-	bmi.err = errors.WithMessagef(err, "visit stored fields, hit: %d", bmi.hit)
+	err := match.VisitStoredFields(bmi.setVal)
+	bmi.err = multierr.Combine(bmi.err, err)
 	return bmi.err == nil
 }
 
+func (bmi *blugeMatchIterator) setVal(field string, value []byte) bool {
+	switch field {
+	case docIDField:
+		bmi.current.DocID = convert.BytesToUint64(value)
+	case seriesIDField:
+		bmi.current.SeriesID = common.SeriesID(convert.BytesToUint64(value))
+	case timestampField:
+		ts, errTime := bluge.DecodeDateTime(value)
+		if errTime != nil {
+			bmi.err = errTime
+			return false
+		}
+		bmi.current.Timestamp = ts.UnixNano()
+	default:
+		bmi.err = errors.Errorf("unexpected field: %s", field)
+	}
+	return true
+}
+
 func (bmi *blugeMatchIterator) Val() index.DocumentResult {
 	return bmi.current
 }