vam

package

v1.12.0 Latest Latest Go to latest Published: Dec 20, 2023 License: BSD-3-Clause Imports: 16 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/brimdata/zed

Links

Open Source Insights

Documentation ¶

Index ¶

func NewMaterializer(p Puller) zbuf.Puller
type CountByString
- func NewCountByString(zctx *zed.Context, parent Puller, name string) *CountByString
- func (c *CountByString) Pull(done bool) (zbuf.Batch, error)
- func (*CountByString) PullVec(_ bool) (vector.Any, error)
type Index
- func (i Index) And(with Index) Index
- func (i Index) Or(with Index) Index
type Projection
- func NewProjection(o *vcache.Object, names []string) (*Projection, error)
- func (p *Projection) Read() (*zed.Value, error)
type Puller
- func NewDematerializer(p zbuf.Puller) Puller
type Sum
- func NewSum(zctx *zed.Context, parent Puller, name string) *Sum
- func (c *Sum) Pull(done bool) (zbuf.Batch, error)
- func (*Sum) PullVec(_ bool) (vector.Any, error)
type VecScanner
- func NewVecScanner(octx *op.Context, cache *vcache.Cache, parent zbuf.Puller, pool *lake.Pool, ...) *VecScanner
- func (v *VecScanner) Pull(done bool) (zbuf.Batch, error)
- func (v *VecScanner) PullVec(done bool) (vector.Any, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewMaterializer ¶

func NewMaterializer(p Puller) zbuf.Puller

Types ¶

type CountByString ¶

type CountByString struct {
	// contains filtered or unexported fields
}

func NewCountByString ¶

func NewCountByString(zctx *zed.Context, parent Puller, name string) *CountByString

func (*CountByString) Pull ¶

func (c *CountByString) Pull(done bool) (zbuf.Batch, error)

func (*CountByString) PullVec ¶

func (*CountByString) PullVec(_ bool) (vector.Any, error)

type Index ¶

type Index []int32

XXX for now this is a list of slots, but it probably should be a roaring bitmap

func (Index) And ¶

func (i Index) And(with Index) Index

func (Index) Or ¶

func (i Index) Or(with Index) Index

type Projection ¶

type Projection struct {
	// contains filtered or unexported fields
}

func NewProjection ¶

func NewProjection(o *vcache.Object, names []string) (*Projection, error)

func (*Projection) Read ¶

func (p *Projection) Read() (*zed.Value, error)

XXX Let's use Pull() here... read whole column into Batch for better perf

type Puller ¶

type Puller interface {
	PullVec(done bool) (vector.Any, error)
}

func NewDematerializer ¶

func NewDematerializer(p zbuf.Puller) Puller

type Sum ¶

type Sum struct {
	// contains filtered or unexported fields
}

func NewSum ¶

func NewSum(zctx *zed.Context, parent Puller, name string) *Sum

func (*Sum) Pull ¶

func (c *Sum) Pull(done bool) (zbuf.Batch, error)

func (*Sum) PullVec ¶

func (*Sum) PullVec(_ bool) (vector.Any, error)

type VecScanner ¶

type VecScanner struct {
	// contains filtered or unexported fields
}

func NewVecScanner ¶

func NewVecScanner(octx *op.Context, cache *vcache.Cache, parent zbuf.Puller, pool *lake.Pool, paths []field.Path, pruner expr.Evaluator, progress *zbuf.Progress) *VecScanner

func (*VecScanner) Pull ¶

func (v *VecScanner) Pull(done bool) (zbuf.Batch, error)

XXX this is here for the compiler to be ablet o create it as a zbuf.Puller, but we will fix the compiler to understand vops and vam/vector.Puller soon.

func (*VecScanner) PullVec ¶

func (v *VecScanner) PullVec(done bool) (vector.Any, error)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL