Function aggregateScope

cmd/tempo-cli/cmd-analyse-block.go:317–408

(pf *parquet.File, meta *backend.BlockMeta, paths scopeAttributePath, includeWellKnown bool)

}

func aggregateScope(pf *parquet.File, meta *backend.BlockMeta, paths scopeAttributePath, includeWellKnown bool) (attributeSummary, error) {
	var strings []backend.DedicatedColumn
	var ints []backend.DedicatedColumn
	for _, c := range meta.DedicatedColumns {
		if c.Scope == paths.dedicatedColScope {
			switch c.Type {
			case backend.DedicatedColumnTypeString:
				strings = append(strings, c)
			case backend.DedicatedColumnTypeInt:
				ints = append(ints, c)
			}
		}
	}

	res, err := aggregateGenericAttributes(pf, paths.defLevel, paths.keyPath, paths.valPath, paths.intPath, paths.isArrayPath)
	if err != nil {
		return res, err
	}

	res.dedicated = make(map[string]struct{})

	for i, c := range strings {
		if i >= len(paths.dedicatedColsPaths) {
			break
		}
		cardinality, err := aggregateStringColumn(pf, paths.dedicatedColsPaths[i])
		if err != nil {
			return res, err
		}
		res.attributes[c.Name] = &stringAttributeSummary{
			name:        c.Name,
			totalBytes:  cardinality.totalBytes(),
			cardinality: cardinality,
		}
		res.dedicated[c.Name] = struct{}{}
	}

	if includeWellKnown {
		for wellKnownAttr, path := range paths.wellKnownPathsString {
			cardinality, err := aggregateStringColumn(pf, path)
			if err != nil {
				return res, err
			}
			res.attributes[wellKnownAttr] = &stringAttributeSummary{
				name:        wellKnownAttr,
				totalBytes:  cardinality.totalBytes(),
				cardinality: cardinality,
			}
			res.dedicated[wellKnownAttr] = struct{}{} // Well-known columns are also dedicated columns.
		}
	}

	for i, c := range ints {
		if i >= len(paths.dedicatedColsPathsInt) {
			break
		}
		path := paths.dedicatedColsPathsInt[i]
		count, err := aggregateIntegerColumn(pf, path)