traceToParquet converts a tempopb.Trace to this schema's object model. Returns the new object and a bool indicating if it's a connected trace or not
(meta *backend.BlockMeta, id common.ID, tr *tempopb.Trace, ot *Trace)
| 349 | // traceToParquet converts a tempopb.Trace to this schema's object model. Returns the new object and |
| 350 | // a bool indicating if it's a connected trace or not |
| 351 | func traceToParquet(meta *backend.BlockMeta, id common.ID, tr *tempopb.Trace, ot *Trace) (*Trace, bool) { |
| 352 | // Dedicated attribute column assignments |
| 353 | dedicatedResourceAttributes := dedicatedColumnsToColumnMapping(meta.DedicatedColumns, backend.DedicatedColumnScopeResource) |
| 354 | dedicatedSpanAttributes := dedicatedColumnsToColumnMapping(meta.DedicatedColumns, backend.DedicatedColumnScopeSpan) |
| 355 | |
| 356 | return traceToParquetWithMapping(id, tr, ot, dedicatedResourceAttributes, dedicatedSpanAttributes) |
| 357 | } |
| 358 | |
| 359 | func traceToParquetWithMapping(id common.ID, tr *tempopb.Trace, ot *Trace, dedicatedResourceAttributes, dedicatedSpanAttributes dedicatedColumnMapping) (*Trace, bool) { |
| 360 | if ot == nil { |