Method ToDedicatedColumns

cmd/tempo-cli/cmd-analyse-block.go:456–509

(settings heuristicSettings)

}

func (s blockSummary) ToDedicatedColumns(settings heuristicSettings) []backend.DedicatedColumn {
	var dedicatedCols []backend.DedicatedColumn

	doStringSummary := func(summary attributeSummary, scope backend.DedicatedColumnScope) {
		if summary.rowCount == 0 {
			return
		}
		for _, attr := range topN(settings.NumStringAttr, summary.attributes) {
			percentOfRows := float64(attr.cardinality.totalOccurrences()) / float64(summary.rowCount)
			if percentOfRows < settings.StrThresholdPercent {
				continue
			}

			options := backend.DedicatedColumnOptions{}
			totalSize := attr.cardinality.avgSizePerRowGroup(s.numRowGroups)
			if settings.BlobThresholdBytes > 0 && totalSize >= settings.BlobThresholdBytes {
				options = append(options, backend.DedicatedColumnOptionBlob)
			}
			dedicatedCols = append(dedicatedCols, backend.DedicatedColumn{
				Name:    attr.name,
				Scope:   scope,
				Type:    backend.DedicatedColumnTypeString,
				Options: options,
			})
		}
	}

	doIntSummary := func(summary attributeSummary, scope backend.DedicatedColumnScope) {
		if summary.rowCount == 0 {
			return
		}
		for _, attr := range topNInt(settings.NumIntAttr, summary.integerAttributes) {
			percentOfRows := float64(attr.count) / float64(summary.rowCount)
			if percentOfRows < settings.IntThresholdPercent {
				continue
			}
			dedicatedCols = append(dedicatedCols, backend.DedicatedColumn{
				Name:    attr.name,
				Scope:   scope,
				Type:    backend.DedicatedColumnTypeInt,
				Options: backend.DedicatedColumnOptions{},
			})
		}
	}

	doStringSummary(s.spanSummary, backend.DedicatedColumnScopeSpan)
	doIntSummary(s.spanSummary, backend.DedicatedColumnScopeSpan)
	doStringSummary(s.resourceSummary, backend.DedicatedColumnScopeResource)
	doIntSummary(s.resourceSummary, backend.DedicatedColumnScopeResource)
	doStringSummary(s.eventSummary, backend.DedicatedColumnScopeEvent)
	doIntSummary(s.eventSummary, backend.DedicatedColumnScopeEvent)

	return dedicatedCols
}

type attributeSummary struct {
	attributes             map[string]*stringAttributeSummary  // key: attribute name