logsplit

Documentation

Overview

Copyright 2022 PingCAP, Inc. Licensed under Apache-2.0.

Index

• func SplitPoint(ctx context.Context, iter *splitHelperIterator, client split.SplitClient, ...) (err error)
• type LogSplitHelper
  • func NewLogSplitHelper(rules map[int64]*restoreutils.RewriteRules, client split.SplitClient, ...) *LogSplitHelper
  • func (helper *LogSplitHelper) Merge(file *backuppb.DataFileInfo)
  • func (helper *LogSplitHelper) Split(ctx context.Context) error
• type Span
• type SplitHelper
  • func NewSplitHelper() *SplitHelper
  • func (f *SplitHelper) Merge(val Valued)
  • func (f *SplitHelper) Traverse(m func(Valued) bool)
• type Value
• type Valued
  • func NewValued(startKey, endKey []byte, value Value) Valued
  • func (v Valued) GetEndKey() []byte
  • func (v Valued) GetStartKey() []byte
  • func (v Valued) Less(other btree.Item) bool
  • func (v Valued) String() string

Functions

func SplitPoint

func SplitPoint(
	ctx context.Context,
	iter *splitHelperIterator,
	client split.SplitClient,
	splitF splitFunc,
) (err error)

SplitPoint selects ranges overlapped with each region, and calls `splitF` to split the region

Types

type LogSplitHelper

type LogSplitHelper struct {
	// contains filtered or unexported fields
}

func NewLogSplitHelper

func NewLogSplitHelper(rules map[int64]*restoreutils.RewriteRules, client split.SplitClient, splitSize uint64, splitKeys int64) *LogSplitHelper

func (*LogSplitHelper) Merge

func (helper *LogSplitHelper) Merge(file *backuppb.DataFileInfo)

func (*LogSplitHelper) Split

func (helper *LogSplitHelper) Split(ctx context.Context) error

type Span

type Span = kv.KeyRange

Span is the type of an adjacent sub key space.

type SplitHelper

type SplitHelper struct {
	// contains filtered or unexported fields
}

SplitHelper represents a set of valued ranges, which doesn't overlap and union of them all is the full key space.

func NewSplitHelper

func NewSplitHelper() *SplitHelper

NewSplitHelper creates a set of a subset of spans, with the full key space as initial status

func (*SplitHelper) Merge

func (f *SplitHelper) Merge(val Valued)

func (*SplitHelper) Traverse

func (f *SplitHelper) Traverse(m func(Valued) bool)

traverse the items in ascend order

type Value

type Value struct {
	Size   uint64
	Number int64
}

Value is the value type of stored in the span tree.

type Valued

type Valued struct {
	Key   Span
	Value Value
}

Valued is span binding to a value, which is the entry type of span tree.

func NewValued

func NewValued(startKey, endKey []byte, value Value) Valued

func (Valued) GetEndKey

func (v Valued) GetEndKey() []byte

implement for `AppliedFile`

func (Valued) GetStartKey

func (v Valued) GetStartKey() []byte

implement for `AppliedFile`

func (Valued) Less

func (v Valued) Less(other btree.Item) bool

func (Valued) String

func (v Valued) String() string