insert

package

v0.6.0 Latest Latest Go to latest Published: Nov 29, 2022 License: Apache-2.0 Imports: 15 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 ¶

func Call(_ int, proc *process.Process, arg any) (bool, error)
func CommitTxn(n *Argument, txn client.TxnOperator, ctx context.Context) error
func GetNewRelation(n *Argument, txn client.TxnOperator, proc *process.Process, ...) (engine.Relation, error)
func NewTxn(n *Argument, proc *process.Process, ctx context.Context) (txn client.TxnOperator, err error)
func Prepare(_ *process.Process, _ any) error
func RolllbackTxn(n *Argument, txn client.TxnOperator, ctx context.Context) error
func String(_ any, buf *bytes.Buffer)
type Argument
- func (arg *Argument) Free(proc *process.Process, pipelineFailed bool)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Call ¶

func Call(_ int, proc *process.Process, arg any) (bool, error)

func CommitTxn ¶ added in v0.6.0

func CommitTxn(n *Argument, txn client.TxnOperator, ctx context.Context) error

func GetNewRelation ¶ added in v0.6.0

func GetNewRelation(n *Argument, txn client.TxnOperator, proc *process.Process, ctx context.Context) (engine.Relation, error)

func NewTxn ¶ added in v0.6.0

func NewTxn(n *Argument, proc *process.Process, ctx context.Context) (txn client.TxnOperator, err error)

func Prepare ¶

func Prepare(_ *process.Process, _ any) error

func RolllbackTxn ¶ added in v0.6.0

func RolllbackTxn(n *Argument, txn client.TxnOperator, ctx context.Context) error

func String ¶

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

Types ¶

type Argument ¶

type Argument struct {
	Ts            uint64
	TargetTable   engine.Relation
	TargetColDefs []*plan.ColDef
	Affected      uint64
	Engine        engine.Engine
	DB            engine.Database
	TableID       string
	CPkeyColDef   *plan.ColDef
	DBName        string
	TableName     string
	IndexTables   []engine.Relation
	IndexInfos    []*plan.IndexInfo
}

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

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

Source Files ¶

View all Source files

insert.go

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