deletion

package
v0.7.0 Latest Latest
Warning

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

Go to latest
Published: Feb 18, 2023 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Call

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

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

func Prepare

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

func String

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

Types

type Argument

type Argument struct {
	Ts           uint64
	DeleteCtx    *DeleteCtx
	AffectedRows uint64
	Engine       engine.Engine
	// when detele data in a remote CN,
	// IsRemote is true, and we need IBucket
	// and NBucket to know those data in batch
	// that we need to delete in this CN, because
	// we need to make sure one Block will be processed
	// by only one CN, this is useful for our compaction
	IsRemote bool
	IBucket  uint64
	NBucket  uint64
}

func (*Argument) Free added in v0.6.0

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

type DeleteCtx added in v0.5.1

type DeleteCtx struct {
	CanTruncate bool

	DelSource []engine.Relation
	DelRef    []*plan.ObjectRef

	IdxSource []engine.Relation
	IdxIdx    []int32

	OnRestrictIdx []int32

	OnCascadeSource []engine.Relation
	OnCascadeIdx    []int32

	OnSetSource       []engine.Relation
	OnSetUniqueSource [][]engine.Relation
	OnSetIdx          [][]int32
	OnSetRef          []*plan.ObjectRef
	OnSetTableDef     []*plan.TableDef
	OnSetUpdateCol    []map[string]int32
}

Jump to

Keyboard shortcuts

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