insert

package

v0.7.0 Latest Latest Go to latest Published: Feb 18, 2023 License: Apache-2.0 Imports: 9 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/matrixorigin/matrixone

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func Call(idx int, proc *process.Process, arg any, isFirst bool, isLast bool) (bool, error)
func Prepare(proc *process.Process, arg any) error
func String(_ any, buf *bytes.Buffer)
type Argument
- func (arg *Argument) Free(proc *process.Process, pipelineFailed bool)
type InsertCtx

Constants ¶

View Source

const (
	INSERT = iota
	DELETE
)

Variables ¶

This section is empty.

Functions ¶

func Call ¶

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

func Prepare ¶

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

func String ¶

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

Types ¶

type Argument ¶

type Argument struct {
	// Ts is not used
	Ts        uint64
	Affected  uint64
	Engine    engine.Engine
	IsRemote  bool // mark if this insert is cn2s3 directly
	Container *colexec.WriteS3Container
	InsertCtx *InsertCtx
}

func (*Argument) Free ¶ added in v0.6.0

func (arg *Argument) Free(proc *process.Process, pipelineFailed bool)

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

type InsertCtx ¶ added in v0.7.0

type InsertCtx struct {
	Source       engine.Relation
	Idx          []int32
	Ref          *plan.ObjectRef
	TableDef     *plan.TableDef
	UniqueSource []engine.Relation

	ParentIdx map[string]int32

	ClusterTable *plan.ClusterTable
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL