mirror of
https://github.com/featurebasedb/featurebase.git
synced 2026-08-28 02:44:59 +00:00
Unexport Row.Intersect
This commit is contained in:
parent
edf87473ee
commit
3025586378
3 changed files with 9 additions and 9 deletions
|
|
@ -712,7 +712,7 @@ func (e *executor) executeIntersectShard(ctx context.Context, index string, c *p
|
|||
if i == 0 {
|
||||
other = row
|
||||
} else {
|
||||
other = other.Intersect(row)
|
||||
other = other.intersect(row)
|
||||
}
|
||||
}
|
||||
other.InvalidateCount()
|
||||
|
|
|
|||
12
fragment.go
12
fragment.go
|
|
@ -598,7 +598,7 @@ func (f *fragment) min(filter *Row, bitDepth uint) (min, count uint64, err error
|
|||
|
||||
consider := f.row(uint64(bitDepth))
|
||||
if filter != nil {
|
||||
consider = consider.Intersect(filter)
|
||||
consider = consider.intersect(filter)
|
||||
}
|
||||
|
||||
// If there are no columns to consider, return early.
|
||||
|
|
@ -631,7 +631,7 @@ func (f *fragment) max(filter *Row, bitDepth uint) (max, count uint64, err error
|
|||
|
||||
consider := f.row(uint64(bitDepth))
|
||||
if filter != nil {
|
||||
consider = consider.Intersect(filter)
|
||||
consider = consider.intersect(filter)
|
||||
}
|
||||
|
||||
// If there are no columns to consider, return early.
|
||||
|
|
@ -643,7 +643,7 @@ func (f *fragment) max(filter *Row, bitDepth uint) (max, count uint64, err error
|
|||
ii := i - 1 // allow for uint range: (bitDepth-1) to 0
|
||||
row := f.row(uint64(ii))
|
||||
|
||||
x := row.Intersect(consider)
|
||||
x := row.intersect(consider)
|
||||
count = x.Count()
|
||||
if count > 0 {
|
||||
max += (1 << ii)
|
||||
|
|
@ -682,7 +682,7 @@ func (f *fragment) rangeEQ(bitDepth uint, predicate uint64) (*Row, error) {
|
|||
bit := (predicate >> uint(i)) & 1
|
||||
|
||||
if bit == 1 {
|
||||
b = b.Intersect(row)
|
||||
b = b.intersect(row)
|
||||
} else {
|
||||
b = b.Difference(row)
|
||||
}
|
||||
|
|
@ -783,7 +783,7 @@ func (f *fragment) rangeGT(bitDepth uint, predicate uint64, allowEquality bool)
|
|||
// If bit is unset then add columns with set bit to keep.
|
||||
// Don't bother to compute this on the final iteration.
|
||||
if i > 0 {
|
||||
keep = keep.Union(b.Intersect(row))
|
||||
keep = keep.Union(b.intersect(row))
|
||||
}
|
||||
}
|
||||
|
||||
|
|
@ -815,7 +815,7 @@ func (f *fragment) rangeBetween(bitDepth uint, predicateMin, predicateMax uint64
|
|||
// If bit is unset then add columns with set bit to keep.
|
||||
// Don't bother to compute this on the final iteration.
|
||||
if i > 0 {
|
||||
keep1 = keep1.Union(b.Intersect(row))
|
||||
keep1 = keep1.Union(b.intersect(row))
|
||||
}
|
||||
}
|
||||
|
||||
|
|
|
|||
4
row.go
4
row.go
|
|
@ -82,8 +82,8 @@ func (r *Row) IntersectionCount(other *Row) uint64 {
|
|||
return n
|
||||
}
|
||||
|
||||
// Intersect returns the itersection of r and other.
|
||||
func (r *Row) Intersect(other *Row) *Row {
|
||||
// intersect returns the itersection of r and other.
|
||||
func (r *Row) intersect(other *Row) *Row {
|
||||
var segments []RowSegment
|
||||
|
||||
itr := newMergeSegmentIterator(r.segments, other.segments)
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue