(r parquet.Row)
| 64 | var _ RawIterator = (*rawIterator)(nil) |
| 65 | |
| 66 | func (i *rawIterator) getTraceID(r parquet.Row) common.ID { |
| 67 | for _, v := range r { |
| 68 | if v.Column() == i.traceIDIndex { |
| 69 | // Important - clone to get a detached copy that lives outside the pool. |
| 70 | return v.Clone().ByteArray() |
| 71 | } |
| 72 | } |
| 73 | return nil |
| 74 | } |
| 75 | |
| 76 | func (i *rawIterator) Next(context.Context) (common.ID, parquet.Row, error) { |
| 77 | rows := []parquet.Row{i.pool.Get()} |