(cb common.TagValuesCallbackV2, v parquet.Value)
| 474 | } |
| 475 | |
| 476 | func callback(cb common.TagValuesCallbackV2, v parquet.Value) (stop bool) { |
| 477 | switch v.Kind() { |
| 478 | |
| 479 | case parquet.Boolean: |
| 480 | return cb(traceql.NewStaticBool(v.Boolean())) |
| 481 | |
| 482 | case parquet.Int32, parquet.Int64: |
| 483 | return cb(traceql.NewStaticInt(int(v.Int64()))) |
| 484 | |
| 485 | case parquet.Float, parquet.Double: |
| 486 | return cb(traceql.NewStaticFloat(v.Double())) |
| 487 | |
| 488 | case parquet.ByteArray, parquet.FixedLenByteArray: |
| 489 | return cb(traceql.NewStaticString(v.String())) |
| 490 | |
| 491 | default: |
| 492 | // Skip nils or unsupported type |
| 493 | return false |
| 494 | } |
| 495 | } |
| 496 | |
| 497 | func rowGroupsFromFile(pf *parquet.File, opts common.SearchOptions) []parquet.RowGroup { |
| 498 | rgs := pf.RowGroups() |
no test coverage detected