(lhs, rhs MapEntry)
| 125 | } |
| 126 | |
| 127 | func less(lhs, rhs MapEntry) bool { |
| 128 | if keyCmp := bytes.Compare(lhs.Key(), rhs.Key()); keyCmp != 0 { |
| 129 | return keyCmp < 0 |
| 130 | } |
| 131 | return lhs.Uid() < rhs.Uid() |
| 132 | } |
| 133 | |
| 134 | func (m *mapper) openOutputFile(shardIdx int) (*os.File, error) { |
| 135 | fileNum := atomic.AddUint32(&m.mapFileId, 1) |
no test coverage detected