kernel

package

v1.15.0 Latest Latest Go to latest Published: Mar 29, 2024 License: BSD-3-Clause Imports: 47 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/brimdata/zed

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func CompileBufferFilter(zctx *zed.Context, e dag.Expr) (*expr.BufferFilter, error)
func EvalAtCompileTime(zctx *zed.Context, in dag.Expr) (val zed.Value, err error)
type Builder
- func NewBuilder(rctx *runtime.Context, source *data.Source) *Builder
type DeleteFilter
- func (f *DeleteFilter) AsBufferFilter() (*expr.BufferFilter, error)
- func (f *DeleteFilter) AsEvaluator() (expr.Evaluator, error)
type Filter
- func (f *Filter) AsBufferFilter() (*expr.BufferFilter, error)
- func (f *Filter) AsEvaluator() (expr.Evaluator, error)

Constants ¶

This section is empty.

Variables ¶

View Source

var ErrJoinParents = errors.New("join requires two upstream parallel query paths")

Functions ¶

func CompileBufferFilter ¶

func CompileBufferFilter(zctx *zed.Context, e dag.Expr) (*expr.BufferFilter, error)

CompileBufferFilter tries to return a BufferFilter for e such that the BufferFilter's Eval method returns true for any byte slice containing the ZNG encoding of a record matching e. (It may also return true for some byte slices that do not match.) compileBufferFilter returns a nil pointer and nil error if it cannot construct a useful filter.

func EvalAtCompileTime ¶ added in v1.0.0

func EvalAtCompileTime(zctx *zed.Context, in dag.Expr) (val zed.Value, err error)

Types ¶

type Builder ¶

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

func NewBuilder ¶

func NewBuilder(rctx *runtime.Context, source *data.Source) *Builder

func (*Builder) Build ¶

func (b *Builder) Build(seq dag.Seq, readers ...zio.Reader) ([]zbuf.Puller, error)

Build builds a flowgraph for seq. If seq contains a dag.DefaultSource, it will read from readers.

func (*Builder) BuildVamToSeqFilter ¶ added in v1.15.0

func (b *Builder) BuildVamToSeqFilter(filter dag.Expr, poolID, commitID ksuid.KSUID) (zbuf.Puller, error)

func (*Builder) BuildWithPuller ¶ added in v1.14.0

func (b *Builder) BuildWithPuller(seq dag.Seq, parent vector.Puller) ([]vector.Puller, error)

func (*Builder) Deletes ¶ added in v1.3.0

func (b *Builder) Deletes() *sync.Map

func (*Builder) Meter ¶ added in v1.3.0

func (b *Builder) Meter() zbuf.Meter

func (*Builder) PushdownOf ¶

func (b *Builder) PushdownOf(e dag.Expr) *Filter

type DeleteFilter ¶ added in v1.3.0

type DeleteFilter struct {
	*Filter
}

func (*DeleteFilter) AsBufferFilter ¶ added in v1.3.0

func (f *DeleteFilter) AsBufferFilter() (*expr.BufferFilter, error)

func (*DeleteFilter) AsEvaluator ¶ added in v1.3.0

func (f *DeleteFilter) AsEvaluator() (expr.Evaluator, error)

type Filter ¶

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

func (*Filter) AsBufferFilter ¶

func (f *Filter) AsBufferFilter() (*expr.BufferFilter, error)

func (*Filter) AsEvaluator ¶ added in v1.0.0

func (f *Filter) AsEvaluator() (expr.Evaluator, error)

Source Files ¶

View all Source files

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