Documentation
¶
Index ¶
- type 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 ¶ added in v1.2.0
func NewArgument() *Argument
func (*Argument) AffectedRows ¶ added in v0.8.0
func (*Argument) Call ¶ added in v1.1.0
first parameter: true represents whether the current pipeline has ended first parameter: false
func (*Argument) Free ¶ added in v0.6.0
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 ¶ added in v0.8.0
func (*Argument) GetOperatorBase ¶ added in v1.2.0
func (arg *Argument) GetOperatorBase() *vm.OperatorBase
type InsertCtx ¶ added in v0.7.0
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
}
Source Files
Click to show internal directories.
Click to hide internal directories.