Function keyNameIterator

tempodb/encoding/vparquet4/block_autocomplete.go:811–827

(makeIter makeIterFn, tr tagRequest, definitionLevel int, keyPath string, attrIters []parquetquery.Iterator)

}

func keyNameIterator(makeIter makeIterFn, tr tagRequest, definitionLevel int, keyPath string, attrIters []parquetquery.Iterator) (parquetquery.Iterator, error) {
	scope := scopeFromDefinitionLevel(definitionLevel, keyPath)
	if len(attrIters) == 0 {
		return parquetquery.NewJoinIterator(
			oneLevelUp(definitionLevel),
			[]parquetquery.Iterator{makeIter(keyPath, nil, "key")},
			newDistinctAttrCollector(scope, true, tr.existsTagName, tr.existsTagValue),
		), nil
	}

	return parquetquery.NewLeftJoinIterator(
		oneLevelUp(definitionLevel),
		attrIters,
		[]parquetquery.Iterator{makeIter(keyPath, nil, "key")},
		newDistinctAttrCollector(scope, true, tr.existsTagName, tr.existsTagValue),
	)
}

func oneLevelUp(definitionLevel int) int {
	switch definitionLevel {