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)
| 380 | // traceToParquet converts a tempopb.Trace to this schema's object model. Returns the new object and |
| 381 | // a bool indicating if it's a connected trace or not |
| 382 | func traceToParquet(meta *backend.BlockMeta, id common.ID, tr *tempopb.Trace, ot *Trace) (*Trace, bool) { |
| 383 | // Dedicated attribute column assignments |
| 384 | dedicatedResourceAttributes := dedicatedColumnsToColumnMapping(meta.DedicatedColumns, backend.DedicatedColumnScopeResource) |
| 385 | dedicatedSpanAttributes := dedicatedColumnsToColumnMapping(meta.DedicatedColumns, backend.DedicatedColumnScopeSpan) |
| 386 | dedicatedEventAttributes := dedicatedColumnsToColumnMapping(meta.DedicatedColumns, backend.DedicatedColumnScopeEvent) |
| 387 | |
| 388 | return traceToParquetWithMapping(id, tr, ot, dedicatedResourceAttributes, dedicatedSpanAttributes, dedicatedEventAttributes) |
| 389 | } |
| 390 | |
| 391 | func traceToParquetWithMapping(id common.ID, tr *tempopb.Trace, ot *Trace, dedicatedResourceAttributes, dedicatedSpanAttributes, dedicatedEventAttributes dedicatedColumnMapping) (*Trace, bool) { |
| 392 | if ot == nil { |