Documentation
¶
Index ¶
- Constants
- type Argument
- func (arg *Argument) AffectedRows() uint64
- func (arg *Argument) Call(proc *process.Process) (vm.CallResult, error)
- func (arg *Argument) Free(proc *process.Process, pipelineFailed bool, err error)
- func (arg *Argument) GetOperatorBase() *vm.OperatorBase
- func (arg *Argument) Prepare(_ *process.Process) error
- func (arg *Argument) Release()
- func (arg *Argument) SplitBatch(proc *process.Process, srcBat *batch.Batch) error
- func (arg *Argument) String(buf *bytes.Buffer)
- func (arg Argument) TypeName() string
- type BatchPool
- type DeleteCtx
Constants ¶
View Source
const ( RawRowIdBatch = iota // remember that, for one block, // when it sends the info to mergedeletes, // either it's Compaction or not. Compaction CNBlockOffset RawBatchOffset FlushDeltaLoc )
3. RawRowIdBatch : belong to txn's snapshot data. 4. FlushDeltaLoc : belong to txn's snapshot data, which on S3 and pointed by delta location.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Argument ¶
type Argument struct {
DeleteCtx *DeleteCtx
// for delete filter below
// mp[segmentId] = 1 => txnWorkSpace,mp[segmentId] = 2 => CN Block
SegmentMap map[string]int32
RemoteDelete bool
IBucket uint32
Nbucket uint32
vm.OperatorBase
// contains filtered or unexported fields
}
func NewArgument ¶ added in v1.2.0
func NewArgument() *Argument
func (*Argument) AffectedRows ¶
func (*Argument) Call ¶ added in v1.1.0
the bool return value means whether it completed its work or not
func (*Argument) GetOperatorBase ¶ added in v1.2.0
func (arg *Argument) GetOperatorBase() *vm.OperatorBase
func (*Argument) SplitBatch ¶ added in v0.8.0
type BatchPool ¶ added in v0.8.0
type BatchPool struct {
// contains filtered or unexported fields
}
type DeleteCtx ¶ added in v0.5.1
type DeleteCtx struct {
CanTruncate bool
RowIdIdx int // The array index position of the rowid column
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
Source engine.Relation
Ref *plan.ObjectRef
AddAffectedRows bool
PrimaryKeyIdx int
}
Source Files
Click to show internal directories.
Click to hide internal directories.