postdml

package

v0.0.0-debug-20260702 Latest Latest Go to latest Published: Jul 2, 2026 License: Apache-2.0 Imports: 11 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 ¶

Overview ¶

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index ¶

func GetAnyAsString(vec *vector.Vector, i int) (string, error)
type PostDml
- func NewArgument() *PostDml
type PostDmlCtx
type PostDmlFullTextCtx

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func GetAnyAsString ¶

func GetAnyAsString(vec *vector.Vector, i int) (string, error)

Types ¶

type PostDml ¶

type PostDml struct {
	PostDmlCtx *PostDmlCtx

	vm.OperatorBase
	// contains filtered or unexported fields
}

func NewArgument ¶

func NewArgument() *PostDml

func (*PostDml) AffectedRows ¶

func (postdml *PostDml) AffectedRows() uint64

func (*PostDml) Call ¶

func (postdml *PostDml) Call(proc *process.Process) (vm.CallResult, error)

func (*PostDml) ExecProjection ¶

func (postdml *PostDml) ExecProjection(proc *process.Process, input *batch.Batch) (*batch.Batch, error)

func (*PostDml) Free ¶

func (postdml *PostDml) Free(proc *process.Process, pipelineFailed bool, err error)

func (*PostDml) GetAffectedRows ¶

func (postdml *PostDml) GetAffectedRows() *uint64

func (*PostDml) GetOperatorBase ¶

func (postdml *PostDml) GetOperatorBase() *vm.OperatorBase

func (*PostDml) OpType ¶

func (postdml *PostDml) OpType() vm.OpType

func (*PostDml) Prepare ¶

func (postdml *PostDml) Prepare(proc *process.Process) error

func (*PostDml) Release ¶

func (postdml *PostDml) Release()

func (*PostDml) Reset ¶

func (postdml *PostDml) Reset(proc *process.Process, pipelineFailed bool, err error)

func (*PostDml) String ¶

func (postdml *PostDml) String(buf *bytes.Buffer)

func (PostDml) TypeName ¶

func (postdml PostDml) TypeName() string

type PostDmlCtx ¶

type PostDmlCtx struct {
	Ref                    *plan.ObjectRef
	AddAffectedRows        bool
	PrimaryKeyIdx          int32
	PrimaryKeyName         string
	IsDelete               bool
	IsInsert               bool
	IsDeleteWithoutFilters bool

	// define various context for different tasks
	FullText *PostDmlFullTextCtx
}

type PostDmlFullTextCtx ¶

type PostDmlFullTextCtx struct {
	SourceTableName string
	IndexTableName  string
	Parts           []string
	AlgoParams      string
}

Source Files ¶

View all Source files

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