(ctx context.Context)
| 245 | } |
| 246 | |
| 247 | func (w *walBlockFlush) rowIterator(ctx context.Context) (*rowIterator, error) { |
| 248 | file, err := w.file(ctx) |
| 249 | if err != nil { |
| 250 | return nil, err |
| 251 | } |
| 252 | |
| 253 | pf := file.parquetFile |
| 254 | |
| 255 | idx, _, _ := parquetquery.GetColumnIndexByPath(pf, TraceIDColumnName) |
| 256 | r := parquet.NewReader(pf) |
| 257 | return newRowIterator(r, file, w.ids.EntriesSortedByID(), idx), nil |
| 258 | } |
| 259 | |
| 260 | type pageFile struct { |
| 261 | parquetFile *parquet.File |