(chunk GenericChunk)
| 16 | } |
| 17 | |
| 18 | func (i *chunkIterator) reset(chunk GenericChunk) { |
| 19 | i.chunk = chunk |
| 20 | i.it = chunk.Iterator(i.it) |
| 21 | i.batch.Length = 0 |
| 22 | i.batch.Index = 0 |
| 23 | } |
| 24 | |
| 25 | func (i *chunkIterator) MaxCurrentChunkTime() int64 { |
| 26 | return i.chunk.MaxTime |