filter

Documentation

Index

• type Filter
  • func NewArgument() *Filter
  • func (filter *Filter) Call(proc *process.Process) (vm.CallResult, error)
  • func (filter *Filter) ExecProjection(proc *process.Process, input *batch.Batch) (*batch.Batch, error)
  • func (filter *Filter) Free(proc *process.Process, pipelineFailed bool, err error)
  • func (filter *Filter) GetOperatorBase() *vm.OperatorBase
  • func (filter *Filter) OpType() vm.OpType
  • func (filter *Filter) Prepare(proc *process.Process) (err error)
  • func (filter *Filter) Release()
  • func (filter *Filter) Reset(proc *process.Process, pipelineFailed bool, err error)
  • func (filter *Filter) SetRuntimeFilterExprs(proc *process.Process, exes []*plan.Expr) (err error)
  • func (filter *Filter) String(buf *bytes.Buffer)
  • func (filter Filter) TypeName() string

Types

type Filter

type Filter struct {
	FilterExprs        []*plan.Expr
	RuntimeFilterExprs []*plan.Expr
	IsEnd              bool

	vm.OperatorBase
	// contains filtered or unexported fields
}

func NewArgument

func NewArgument() *Filter

func (*Filter) Call

func (filter *Filter) Call(proc *process.Process) (vm.CallResult, error)

func (*Filter) ExecProjection

func (filter *Filter) ExecProjection(proc *process.Process, input *batch.Batch) (*batch.Batch, error)

func (*Filter) Free

func (filter *Filter) Free(proc *process.Process, pipelineFailed bool, err error)

func (*Filter) GetOperatorBase

func (filter *Filter) GetOperatorBase() *vm.OperatorBase

func (*Filter) OpType

func (filter *Filter) OpType() vm.OpType

func (*Filter) Prepare

func (filter *Filter) Prepare(proc *process.Process) (err error)

func (*Filter) Release

func (filter *Filter) Release()

func (*Filter) Reset

func (filter *Filter) Reset(proc *process.Process, pipelineFailed bool, err error)

func (*Filter) SetRuntimeFilterExprs

func (filter *Filter) SetRuntimeFilterExprs(proc *process.Process, exes []*plan.Expr) (err error)

func (*Filter) String

func (filter *Filter) String(buf *bytes.Buffer)

func (Filter) TypeName

func (filter Filter) TypeName() string