filesort

package

v0.0.0-...-08a93fc Latest Latest Go to latest Published: Oct 6, 2019 License: Apache-2.0 Imports: 11 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

This section is empty.

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

Builder builds a new FileSorter.

func (b *Builder) Build() (*FileSorter, error)

Build creates a FileSorter instance using given data.

func (b *Builder) SetBuf(bufSize int) *Builder

SetBuf sets the number of rows FileSorter can hold in memory at a time.

func (b *Builder) SetDesc(byDesc []bool) *Builder

SetDesc sets the ordering rule of row comparison.

func (b *Builder) SetDir(tmpDir string) *Builder

SetDir sets the working directory for FileSorter.

func (b *Builder) SetSC(sc *variable.StatementContext) *Builder

SetSC sets StatementContext instance which is required in row comparison.

func (b *Builder) SetSchema(keySize, valSize int) *Builder

SetSchema sets the schema of row, including key size and value size.

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

FileSorter sorts the given rows according to the byDesc order. FileSorter can sort rows that exceed predefined memory capacity.

func (fs *FileSorter) Close() error

Close terminates the input or output process and discards all remaining data.

func (fs *FileSorter) Input(key []types.Datum, val []types.Datum, handle int64) error

Input adds one row into FileSorter. Caller should not call Input after calling Output.

func (fs *FileSorter) Len() int

Len implements sort.Interface Len interface.

func (fs *FileSorter) Less(i, j int) bool

Less implements sort.Interface Less interface.

func (fs *FileSorter) Output() ([]types.Datum, []types.Datum, int64, error)

Output gets the next sorted row.

func (fs *FileSorter) Swap(i, j int)

Swap implements sort.Interface Swap interface.