(ctx context.Context)
| 253 | } |
| 254 | |
| 255 | func (w *walBlockFlush) rowIterator(ctx context.Context) (*rowIterator, error) { |
| 256 | file, err := w.file(ctx) |
| 257 | if err != nil { |
| 258 | return nil, err |
| 259 | } |
| 260 | |
| 261 | pf := file.parquetFile |
| 262 | |
| 263 | idx, _, _ := parquetquery.GetColumnIndexByPath(pf, TraceIDColumnName) |
| 264 | r := parquet.NewReader(pf) |
| 265 | return newRowIterator(r, file, w.ids.EntriesSortedByID(), idx), nil |
| 266 | } |
| 267 | |
| 268 | type pageFile struct { |
| 269 | parquetFile *parquet.File |