deletion

Documentation

Index

• Constants
• type Argument
  • func NewArgument() *Argument
  • func (arg *Argument) AffectedRows() uint64
  • func (arg *Argument) Call(proc *process.Process) (vm.CallResult, error)
  • func (arg *Argument) Free(proc *process.Process, pipelineFailed bool, err error)
  • func (arg *Argument) GetOperatorBase() *vm.OperatorBase
  • func (arg *Argument) Prepare(_ *process.Process) error
  • func (arg *Argument) Release()
  • func (arg *Argument) SplitBatch(proc *process.Process, srcBat *batch.Batch) error
  • func (arg *Argument) String(buf *bytes.Buffer)
  • func (arg Argument) TypeName() string
• 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.

Types

type Argument

type Argument 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

func NewArgument() *Argument

func (*Argument) AffectedRows

func (arg *Argument) AffectedRows() uint64

func (*Argument) Call

func (arg *Argument) Call(proc *process.Process) (vm.CallResult, error)

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

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) GetOperatorBase

func (arg *Argument) GetOperatorBase() *vm.OperatorBase

func (*Argument) Prepare

func (arg *Argument) Prepare(_ *process.Process) error

func (*Argument) Release

func (arg *Argument) Release()

func (*Argument) SplitBatch

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

func (*Argument) String

func (arg *Argument) String(buf *bytes.Buffer)

func (Argument) TypeName

func (arg Argument) TypeName() string

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
}