Documentation
¶
Index ¶
- func NewPartitionInsert(raw *Insert, tableID uint64) vm.Operator
- func NewPartitionInsertFrom(ps *PartitionInsert) vm.Operator
- type Insert
- func (insert *Insert) Call(proc *process.Process) (vm.CallResult, error)
- func (insert *Insert) ExecProjection(proc *process.Process, input *batch.Batch) (*batch.Batch, error)
- func (insert *Insert) Free(proc *process.Process, pipelineFailed bool, err error)
- func (insert *Insert) GetAffectedRows() uint64
- func (insert *Insert) GetOperatorBase() *vm.OperatorBase
- func (insert *Insert) OpType() vm.OpType
- func (insert *Insert) Prepare(proc *process.Process) error
- func (insert *Insert) Release()
- func (insert *Insert) Reset(proc *process.Process, pipelineFailed bool, err error)
- func (insert *Insert) String(buf *bytes.Buffer)
- func (insert Insert) TypeName() string
- type InsertCtx
- type PartitionInsert
- func (op *PartitionInsert) Call(proc *process.Process) (vm.CallResult, error)
- func (op *PartitionInsert) ExecProjection(proc *process.Process, input *batch.Batch) (*batch.Batch, error)
- func (op *PartitionInsert) Free(proc *process.Process, pipelineFailed bool, err error)
- func (op *PartitionInsert) GetOperatorBase() *vm.OperatorBase
- func (op *PartitionInsert) OpType() vm.OpType
- func (op *PartitionInsert) Prepare(proc *process.Process) error
- func (op *PartitionInsert) Release()
- func (op *PartitionInsert) Reset(proc *process.Process, pipelineFailed bool, err error)
- func (op *PartitionInsert) String(buf *bytes.Buffer)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewPartitionInsertFrom ¶
func NewPartitionInsertFrom( ps *PartitionInsert, ) vm.Operator
Types ¶
type Insert ¶
type Insert struct {
ToWriteS3 bool // mark if this insert's target is S3 or not.
// ToExternal marks that this insert writes into a writable external table's
// backing files (CSV/JSONLine in a stage) instead of an engine relation.
ToExternal bool
InsertCtx *InsertCtx
vm.OperatorBase
// contains filtered or unexported fields
}
func NewArgument ¶ added in v1.2.0
func NewArgument() *Insert
func (*Insert) Call ¶
first parameter: true represents whether the current pipeline has ended first parameter: false
func (*Insert) ExecProjection ¶
func (*Insert) Free ¶
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 (*Insert) GetAffectedRows ¶
func (*Insert) GetOperatorBase ¶
func (insert *Insert) GetOperatorBase() *vm.OperatorBase
type InsertCtx ¶ added in v0.7.0
type InsertCtx struct {
// insert data into Rel.
Engine engine.Engine
Ref *plan.ObjectRef
AddAffectedRows bool // for hidden table, should not update affect Rows
Attrs []string // letter case: origin
TableDef *plan.TableDef
// ExternalConfig is populated at compile time when the target is a writable
// external table; consumed by the operator to build an ExternalWriter.
ExternalConfig externalwrite.WriterConfig
}
type PartitionInsert ¶
type PartitionInsert struct {
vm.OperatorBase
// contains filtered or unexported fields
}
func (*PartitionInsert) Call ¶
func (op *PartitionInsert) Call( proc *process.Process, ) (vm.CallResult, error)
func (*PartitionInsert) ExecProjection ¶
func (*PartitionInsert) Free ¶
func (op *PartitionInsert) Free( proc *process.Process, pipelineFailed bool, err error, )
func (*PartitionInsert) GetOperatorBase ¶
func (op *PartitionInsert) GetOperatorBase() *vm.OperatorBase
func (*PartitionInsert) OpType ¶
func (op *PartitionInsert) OpType() vm.OpType
func (*PartitionInsert) Prepare ¶
func (op *PartitionInsert) Prepare( proc *process.Process, ) error
func (*PartitionInsert) Release ¶
func (op *PartitionInsert) Release()
func (*PartitionInsert) Reset ¶
func (op *PartitionInsert) Reset( proc *process.Process, pipelineFailed bool, err error, )
func (*PartitionInsert) String ¶
func (op *PartitionInsert) String(buf *bytes.Buffer)
Source Files
Click to show internal directories.
Click to hide internal directories.