txnentries

Documentation

Index

• Constants
• func NewCompactBlockEntry(txn txnif.AsyncTxn, from, to handle.Block, sortIdx []int32, ...) *compactBlockEntry
• func NewFlushTableTailEntry(txn txnif.AsyncTxn, taskID uint64, mapping *BlkTransferBooking, ...) *flushTableTailEntry
• func NewMergeBlocksEntry(txn txnif.AsyncTxn, relation handle.Relation, ...) *mergeBlocksEntry
• type BlkTransferBooking
  • func NewBlkTransferBooking(size int) *BlkTransferBooking
  • func (b *BlkTransferBooking) AddSortPhaseMapping(idx int, originRowCnt int, deletes *nulls.Nulls, mapping []int32)
  • func (b *BlkTransferBooking) Clean()
  • func (b *BlkTransferBooking) UpdateMappingAfterMerge(mapping, fromLayout, toLayout []uint32)
• type DestPos

Constants

const (
	IOET_WALTxnCommand_Compact        uint16 = 3006
	IOET_WALTxnCommand_Merge          uint16 = 3007
	IOET_WALTxnCommand_FlushTableTail uint16 = 3014

	IOET_WALTxnCommand_Compact_V1        uint16 = 1
	IOET_WALTxnCommand_Merge_V1          uint16 = 1
	IOET_WALTxnCommand_FlashTableTail_V1 uint16 = 1

	IOET_WALTxnCommand_Compact_CurrVer        = IOET_WALTxnCommand_Compact_V1
	IOET_WALTxnCommand_Merge_CurrVer          = IOET_WALTxnCommand_Merge_V1
	IOET_WALTxnCommand_FlushTableTail_CurrVer = IOET_WALTxnCommand_FlashTableTail_V1
)

Functions

func NewCompactBlockEntry

func NewCompactBlockEntry(
	txn txnif.AsyncTxn,
	from, to handle.Block,
	sortIdx []int32,
	deletes *nulls.Bitmap,
	rt *dbutils.Runtime,
) *compactBlockEntry

func NewFlushTableTailEntry

func NewFlushTableTailEntry(
	txn txnif.AsyncTxn,
	taskID uint64,
	mapping *BlkTransferBooking,
	tableEntry *catalog.TableEntry,
	ablksMetas []*catalog.BlockEntry,
	nblksMetas []*catalog.BlockEntry,
	ablksHandles []handle.Block,
	nblksHandles []handle.Block,
	createdBlkHandles []handle.Block,
	createdDeletesFile string,
	createdMergeFile string,
	dirtyLen int,
	rt *dbutils.Runtime,
	dirtyEndTs types.TS,
) *flushTableTailEntry

func NewMergeBlocksEntry

func NewMergeBlocksEntry(
	txn txnif.AsyncTxn,
	relation handle.Relation,
	droppedSegs, createdSegs []*catalog.SegmentEntry,
	droppedBlks, createdBlks []*catalog.BlockEntry,
	transMappings *BlkTransferBooking,
	mapping, fromAddr, toAddr []uint32,
	deletes []*nulls.Bitmap,
	skipBlks []int,
	rt *dbutils.Runtime,
) *mergeBlocksEntry

Types

type BlkTransferBooking

type BlkTransferBooking struct {
	// row in the deleted blk -> row in the created blk
	Mappings []map[int]DestPos
}

func NewBlkTransferBooking

func NewBlkTransferBooking(size int) *BlkTransferBooking

func (*BlkTransferBooking) AddSortPhaseMapping

func (b *BlkTransferBooking) AddSortPhaseMapping(idx int, originRowCnt int, deletes *nulls.Nulls, mapping []int32)

func (*BlkTransferBooking) Clean

func (b *BlkTransferBooking) Clean()

func (*BlkTransferBooking) UpdateMappingAfterMerge

func (b *BlkTransferBooking) UpdateMappingAfterMerge(mapping, fromLayout, toLayout []uint32)

type DestPos

type DestPos struct {
	Idx int // idx of the created blk
	Row int // destination row number
}