merge

Documentation

Index

• func Merge(mergeTree MergeTreePrioQueue, sortedFileName string, k int, reader pp.FReader, ...) error
• func MergeRunLengths(runLengths []MergeTreeNode, result *os.File, reader pp.FReader, ...)
• type LoserTree
  • func (lt *LoserTree) Adjust(records []preprocessing.FileRecord, s int)
  • func (lt LoserTree) GetWinner() int
  • func (lt *LoserTree) InitLoserTree(records []preprocessing.FileRecord)

Functions

func Merge

func Merge(mergeTree MergeTreePrioQueue, sortedFileName string, k int,
	reader pp.FReader, cvt pp.Converter, readingMethod int, recordSize uint64) error

合并所有游程文件

func MergeRunLengths

func MergeRunLengths(runLengths []MergeTreeNode, result *os.File,
	reader pp.FReader, cvt pp.Converter, readingMethod int, recordSize uint64)

将K个游程文件合并到指定的文件中

Types

type LoserTree

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

func (*LoserTree) Adjust

func (lt *LoserTree) Adjust(records []preprocessing.FileRecord, s int)

func (LoserTree) GetWinner

func (lt LoserTree) GetWinner() int

func (*LoserTree) InitLoserTree

func (lt *LoserTree) InitLoserTree(records []preprocessing.FileRecord)