fixed comments; removed create fragment

This commit is contained in:
Todd Gruben 2020-01-07 10:39:56 -06:00
parent 75e017cf4f
commit d843959904
2 changed files with 4 additions and 4 deletions

View file

@ -3031,7 +3031,7 @@ func (e *executor) executeSetValueField(ctx context.Context, index string, c *pq
return ret, nil
}
// executeSetValueField removes value for colID if present
// executeClearValueField removes value for colID if present
func (e *executor) executeClearValueField(ctx context.Context, index string, c *pql.Call, f *Field, colID uint64, opt *execOptions) (bool, error) {
span, ctx := tracing.StartSpanFromContext(ctx, "Executor.executeClearValueField")
defer span.Finish()

View file

@ -408,9 +408,9 @@ func (v *view) setValue(columnID uint64, bitDepth uint, value int64) (changed bo
// clearValue removes a specific value assigned to columnID
func (v *view) clearValue(columnID uint64, bitDepth uint, value int64) (changed bool, err error) {
shard := columnID / ShardWidth
frag, err := v.CreateFragmentIfNotExists(shard)
if err != nil {
return changed, err
frag := v.Fragment(shard)
if frag == nil {
return false, nil
}
return frag.clearValue(columnID, bitDepth, value)
}