Function
newCommonIterator
(meta *backend.BlockMeta, iter *MultiBlockIterator[parquet.Row], schema *parquet.Schema)
Source from the content-addressed store, hash-verified
| 1090 | } |
| 1091 | |
| 1092 | func newCommonIterator(meta *backend.BlockMeta, iter *MultiBlockIterator[parquet.Row], schema *parquet.Schema) *commonIterator { |
| 1093 | return &commonIterator{ |
| 1094 | meta: meta, |
| 1095 | iter: iter, |
| 1096 | schema: schema, |
| 1097 | } |
| 1098 | } |
| 1099 | |
| 1100 | func (i *commonIterator) Next(ctx context.Context) (common.ID, *tempopb.Trace, error) { |
| 1101 | id, row, err := i.iter.Next(ctx) |
Tested by
no test coverage detected