Documentation
¶
Index ¶
Constants ¶
View Source
const ( Process = iota End )
Variables ¶
This section is empty.
Functions ¶
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 ¶ added in v0.8.0
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
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
}
Click to show internal directories.
Click to hide internal directories.