deletion

package

v0.0.0-debug-20260702 Latest Latest Go to latest Published: Jul 2, 2026 License: Apache-2.0 Imports: 20 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/matrixorigin/matrixone

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func NewPartitionDelete(raw *Deletion, tableID uint64) vm.Operator
func NewPartitionDeleteFrom(ps *PartitionDelete) vm.Operator
func SetCNFlushDeletesThreshold(n int)
type BatchPool
type DeleteCtx
type Deletion
- func NewArgument() *Deletion
type PartitionDelete

Constants ¶

View Source

const (
	FlushDeltaLoc = iota

	DeletionOnTxnUnCommit
	DeletionOnCommitted
)

Variables ¶

This section is empty.

Functions ¶

func NewPartitionDelete ¶

func NewPartitionDelete(
	raw *Deletion,
	tableID uint64,
) vm.Operator

func NewPartitionDeleteFrom ¶

func NewPartitionDeleteFrom(
	ps *PartitionDelete,
) vm.Operator

func SetCNFlushDeletesThreshold ¶

func SetCNFlushDeletesThreshold(n int)

SetCNFlushDeletesThreshold update threshold to n MB

Types ¶

type BatchPool ¶ added in v0.8.0

type BatchPool struct {
	// contains filtered or unexported fields
}

type DeleteCtx ¶ added in v0.5.1

type DeleteCtx struct {
	CanTruncate     bool
	RowIdIdx        int // The array index position of the rowid column
	Ref             *plan.ObjectRef
	AddAffectedRows bool // for hidden table, should not update affect Rows
	PrimaryKeyIdx   int

	Engine engine.Engine
}

type Deletion ¶

type Deletion struct {
	DeleteCtx *DeleteCtx

	// for delete filter below
	// mp[segmentId] = 1 => txnWorkSpace,mp[segmentId] = 2 => CN Block
	SegmentMap   map[string]int32
	RemoteDelete bool
	IBucket      uint32
	Nbucket      uint32

	vm.OperatorBase
	// contains filtered or unexported fields
}

func NewArgument ¶ added in v1.2.0

func NewArgument() *Deletion

func (*Deletion) Call ¶

func (deletion *Deletion) Call(proc *process.Process) (vm.CallResult, error)

the bool return value means whether it completed its work or not

func (*Deletion) ExecProjection ¶

func (deletion *Deletion) ExecProjection(proc *process.Process, input *batch.Batch) (*batch.Batch, error)

func (*Deletion) Free ¶

func (deletion *Deletion) Free(proc *process.Process, pipelineFailed bool, err error)

delete from t1 using t1 join t2 on t1.a = t2.a;

func (*Deletion) GetAffectedRows ¶

func (deletion *Deletion) GetAffectedRows() uint64

func (*Deletion) GetOperatorBase ¶

func (deletion *Deletion) GetOperatorBase() *vm.OperatorBase

func (*Deletion) OpType ¶

func (deletion *Deletion) OpType() vm.OpType

func (*Deletion) Prepare ¶

func (deletion *Deletion) Prepare(proc *process.Process) error

func (*Deletion) Release ¶

func (deletion *Deletion) Release()

func (*Deletion) Reset ¶

func (deletion *Deletion) Reset(proc *process.Process, pipelineFailed bool, err error)

func (*Deletion) SplitBatch ¶

func (deletion *Deletion) SplitBatch(proc *process.Process, srcBat *batch.Batch, analyzer process.Analyzer) error

func (*Deletion) String ¶

func (deletion *Deletion) String(buf *bytes.Buffer)

func (Deletion) TypeName ¶

func (deletion Deletion) TypeName() string

type PartitionDelete ¶

type PartitionDelete struct {
	vm.OperatorBase
	// contains filtered or unexported fields
}

func (*PartitionDelete) Call ¶

func (op *PartitionDelete) Call(
	proc *process.Process,
) (vm.CallResult, error)

func (*PartitionDelete) ExecProjection ¶

func (op *PartitionDelete) ExecProjection(
	proc *process.Process,
	input *batch.Batch,
) (*batch.Batch, error)

func (*PartitionDelete) Free ¶

func (op *PartitionDelete) Free(
	proc *process.Process,
	pipelineFailed bool,
	err error,
)

func (*PartitionDelete) GetDelete ¶

func (op *PartitionDelete) GetDelete() *Deletion

func (*PartitionDelete) GetOperatorBase ¶

func (op *PartitionDelete) GetOperatorBase() *vm.OperatorBase

func (*PartitionDelete) OpType ¶

func (op *PartitionDelete) OpType() vm.OpType

func (*PartitionDelete) Prepare ¶

func (op *PartitionDelete) Prepare(
	proc *process.Process,
) error

func (*PartitionDelete) Release ¶

func (op *PartitionDelete) Release()

func (*PartitionDelete) Reset ¶

func (op *PartitionDelete) Reset(
	proc *process.Process,
	pipelineFailed bool,
	err error,
)

func (*PartitionDelete) String ¶

func (op *PartitionDelete) String(buf *bytes.Buffer)

Source Files ¶

View all Source files

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