-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathknn.go
More file actions
61 lines (51 loc) · 1.13 KB
/
knn.go
File metadata and controls
61 lines (51 loc) · 1.13 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
package rtree
import (
"github.com/intdxdt/heap"
"github.com/intdxdt/mbr"
)
func predicate(_ *KObj) (bool, bool) {
return true, false
}
func (tree *RTree) Knn(
query mbr.MBR[float64], limit int, score func(*mbr.MBR[float64], *KObj) float64,
predicates ...func(*KObj) (bool, bool)) []BoxObject {
var predFn = predicate
if len(predicates) > 0 {
predFn = predicates[0]
}
var nd = &tree.Data
var result []BoxObject
var child *node
var stop, pred bool
var queue = heap.NewHeap(kobjCmp, heap.NewHeapType().AsMin())
for !stop && (nd != nil) {
for i := range nd.children {
child = &nd.children[i]
var o = &KObj{child, &child.bbox, len(child.children) == 0, -1}
o.Dist = score(&query, o)
queue.Push(o)
}
for !queue.IsEmpty() && queue.Peek().(*KObj).IsItem {
var candidate = queue.Pop().(*KObj)
pred, stop = predFn(candidate)
if pred {
result = append(result, candidate.GetItem())
}
if stop {
break
}
if limit != 0 && len(result) == limit {
return result
}
}
if !stop {
var q = queue.Pop()
if q == nil {
nd = nil
} else {
nd = q.(*KObj).node
}
}
}
return result
}