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