loopjoin

package
v0.0.0-debug-20260702 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 2, 2026 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source
const (
	Build = iota
	Probe
	Finalize
	End
)

Variables

This section is empty.

Functions

This section is empty.

Types

type LoopJoin

type LoopJoin struct {
	LeftTypes  []types.Type
	RightTypes []types.Type
	NonEqCond  *plan.Expr
	ResultCols []colexec.ResultPos
	JoinMapTag int32
	JoinType   plan.Node_JoinType
	MarkPos    int

	vm.OperatorBase
	// contains filtered or unexported fields
}

func NewArgument added in v1.2.0

func NewArgument() *LoopJoin

func (*LoopJoin) Call

func (loopJoin *LoopJoin) Call(proc *process.Process) (vm.CallResult, error)

func (*LoopJoin) ExecProjection

func (loopJoin *LoopJoin) ExecProjection(proc *process.Process, input *batch.Batch) (*batch.Batch, error)

func (*LoopJoin) Free

func (loopJoin *LoopJoin) Free(proc *process.Process, pipelineFailed bool, err error)

func (*LoopJoin) GetOperatorBase

func (loopJoin *LoopJoin) GetOperatorBase() *vm.OperatorBase

func (*LoopJoin) OpType

func (loopJoin *LoopJoin) OpType() vm.OpType

func (*LoopJoin) Prepare

func (loopJoin *LoopJoin) Prepare(proc *process.Process) error

func (*LoopJoin) Release

func (loopJoin *LoopJoin) Release()

func (*LoopJoin) Reset

func (loopJoin *LoopJoin) Reset(proc *process.Process, pipelineFailed bool, err error)

func (*LoopJoin) String

func (loopJoin *LoopJoin) String(buf *bytes.Buffer)

func (LoopJoin) TypeName

func (loopJoin LoopJoin) TypeName() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL