Documentation
¶
Index ¶
- Variables
- func CompileBufferFilter(zctx *zed.Context, e dag.Expr) (*expr.BufferFilter, error)
- func EvalAtCompileTime(zctx *zed.Context, arena *zed.Arena, in dag.Expr) (zed.Value, error)
- type Builder
- func (b *Builder) Build(seq dag.Seq, readers ...zio.Reader) ([]zbuf.Puller, error)
- func (b *Builder) BuildVamToSeqFilter(filter dag.Expr, poolID, commitID ksuid.KSUID) (zbuf.Puller, error)
- func (b *Builder) BuildWithPuller(seq dag.Seq, parent vector.Puller) ([]vector.Puller, error)
- func (b *Builder) Deletes() *sync.Map
- func (b *Builder) Meter() zbuf.Meter
- func (b *Builder) PushdownOf(e dag.Expr) *Filter
- type DeleteFilter
- type Filter
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrJoinParents = errors.New("join requires two upstream parallel query paths")
Functions ¶
func CompileBufferFilter ¶
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.
Types ¶
type Builder ¶
type Builder struct {
// contains filtered or unexported fields
}
func (*Builder) Build ¶
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 (*Builder) BuildWithPuller ¶ added in v1.14.0
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)
Source Files
¶
Click to show internal directories.
Click to hide internal directories.