deletion

Documentation

Index

• Constants
• func Call(_ int, proc *process.Process, arg any, isFirst bool, isLast bool) (process.ExecStatus, error)
• func Prepare(_ *process.Process, arg any) error
• func String(arg any, buf *bytes.Buffer)
• type Argument
  • func (arg *Argument) AffectedRows() uint64
  • func (arg *Argument) Free(proc *process.Process, pipelineFailed bool, err error)
  • func (arg *Argument) SplitBatch(proc *process.Process, srcBat *batch.Batch) error
• type BatchPool
• type DeleteCtx

Constants

const (
	RawRowIdBatch = iota
	// remember that, for one block,
	// when it sends the info to mergedeletes,
	// either it's Compaction or not.
	Compaction
	CNBlockOffset
	RawBatchOffset
	FlushDeltaLoc
)

3. RawRowIdBatch : belong to txn's snapshot data. 4. FlushDeltaLoc : belong to txn's snapshot data, which on S3 and pointed by delta location.

Functions

func Call

func Call(_ int, proc *process.Process, arg any, isFirst bool, isLast bool) (process.ExecStatus, error)

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

func Prepare

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

func String

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

Types

type Argument

type Argument struct {
	Ts        uint64
	DeleteCtx *DeleteCtx

	// for delete filter below
	// mp[segmentName] = 1 => txnWorkSpace,mp[segmentName] = 2 => CN Block
	SegmentMap   map[string]int32
	RemoteDelete bool
	IBucket      uint32
	Nbucket      uint32
	// contains filtered or unexported fields
}

func (*Argument) AffectedRows

func (arg *Argument) AffectedRows() uint64

func (*Argument) Free

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

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

func (*Argument) SplitBatch

func (arg *Argument) SplitBatch(proc *process.Process, srcBat *batch.Batch) error

type BatchPool

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

type DeleteCtx

type DeleteCtx struct {
	CanTruncate           bool
	RowIdIdx              int               // The array index position of the rowid column
	PartitionTableIDs     []uint64          // Align array index with the partition number
	PartitionTableNames   []string          // Align array index with the partition number
	PartitionIndexInBatch int               // The array index position of the partition expression column
	PartitionSources      []engine.Relation // Align array index with the partition number
	Source                engine.Relation
	Ref                   *plan.ObjectRef
	AddAffectedRows       bool
	PrimaryKeyIdx         int
}