gibheer
/
bleve
0
0
Fork 0
Code

need to copy the doc ID for it to survive past next iteration

This commit is contained in:
Marty Schoch 2016-08-01 17:01:04 -04:00
parent e188fe35f7
commit 172ca7e69e
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
index/upside_down/reader.go
View File

@ -83,7 +83,7 @@ func (r *UpsideDownCouchTermFieldReader) Next(preAlloced *index.TermFieldDoc) (*
if rv == nil {
rv = &index.TermFieldDoc{}
}
rv.ID = tfr.doc
rv.ID = append([]byte(nil), tfr.doc...)
rv.Freq = tfr.freq
rv.Norm = float64(tfr.norm)
if tfr.vectors != nil {
@ -110,7 +110,7 @@ func (r *UpsideDownCouchTermFieldReader) Advance(docID index.IndexInternalID, pr
if rv == nil {
rv = &index.TermFieldDoc{}
}
rv.ID = tfr.doc
rv.ID = append([]byte(nil), tfr.doc...)
rv.Freq = tfr.freq
rv.Norm = float64(tfr.norm)
if tfr.vectors != nil {
@ -199,7 +199,7 @@ func (r *UpsideDownCouchDocIDReader) Next() (index.IndexInternalID, error) {
key, val, valid = r.iterator.Current()
continue
} else {
rv = br.doc
rv = append([]byte(nil), br.doc...)
break
}
}
@ -217,7 +217,7 @@ func (r *UpsideDownCouchDocIDReader) Next() (index.IndexInternalID, error) {
if err != nil {
return nil, err
}
rv := br.doc
rv := append([]byte(nil), br.doc...)
r.iterator.Next()
return rv, nil
}
@ -246,7 +246,7 @@ func (r *UpsideDownCouchDocIDReader) Advance(docID index.IndexInternalID) (index
r.iterator.Seek(NewBackIndexRow([]byte(r.only[r.onlyPos]), nil, nil).Key())
continue
} else {
rv = br.doc
rv = append([]byte(nil), br.doc...)
break
}
}
@ -263,7 +263,7 @@ func (r *UpsideDownCouchDocIDReader) Advance(docID index.IndexInternalID) (index
if err != nil {
return nil, err
}
rv := br.doc
rv := append([]byte(nil), br.doc...)
r.iterator.Next()
return rv, nil
}