Function allParquetBlocksHaveHashColumn

pkg/querier/parquet_queryable.go:646–653

allParquetBlocksHaveHashColumn checks if all parquet blocks have version >= 2, which means they have the hash column. Parquet blocks with version 1 don't have the hash column, so projection cannot be enabled for them.

(blocks []*bucketindex.Block)

// allParquetBlocksHaveHashColumn checks if all parquet blocks have version >= 2, which means they have the hash column.
// Parquet blocks with version 1 don't have the hash column, so projection cannot be enabled for them.
func allParquetBlocksHaveHashColumn(blocks []*bucketindex.Block) bool {
	for _, b := range blocks {
		if b.Parquet == nil || b.Parquet.Version < cortex_parquet.ParquetConverterMarkVersion2 {
			return false
		}
	}
	return true
}

type shardMatcherLabelsFilter struct {
	shardMatcher *storepb.ShardMatcher