Documentation
¶
Index ¶
- type MergeDelete
- func (mergeDelete *MergeDelete) Call(proc *process.Process) (vm.CallResult, error)
- func (mergeDelete *MergeDelete) ExecProjection(proc *process.Process, input *batch.Batch) (*batch.Batch, error)
- func (mergeDelete *MergeDelete) Free(proc *process.Process, pipelineFailed bool, err error)
- func (mergeDelete *MergeDelete) GetAffectedRows() uint64
- func (mergeDelete *MergeDelete) GetOperatorBase() *vm.OperatorBase
- func (mergeDelete *MergeDelete) OpType() vm.OpType
- func (mergeDelete *MergeDelete) Prepare(proc *process.Process) error
- func (mergeDelete *MergeDelete) Release()
- func (mergeDelete *MergeDelete) Reset(proc *process.Process, pipelineFailed bool, err error)
- func (mergeDelete *MergeDelete) String(buf *bytes.Buffer)
- func (mergeDelete MergeDelete) TypeName() string
- func (mergeDelete *MergeDelete) WithAddAffectedRows(addAffectedRows bool) *MergeDelete
- func (mergeDelete *MergeDelete) WithEngine(eng engine.Engine) *MergeDelete
- func (mergeDelete *MergeDelete) WithObjectRef(ref *plan.ObjectRef) *MergeDelete
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MergeDelete ¶
type MergeDelete struct {
AddAffectedRows bool
Ref *plan.ObjectRef
Engine engine.Engine
vm.OperatorBase
// contains filtered or unexported fields
}
func NewArgument ¶ added in v1.2.0
func NewArgument() *MergeDelete
func (*MergeDelete) Call ¶
func (mergeDelete *MergeDelete) Call(proc *process.Process) (vm.CallResult, error)
func (*MergeDelete) ExecProjection ¶
func (*MergeDelete) Free ¶
func (mergeDelete *MergeDelete) Free(proc *process.Process, pipelineFailed bool, err error)
func (*MergeDelete) GetAffectedRows ¶
func (mergeDelete *MergeDelete) GetAffectedRows() uint64
func (*MergeDelete) GetOperatorBase ¶
func (mergeDelete *MergeDelete) GetOperatorBase() *vm.OperatorBase
func (*MergeDelete) OpType ¶
func (mergeDelete *MergeDelete) OpType() vm.OpType
func (*MergeDelete) Release ¶
func (mergeDelete *MergeDelete) Release()
func (*MergeDelete) Reset ¶
func (mergeDelete *MergeDelete) Reset(proc *process.Process, pipelineFailed bool, err error)
func (*MergeDelete) String ¶
func (mergeDelete *MergeDelete) String(buf *bytes.Buffer)
func (MergeDelete) TypeName ¶
func (mergeDelete MergeDelete) TypeName() string
func (*MergeDelete) WithAddAffectedRows ¶
func (mergeDelete *MergeDelete) WithAddAffectedRows(addAffectedRows bool) *MergeDelete
func (*MergeDelete) WithEngine ¶
func (mergeDelete *MergeDelete) WithEngine(eng engine.Engine) *MergeDelete
func (*MergeDelete) WithObjectRef ¶
func (mergeDelete *MergeDelete) WithObjectRef(ref *plan.ObjectRef) *MergeDelete
Source Files
Click to show internal directories.
Click to hide internal directories.