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

rename RowIDs methods to Rows

Browse source
This commit is contained in:
Matt Jaffee 2018-09-26 16:03:26 -05:00
parent 86d238edb0
commit 4face45c2a
No known key found for this signature in database
GPG key ID: 08A3DFFF987B11BF
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

@ -198,7 +198,7 @@ func (e *executor) executeCall(ctx context.Context, index string, c *pql.Call, s
return e.executeTopN(ctx, index, c, shards, opt)
case "RowIDs":
e.Holder.Stats.CountWithCustomTags(c.Name, 1, 1.0, []string{indexTag})
return e.executeRowIDs(ctx, index, c, shards, opt)
return e.executeRows(ctx, index, c, shards, opt)
case "GroupBy":
e.Holder.Stats.CountWithCustomTags(c.Name, 1, 1.0, []string{indexTag})
return e.executeGroupBy(ctx, index, c, shards, opt)
@ -950,10 +950,10 @@ func product(input [][]gbi) []ppi {
return res
}
func (e *executor) executeRowIDs(ctx context.Context, index string, c *pql.Call, shards []uint64, opt *execOptions) (RowIDs, error) {
func (e *executor) executeRows(ctx context.Context, index string, c *pql.Call, shards []uint64, opt *execOptions) (RowIDs, error) {
// Execute calls in bulk on each remote node and merge.
mapFn := func(shard uint64) (interface{}, error) {
return e.executeRowIDsShard(ctx, index, c, shard)
return e.executeRowsShard(ctx, index, c, shard)
}
// Merge returned results at coordinating node.
reduceFn := func(prev, v interface{}) interface{} {
@ -985,7 +985,7 @@ func (e *executor) executeRowIDs(ctx context.Context, index string, c *pql.Call,
return results, nil
}
func (e *executor) executeRowIDsShard(ctx context.Context, index string, c *pql.Call, shard uint64) (RowIDs, error) {
func (e *executor) executeRowsShard(ctx context.Context, index string, c *pql.Call, shard uint64) (RowIDs, error) {
// Fetch index.
idx := e.Holder.Index(index)
if idx == nil {