(_ context.Context)
| 138 | } |
| 139 | |
| 140 | func (i *parquetIterator4) Next(_ context.Context) (common.ID, *tempopb.Trace, error) { |
| 141 | traces := []*vparquet4.Trace{{}} |
| 142 | |
| 143 | i.i++ |
| 144 | if i.i%1000 == 0 { |
| 145 | fmt.Println(i.i) |
| 146 | } |
| 147 | |
| 148 | _, err := i.r.Read(traces) |
| 149 | if errors.Is(err, io.EOF) { |
| 150 | return nil, nil, io.EOF |
| 151 | } |
| 152 | if err != nil { |
| 153 | return nil, nil, err |
| 154 | } |
| 155 | |
| 156 | pqTrace := traces[0] |
| 157 | pbTrace := vparquet4.ParquetTraceToTempopbTrace(i.m, pqTrace) |
| 158 | return pqTrace.TraceID, pbTrace, nil |
| 159 | } |
| 160 | |
| 161 | func (i *parquetIterator4) Close() { |
| 162 | _ = i.r.Close() |
nothing calls this directly
no test coverage detected