sort

Index ¶

• func ByKey(values []byte) func(a, b interface{}) bool
• func BytesCompare10(a, b []byte) bool
• func BytesCompare10Equ(a, b []byte) bool
• func BytesCompare10U16(a, b []byte) bool
• func Cmp10(a []byte, b []byte) bool
• func CreateSortRuns(file string, maxMemory int) ([]string, error)
• func SortInMemory(buffer []byte)
• func SortSingleBuffer(buffer []byte, outputPath string) error
• func SortSingleFile(inputPath, outputPath string) error
• func SortSingleFileSwapped(path, output string) error
• func SortSingleFileUniform(path, output string, rangeStart []byte, rangeEnd []byte) error
• type BufWriterCollecter
• • func (c *BufWriterCollecter) Collect(value []byte) error
  • func (c *BufWriterCollecter) FlushAndClose() error
• type ChunkReader
• • func NewChunkReader(stream chan []byte) *ChunkReader
• • func (r *ChunkReader) Read(b []byte) (int, error)
• type Collecter
• type Marker
• • func MergeRuns(items MergeHeap, collecter Collecter) ([]Marker, error)
  • func SortChunkAndWrite(buffer []byte, path string, markerInterval int, rwBufSize int) ([]Marker, error)
• type MergeHeap
• • func (h MergeHeap) Len() int
  • func (h MergeHeap) Less(i, j int) bool
  • func (h *MergeHeap) Pop() interface{}
  • func (h *MergeHeap) Push(x interface{})
  • func (h MergeHeap) Swap(i, j int)
• type MergeHeapItem
• • func (m *MergeHeapItem) Value() []byte
• type PipeWriterCollecter
• • func (c *PipeWriterCollecter) Collect(value []byte) error
  • func (c *PipeWriterCollecter) FlushAndClose() error
• type RunWriter
• • func NewRunWriter(memory int, base string) (*RunWriter, error)
• • func (w *RunWriter) Close() error
  • func (w *RunWriter) Write(b []byte) (int, error)