insert

Documentation

Index

• 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) GetAffectedRows() *uint64
  • func (arg *Argument) GetOperatorBase() *vm.OperatorBase
  • func (arg *Argument) Prepare(proc *process.Process) error
  • func (arg *Argument) Release()
  • func (arg *Argument) String(buf *bytes.Buffer)
  • func (arg Argument) TypeName() string
• type InsertCtx

Types

type Argument

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

	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)

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

func (*Argument) Free

func (arg *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 (arg *Argument) GetAffectedRows() *uint64

func (*Argument) GetOperatorBase

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

func (*Argument) Prepare

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

func (*Argument) Release

func (arg *Argument) Release()

func (*Argument) String

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

func (Argument) TypeName

func (arg Argument) TypeName() string

type InsertCtx

type InsertCtx struct {
	// insert data into Rel.
	Rel                   engine.Relation
	Ref                   *plan.ObjectRef
	AddAffectedRows       bool // for hidden table, should not update affect Rows
	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
}