intersectall

Documentation

Index

• Constants
• func Call(idx int, proc *process.Process, argument any, isFirst bool, isLast bool) (process.ExecStatus, error)
• func Prepare(proc *process.Process, arg any) error
• func String(_ any, buf *bytes.Buffer)
• type Argument
  • func (arg *Argument) Free(proc *process.Process, pipelineFailed bool, err error)

Constants

const (
	Build = iota
	Probe
	End
)

Functions

func Call

func Call(idx int, proc *process.Process, argument any, isFirst bool, isLast bool) (process.ExecStatus, 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 Prepare

func Prepare(proc *process.Process, arg any) error

func String

func String(_ any, buf *bytes.Buffer)

Types

type Argument

type Argument struct {

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

func (*Argument) Free

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