(ctx context.Context)
| 15 | ) |
| 16 | |
| 17 | func (b *backendBlock) open(ctx context.Context) (*parquet.File, *parquet.Reader, error) { //nolint:all //deprecated |
| 18 | rr := NewBackendReaderAt(ctx, b.r, DataFileName, b.meta) |
| 19 | |
| 20 | // 128 MB memory buffering |
| 21 | br := tempo_io.NewBufferedReaderAt(rr, int64(b.meta.Size_), 2*1024*1024, 64) |
| 22 | |
| 23 | o := []parquet.FileOption{ |
| 24 | parquet.SkipBloomFilters(true), |
| 25 | parquet.SkipPageIndex(true), |
| 26 | parquet.FileSchema(parquetSchema), |
| 27 | parquet.FileReadMode(parquet.ReadModeAsync), |
| 28 | } |
| 29 | |
| 30 | pf, err := parquet.OpenFile(br, int64(b.meta.Size_), o...) |
| 31 | if err != nil { |
| 32 | return nil, nil, err |
| 33 | } |
| 34 | |
| 35 | r := parquet.NewReader(pf, parquet.SchemaOf(&Trace{})) |
| 36 | return pf, r, nil |
| 37 | } |
| 38 | |
| 39 | func (b *backendBlock) rawIter(ctx context.Context, pool *rowPool) (*rawIterator, error) { |
| 40 | pf, r, err := b.open(ctx) |
no test coverage detected