Documentation
¶
Index ¶
- Constants
- type IntersectAll
- func (intersectAll *IntersectAll) Call(proc *process.Process) (vm.CallResult, error)
- func (intersectAll *IntersectAll) ExecProjection(proc *process.Process, input *batch.Batch) (*batch.Batch, error)
- func (intersectAll *IntersectAll) Free(proc *process.Process, pipelineFailed bool, err error)
- func (intersectAll *IntersectAll) GetOperatorBase() *vm.OperatorBase
- func (intersectAll *IntersectAll) OpType() vm.OpType
- func (intersectAll *IntersectAll) Prepare(proc *process.Process) error
- func (intersectAll *IntersectAll) Release()
- func (intersectAll *IntersectAll) Reset(proc *process.Process, pipelineFailed bool, err error)
- func (intersectAll *IntersectAll) String(buf *bytes.Buffer)
- func (intersectAll IntersectAll) TypeName() string
Constants ¶
View Source
const ( Build = iota Probe End )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type IntersectAll ¶
type IntersectAll struct {
vm.OperatorBase
// contains filtered or unexported fields
}
func NewArgument ¶ added in v1.2.0
func NewArgument() *IntersectAll
func (*IntersectAll) Call ¶
func (intersectAll *IntersectAll) Call(proc *process.Process) (vm.CallResult, error)
Call is the execute method of `intersect all` operator it built a hash table for right relation first. and use an array to record how many times each key appears in right relation. use values from left relation to probe and update the array. throw away values that do not exist in the hash table. preserve values that exist in the hash table (the minimum of the number of times that exist in either).
func (*IntersectAll) ExecProjection ¶
func (*IntersectAll) Free ¶
func (intersectAll *IntersectAll) Free(proc *process.Process, pipelineFailed bool, err error)
func (*IntersectAll) GetOperatorBase ¶
func (intersectAll *IntersectAll) GetOperatorBase() *vm.OperatorBase
func (*IntersectAll) OpType ¶
func (intersectAll *IntersectAll) OpType() vm.OpType
func (*IntersectAll) Prepare ¶
func (intersectAll *IntersectAll) Prepare(proc *process.Process) error
func (*IntersectAll) Release ¶
func (intersectAll *IntersectAll) Release()
func (*IntersectAll) Reset ¶
func (intersectAll *IntersectAll) Reset(proc *process.Process, pipelineFailed bool, err error)
func (*IntersectAll) String ¶
func (intersectAll *IntersectAll) String(buf *bytes.Buffer)
func (IntersectAll) TypeName ¶
func (intersectAll IntersectAll) TypeName() string
Source Files
Click to show internal directories.
Click to hide internal directories.