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