merge

package
v0.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 30, 2023 License: Apache-2.0 Imports: 2 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Aggregator

type Aggregator interface {
	Aggregate(values []proto.Value)
	GetResult() (proto.Value, bool)
}

type MergeRows

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

func NewMergeRows

func NewMergeRows(rows []proto.Row) *MergeRows

func NewMergeRowses

func NewMergeRowses(rowses [][]proto.Row) []*MergeRows

func (*MergeRows) GetCurrentRow

func (s *MergeRows) GetCurrentRow() proto.Row

func (*MergeRows) HasNext

func (s *MergeRows) HasNext() bool

func (*MergeRows) Next

func (s *MergeRows) Next() proto.Row

type OrderByItem

type OrderByItem struct {
	Column string
	Desc   bool
}

type PriorityQueue

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

func NewPriorityQueue

func NewPriorityQueue(rows []*MergeRows, orderByItems []OrderByItem) PriorityQueue

func (*PriorityQueue) Len

func (pq *PriorityQueue) Len() int

func (*PriorityQueue) Less

func (pq *PriorityQueue) Less(i, j int) bool

func (*PriorityQueue) Peek

func (pq *PriorityQueue) Peek() interface{}

func (*PriorityQueue) Pop

func (pq *PriorityQueue) Pop() interface{}

func (*PriorityQueue) Push

func (pq *PriorityQueue) Push(x interface{})

func (*PriorityQueue) Swap

func (pq *PriorityQueue) Swap(i, j int)

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL