scriptoriumadmin/featurebase
1
0
Fork 0
mirror of https://github.com/featurebasedb/featurebase.git synced 2026-08-28 10:54:59 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

adjusted first phase topn to collect all slices id's

Browse source
This commit is contained in:
Todd Gruben 2017-02-27 19:34:33 -06:00
parent 3b309d0d51
commit 5ef4d6fa6b
1 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
executor.go
View file

@ -199,7 +199,7 @@ func (e *Executor) executeTopN(ctx context.Context, db string, c *pql.Call, slic
}
func (e *Executor) executeTopNSlices(ctx context.Context, db string, c *pql.Call, slices []uint64, opt *ExecOptions) ([]Pair, error) {
n, _ := c.Args["n"].(uint64)
//n, _ := c.Args["n"].(uint64)
// Execute calls in bulk on each remote node and merge.
mapFn := func(slice uint64) (interface{}, error) {
@ -222,9 +222,9 @@ func (e *Executor) executeTopNSlices(ctx context.Context, db string, c *pql.Call
sort.Sort(Pairs(results))
// Only keep the top n after sorting.
if n > 0 && len(results) > int(n) {
results = results[0:n]
}
// if n > 0 && len(results) > int(n) {
// results = results[0:n]
//}
return results, nil
}