insert

Documentation

Index

• Constants
• func Call(idx int, proc *process.Process, arg any, _ bool, _ bool) (process.ExecStatus, error)
• func Prepare(proc *process.Process, arg any) error
• func String(_ any, buf *bytes.Buffer)
• type Argument
  • func (ap *Argument) AffectedRows() uint64
  • func (ap *Argument) Free(proc *process.Process, pipelineFailed bool, err error)
  • func (ap *Argument) GetAffectedRows() *uint64
• type InsertCtx

Constants

const (
	Process = iota
	End
)

Functions

func Call

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

first parameter: true represents whether the current pipeline has ended first parameter: false

func Prepare

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

func String

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

Types

type Argument

type Argument struct {
	ToWriteS3 bool // mark if this insert's target is S3 or not.
	InsertCtx *InsertCtx
	// contains filtered or unexported fields
}

func (*Argument) AffectedRows

func (ap *Argument) AffectedRows() uint64

func (*Argument) Free

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

The Argument for insert data directly to s3 can not be free when this function called as some datastructure still needed. therefore, those argument in remote CN will be free in connector operator, and local argument will be free in mergeBlock operator

func (*Argument) GetAffectedRows

func (ap *Argument) GetAffectedRows() *uint64

type InsertCtx

type InsertCtx struct {
	//insert data into Rel.
	Rel                   engine.Relation
	Ref                   *plan.ObjectRef
	AddAffectedRows       bool
	Attrs                 []string
	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
	TableDef              *plan.TableDef
}