Method IterateLowSeriesIDs

flow/context.go:396–420

IterateLowSeriesIDs iterates low series ids from storage, then found low series id which query need.

(lowSeriesIDsFromStorage roaring.Container,
	fn func(seriesIdxFromQuery uint16, seriesIdxFromStorage int),
)

// IterateLowSeriesIDs iterates low series ids from storage, then found low series id which query need.
func (ctx *DataLoadContext) IterateLowSeriesIDs(lowSeriesIDsFromStorage roaring.Container,
	fn func(seriesIdxFromQuery uint16, seriesIdxFromStorage int),
) {
	min := ctx.MinSeriesID
	max := ctx.MaxSeriesID
	lowSeriesIDs := ctx.LowSeriesIDs
	it := lowSeriesIDsFromStorage.PeekableIterator()
	seriesIdxFromStorage := 0
	for it.HasNext() {
		seriesID := it.Next()
		if seriesID > max {
			break
		}
		if seriesID < min {
			seriesIdxFromStorage++
			continue
		}
		seriesIdxFromQuery := seriesID - min
		if lowSeriesIDs[seriesIdxFromQuery] == seriesID {
			// match low series invoke callback
			fn(seriesIdxFromQuery, seriesIdxFromStorage)
		}
		seriesIdxFromStorage++
	}
}

// Reduce reduces down sampling result.
func (ctx *DataLoadContext) Reduce(reduceFn func(it series.GroupedIterator)) {