Method Select

pkg/querier/parquet_queryable.go:485–579

(ctx context.Context, sortSeries bool, h *storage.SelectHints, matchers ...*labels.Matcher)

}

func (q *parquetQuerierWithFallback) Select(ctx context.Context, sortSeries bool, h *storage.SelectHints, matchers ...*labels.Matcher) storage.SeriesSet {
	span, ctx := opentracing.StartSpanFromContext(ctx, "parquetQuerierWithFallback.Select")
	defer span.Finish()

	newMatchers, shardInfo, err := querysharding.ExtractShardingInfo(matchers)
	if err != nil {
		return storage.ErrSeriesSet(err)
	}

	hints := storage.SelectHints{
		Start: q.minT,
		End:   q.maxT,
	}

	mint, maxt, limit := q.minT, q.maxT, 0
	if h != nil {
		// let copy the hints here as we wanna potentially modify it
		hints = *h
		mint, maxt, limit = hints.Start, hints.End, hints.Limit
	}

	maxt = q.adjustMaxT(maxt)
	hints.End = maxt

	if maxt < mint {
		return storage.EmptySeriesSet()
	}

	remaining, parquet, err := q.getBlocks(ctx, mint, maxt, matchers)
	defer q.incrementOpsMetric("Select", remaining, parquet)

	if err != nil {
		return storage.ErrSeriesSet(err)
	}

	if len(remaining) > 0 && q.fallbackDisabled {
		err = parquetConsistencyCheckError(remaining)
		return storage.ErrSeriesSet(err)
	}

	// Lets sort the series to merge
	if len(parquet) > 0 && len(remaining) > 0 {
		sortSeries = true
	}

	// Reset projection hints if:
	// - there are mixed blocks (both parquet and non-parquet)
	// - not all parquet blocks have hash column (version < 2)
	if q.honorProjectionHints {
		if len(remaining) > 0 || !allParquetBlocksHaveHashColumn(parquet) {
			hints.ProjectionLabels = nil
			hints.ProjectionInclude = false
		}
		if hints.ProjectionInclude && !slices.Contains(hints.ProjectionLabels, schema.SeriesHashColumn) {
			// Series hash column is always required for projection unless duplicate label check is disabled.
			hints.ProjectionLabels = append(hints.ProjectionLabels, schema.SeriesHashColumn)

		}