Function parquetToProtoEvents

tempodb/encoding/vparquet5/schema.go:741–775

(parquetEvents []Event, spanStartTimeNano uint64, dedicatedAttributes dedicatedColumnMapping)

}

func parquetToProtoEvents(parquetEvents []Event, spanStartTimeNano uint64, dedicatedAttributes dedicatedColumnMapping) []*v1_trace.Span_Event {
	var protoEvents []*v1_trace.Span_Event

	if len(parquetEvents) > 0 {
		protoEvents = make([]*v1_trace.Span_Event, 0, len(parquetEvents))

		for _, e := range parquetEvents {

			protoEvent := &v1_trace.Span_Event{
				TimeUnixNano:           e.TimeSinceStartNano + spanStartTimeNano,
				Name:                   e.Name,
				Attributes:             nil,
				DroppedAttributesCount: uint32(e.DroppedAttributesCount),
			}

			if len(e.Attrs) > 0 {
				protoEvent.Attributes = parquetToProtoAttrs(e.Attrs)
			}

			for attr, col := range dedicatedAttributes.items() {
				val := col.readValue(&e.DedicatedAttributes)
				if val != nil {
					protoEvent.Attributes = append(protoEvent.Attributes, &v1.KeyValue{
						Key:   attr,
						Value: val,
					})
				}
			}

			protoEvents = append(protoEvents, protoEvent)
		}
	}

	return protoEvents
}

func ParquetTraceToTempopbTrace(meta *backend.BlockMeta, parquetTrace *Trace) *tempopb.Trace {
	protoTrace := &tempopb.Trace{}