Skip to content

Commit

Permalink
cmd/root2npy: use rtree.Reader
Browse files Browse the repository at this point in the history
  • Loading branch information
sbinet committed Jun 3, 2020
1 parent 6c0e8ee commit e2ffbc7
Showing 1 changed file with 11 additions and 10 deletions.
21 changes: 11 additions & 10 deletions cmd/root2npy/main.go
Expand Up @@ -191,18 +191,18 @@ func main() {
}
log.Printf("scanning leaves... [done]")

sc, err := rtree.NewTreeScannerVars(tree, nt.args...)
r, err := rtree.NewReader(tree, nt.args)
if err != nil {
log.Fatal(err)
}
defer sc.Close()
defer r.Close()

for sc.Next() {
err = sc.Scan(nt.vars...)
if err != nil {
log.Fatal(err)
}
err = r.Read(func(ctx rtree.RCtx) error {
nt.fill()
return nil
})
if err != nil {
log.Fatal(err)
}

out, err := os.Create(*oname)
Expand Down Expand Up @@ -253,15 +253,16 @@ type ntuple struct {
n int64
cols []column
args []rtree.ReadVar
vars []interface{}
}

func (nt *ntuple) add(name string, leaf rtree.Leaf) {
n := len(nt.cols)
nt.cols = append(nt.cols, newColumn(name, leaf, nt.n))
col := &nt.cols[n]
nt.args = append(nt.args, rtree.ReadVar{Name: name, Leaf: leaf.Name()})
nt.vars = append(nt.vars, col.data.Addr().Interface())
nt.args = append(nt.args, rtree.ReadVar{
Name: name, Leaf: leaf.Name(),
Value: col.data.Addr().Interface(),
})
}

func (nt *ntuple) fill() {
Expand Down

0 comments on commit e2ffbc7

Please sign in to comment.