(key []byte, p *pb.Posting, shard int)
| 292 | } |
| 293 | |
| 294 | func (m *mapper) addMapEntry(key []byte, p *pb.Posting, shard int) { |
| 295 | atomic.AddInt64(&m.prog.mapEdgeCount, 1) |
| 296 | |
| 297 | uid := p.Uid |
| 298 | if p.PostingType != pb.Posting_REF || len(p.Facets) > 0 { |
| 299 | // Keep p |
| 300 | } else { |
| 301 | // We only needed the UID. |
| 302 | p = nil |
| 303 | } |
| 304 | |
| 305 | sh := &m.shards[shard] |
| 306 | |
| 307 | sz := mapEntrySize(key, p) |
| 308 | dst := sh.cbuf.SliceAllocate(sz) |
| 309 | marshalMapEntry(dst, uid, key, p) |
| 310 | } |
| 311 | |
| 312 | func (m *mapper) processNQuad(nq dql.NQuad) { |
| 313 | if m.opt.Namespace != math.MaxUint64 { |
no test coverage detected