kernel

package

v1.5.0 Latest Latest Go to latest Published: Jan 30, 2023 License: BSD-3-Clause Imports: 37 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 ¶

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(pctx *op.Context, source *data.Source) *Builder
type DeleteFilter
- func (f *DeleteFilter) AsBufferFilter() (*expr.BufferFilter, error)
- func (f *DeleteFilter) AsEvaluator() (expr.Evaluator, error)
type Filter
type Reader
- func (*Reader) Source()

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(pctx *op.Context, source *data.Source) *Builder

func (*Builder) Build ¶

func (b *Builder) Build(seq *dag.Sequential) ([]zbuf.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(trunk *dag.Trunk) (*Filter, error)

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)

func (*Filter) AsKeyCroppedByFilter ¶ added in v1.3.0

func (f *Filter) AsKeyCroppedByFilter(key field.Path, o order.Which) (*expr.SpanFilter, error)

func (*Filter) AsKeySpanFilter ¶ added in v1.3.0

func (f *Filter) AsKeySpanFilter(key field.Path, o order.Which) (*expr.SpanFilter, error)

func (*Filter) Pushdown ¶ added in v1.1.0

func (f *Filter) Pushdown() dag.Expr

type Reader ¶

type Reader struct {
	Layout  order.Layout
	Readers []zio.Reader
}

func (*Reader) Source ¶

func (*Reader) Source()

Source Files ¶

View all Source files

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