Documentation
¶
Index ¶
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 ¶
Types ¶
type Argument ¶
type Argument struct {
Ts uint64
DeleteCtx *DeleteCtx
// for delete filter below
// mp[segmentName] = 1 => txnWorkSpace,mp[segmentName] = 2 => CN Block
SegmentMap map[string]int32
RemoteDelete bool
IBucket uint32
Nbucket uint32
// contains filtered or unexported fields
}
func (*Argument) AffectedRows ¶
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
}
Click to show internal directories.
Click to hide internal directories.