(ctx context.Context)
| 1049 | } |
| 1050 | |
| 1051 | func (i *commonIterator) Next(ctx context.Context) (common.ID, *tempopb.Trace, error) { |
| 1052 | id, row, err := i.iter.Next(ctx) |
| 1053 | if err != nil && !errors.Is(err, io.EOF) { |
| 1054 | return nil, nil, err |
| 1055 | } |
| 1056 | |
| 1057 | if row == nil || errors.Is(err, io.EOF) { |
| 1058 | return nil, nil, nil |
| 1059 | } |
| 1060 | |
| 1061 | t := &Trace{} |
| 1062 | err = i.schema.Reconstruct(t, row) |
| 1063 | if err != nil { |
| 1064 | return nil, nil, err |
| 1065 | } |
| 1066 | |
| 1067 | tr := ParquetTraceToTempopbTrace(i.meta, t) |
| 1068 | return id, tr, nil |
| 1069 | } |
| 1070 | |
| 1071 | func (i *commonIterator) NextRow(ctx context.Context) (common.ID, parquet.Row, error) { |
| 1072 | return i.iter.Next(ctx) |
nothing calls this directly
no test coverage detected