(cb common.TagValuesCallbackV2, v parquet.Value)
| 460 | } |
| 461 | |
| 462 | func callback(cb common.TagValuesCallbackV2, v parquet.Value) (stop bool) { |
| 463 | switch v.Kind() { |
| 464 | |
| 465 | case parquet.Boolean: |
| 466 | return cb(traceql.NewStaticBool(v.Boolean())) |
| 467 | |
| 468 | case parquet.Int32, parquet.Int64: |
| 469 | return cb(traceql.NewStaticInt(int(v.Int64()))) |
| 470 | |
| 471 | case parquet.Float, parquet.Double: |
| 472 | return cb(traceql.NewStaticFloat(v.Double())) |
| 473 | |
| 474 | case parquet.ByteArray, parquet.FixedLenByteArray: |
| 475 | return cb(traceql.NewStaticString(v.String())) |
| 476 | |
| 477 | default: |
| 478 | // Skip nils or unsupported type |
| 479 | return false |
| 480 | } |
| 481 | } |
| 482 | |
| 483 | func rowGroupsFromFile(pf *parquet.File, opts common.SearchOptions) []parquet.RowGroup { |
| 484 | rgs := pf.RowGroups() |
no test coverage detected