intersectall

Documentation

Index

• Constants
• type Argument
  • func (arg *Argument) AppendChild(child vm.Operator)
  • func (arg *Argument) Call(proc *process.Process) (vm.CallResult, error)
  • func (arg *Argument) Free(proc *process.Process, pipelineFailed bool, err error)
  • func (arg *Argument) Prepare(proc *process.Process) error
  • func (arg *Argument) SetInfo(info *vm.OperatorInfo)
  • func (arg *Argument) String(buf *bytes.Buffer)

Constants

const (
	Build = iota
	Probe
	End
)

Types

type Argument

type Argument struct {

	// index in buckets
	IBucket uint64
	// buckets count
	NBucket uint64
	// contains filtered or unexported fields
}

func (*Argument) AppendChild

func (arg *Argument) AppendChild(child vm.Operator)

func (*Argument) Call

func (arg *Argument) 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 (*Argument) Free

func (arg *Argument) Free(proc *process.Process, pipelineFailed bool, err error)

func (*Argument) Prepare

func (arg *Argument) Prepare(proc *process.Process) error

func (*Argument) SetInfo

func (arg *Argument) SetInfo(info *vm.OperatorInfo)

func (*Argument) String

func (arg *Argument) String(buf *bytes.Buffer)