aggregation

package

Go to main page

Versions in this module

v0

v0.18.1

Apr 9, 2024

v0.18.0

Feb 28, 2024

Changes in this version

type AnyValue

+ func (a *AnyValue) Id() sql.ColumnId

+ func (a *AnyValue) WithId(id sql.ColumnId) sql.IdExpression

type Avg

+ func (a *Avg) Id() sql.ColumnId

+ func (a *Avg) WithId(id sql.ColumnId) sql.IdExpression

type BitAnd

+ func (a *BitAnd) Id() sql.ColumnId

+ func (a *BitAnd) WithId(id sql.ColumnId) sql.IdExpression

type BitOr

+ func (a *BitOr) Id() sql.ColumnId

+ func (a *BitOr) WithId(id sql.ColumnId) sql.IdExpression

type BitXor

+ func (a *BitXor) Id() sql.ColumnId

+ func (a *BitXor) WithId(id sql.ColumnId) sql.IdExpression

type Count

+ func (a *Count) Id() sql.ColumnId

+ func (a *Count) WithId(id sql.ColumnId) sql.IdExpression

type CountDistinct

+ func (a *CountDistinct) Id() sql.ColumnId

+ func (a *CountDistinct) WithId(id sql.ColumnId) sql.IdExpression

type First

+ func (a *First) Id() sql.ColumnId

+ func (a *First) WithId(id sql.ColumnId) sql.IdExpression

type GroupConcat

+ func (a *GroupConcat) Id() sql.ColumnId

+ func (a *GroupConcat) WithId(id sql.ColumnId) sql.IdExpression

type JSONObjectAgg

+ func (j *JSONObjectAgg) Id() sql.ColumnId

+ func (j *JSONObjectAgg) WithId(id sql.ColumnId) sql.IdExpression

type JsonArray

+ func (a *JsonArray) Id() sql.ColumnId

+ func (a *JsonArray) WithId(id sql.ColumnId) sql.IdExpression

type Last

+ func (a *Last) Id() sql.ColumnId

+ func (a *Last) WithId(id sql.ColumnId) sql.IdExpression

type Max

+ func (a *Max) Id() sql.ColumnId

+ func (a *Max) WithId(id sql.ColumnId) sql.IdExpression

type Min

+ func (a *Min) Id() sql.ColumnId

+ func (a *Min) WithId(id sql.ColumnId) sql.IdExpression

type Sum

+ func (a *Sum) Id() sql.ColumnId

+ func (a *Sum) WithId(id sql.ColumnId) sql.IdExpression

v0.17.0

Aug 23, 2023

v0.16.0

Jun 29, 2023

v0.15.0

Apr 18, 2023

Changes in this version

+ func NewAnyValueBuffer(child sql.Expression) *anyValueBuffer

+ type AnyValue struct

+ func NewAnyValue(e sql.Expression) *AnyValue

+ func (a *AnyValue) Children() []sql.Expression

+ func (a *AnyValue) CollationCoercibility(ctx *sql.Context) (collation sql.CollationID, coercibility byte)

+ func (a *AnyValue) DebugString() string

+ func (a *AnyValue) Eval(ctx *sql.Context, row sql.Row) (interface{}, error)

+ func (a *AnyValue) IsNullable() bool

+ func (a *AnyValue) NewBuffer() (sql.AggregationBuffer, error)

+ func (a *AnyValue) NewWindowFunction() (sql.WindowFunction, error)

+ func (a *AnyValue) Resolved() bool

+ func (a *AnyValue) String() string

+ func (a *AnyValue) Type() sql.Type

+ func (a *AnyValue) Window() *sql.WindowDefinition

+ func (a *AnyValue) WithChildren(children ...sql.Expression) (sql.Expression, error)

+ func (a *AnyValue) WithWindow(window *sql.WindowDefinition) (sql.Aggregation, error)

+ func (a AnyValue) Description() string

+ func (a AnyValue) FunctionName() string

+ type AnyValueAgg struct

+ func NewAnyValueAgg(e sql.Expression) *AnyValueAgg

+ func (a *AnyValueAgg) Compute(ctx *sql.Context, interval sql.WindowInterval, buf sql.WindowBuffer) interface{}

+ func (a *AnyValueAgg) DefaultFramer() sql.WindowFramer

+ func (a *AnyValueAgg) Dispose()

+ func (a *AnyValueAgg) StartPartition(ctx *sql.Context, interval sql.WindowInterval, buf sql.WindowBuffer) error

+ func (a *AnyValueAgg) WithWindow(w *sql.WindowDefinition) (sql.WindowFunction, error)

type Avg

+ func (a *Avg) CollationCoercibility(ctx *sql.Context) (collation sql.CollationID, coercibility byte)

+ func (a *Avg) DebugString() string

type BitAnd

+ func (a *BitAnd) CollationCoercibility(ctx *sql.Context) (collation sql.CollationID, coercibility byte)

+ func (a *BitAnd) DebugString() string

type BitOr

+ func (a *BitOr) CollationCoercibility(ctx *sql.Context) (collation sql.CollationID, coercibility byte)

+ func (a *BitOr) DebugString() string

type BitXor

+ func (a *BitXor) CollationCoercibility(ctx *sql.Context) (collation sql.CollationID, coercibility byte)

+ func (a *BitXor) DebugString() string

type Count

+ func (a *Count) CollationCoercibility(ctx *sql.Context) (collation sql.CollationID, coercibility byte)

+ func (a *Count) DebugString() string

type CountDistinct

+ func (*CountDistinct) CollationCoercibility(ctx *sql.Context) (collation sql.CollationID, coercibility byte)

type First

+ func (a *First) CollationCoercibility(ctx *sql.Context) (collation sql.CollationID, coercibility byte)

+ func (a *First) DebugString() string

type JSONObjectAgg

+ func (*JSONObjectAgg) CollationCoercibility(ctx *sql.Context) (collation sql.CollationID, coercibility byte)

type JsonArray

+ func (a *JsonArray) CollationCoercibility(ctx *sql.Context) (collation sql.CollationID, coercibility byte)

+ func (a *JsonArray) DebugString() string

type Last

+ func (a *Last) CollationCoercibility(ctx *sql.Context) (collation sql.CollationID, coercibility byte)

+ func (a *Last) DebugString() string

type Max

+ func (a *Max) CollationCoercibility(ctx *sql.Context) (collation sql.CollationID, coercibility byte)

type Min

+ func (a *Min) CollationCoercibility(ctx *sql.Context) (collation sql.CollationID, coercibility byte)

+ func (a *Min) DebugString() string

type Sum

+ func (a *Sum) CollationCoercibility(ctx *sql.Context) (collation sql.CollationID, coercibility byte)

+ func (a *Sum) DebugString() string

v0.14.0

Nov 1, 2022

Changes in this version

+ func NewBitAndBuffer(child sql.Expression) *bitAndBuffer

+ func NewBitOrBuffer(child sql.Expression) *bitOrBuffer

+ func NewBitXorBuffer(child sql.Expression) *bitXorBuffer

+ type BitAnd struct

+ func NewBitAnd(e sql.Expression) *BitAnd

+ func (a *BitAnd) Children() []sql.Expression

+ func (a *BitAnd) Eval(ctx *sql.Context, row sql.Row) (interface{}, error)

+ func (a *BitAnd) IsNullable() bool

+ func (a *BitAnd) NewBuffer() (sql.AggregationBuffer, error)

+ func (a *BitAnd) NewWindowFunction() (sql.WindowFunction, error)

+ func (a *BitAnd) Resolved() bool

+ func (a *BitAnd) String() string

+ func (a *BitAnd) Type() sql.Type

+ func (a *BitAnd) Window() *sql.WindowDefinition

+ func (a *BitAnd) WithChildren(children ...sql.Expression) (sql.Expression, error)

+ func (a *BitAnd) WithWindow(window *sql.WindowDefinition) (sql.Aggregation, error)

+ func (a BitAnd) Description() string

+ func (a BitAnd) FunctionName() string

+ type BitAndAgg struct

+ func NewBitAndAgg(e sql.Expression) *BitAndAgg

+ func (b *BitAndAgg) Compute(ctx *sql.Context, interval sql.WindowInterval, buf sql.WindowBuffer) interface{}

+ func (b *BitAndAgg) DefaultFramer() sql.WindowFramer

+ func (b *BitAndAgg) Dispose()

+ func (b *BitAndAgg) NewSlidingFrameInterval(added, dropped sql.WindowInterval)

+ func (b *BitAndAgg) StartPartition(ctx *sql.Context, interval sql.WindowInterval, buf sql.WindowBuffer) error

+ func (b *BitAndAgg) WithWindow(w *sql.WindowDefinition) (sql.WindowFunction, error)

+ type BitOr struct

+ func NewBitOr(e sql.Expression) *BitOr

+ func (a *BitOr) Children() []sql.Expression

+ func (a *BitOr) Eval(ctx *sql.Context, row sql.Row) (interface{}, error)

+ func (a *BitOr) IsNullable() bool

+ func (a *BitOr) NewBuffer() (sql.AggregationBuffer, error)

+ func (a *BitOr) NewWindowFunction() (sql.WindowFunction, error)

+ func (a *BitOr) Resolved() bool

+ func (a *BitOr) String() string

+ func (a *BitOr) Type() sql.Type

+ func (a *BitOr) Window() *sql.WindowDefinition

+ func (a *BitOr) WithChildren(children ...sql.Expression) (sql.Expression, error)

+ func (a *BitOr) WithWindow(window *sql.WindowDefinition) (sql.Aggregation, error)

+ func (a BitOr) Description() string

+ func (a BitOr) FunctionName() string

+ type BitOrAgg struct

+ func NewBitOrAgg(e sql.Expression) *BitOrAgg

+ func (b *BitOrAgg) Compute(ctx *sql.Context, interval sql.WindowInterval, buf sql.WindowBuffer) interface{}

+ func (b *BitOrAgg) DefaultFramer() sql.WindowFramer

+ func (b *BitOrAgg) Dispose()

+ func (b *BitOrAgg) NewSlidingFrameInterval(added, dropped sql.WindowInterval)

+ func (b *BitOrAgg) StartPartition(ctx *sql.Context, interval sql.WindowInterval, buf sql.WindowBuffer) error

+ func (b *BitOrAgg) WithWindow(w *sql.WindowDefinition) (sql.WindowFunction, error)

+ type BitXor struct

+ func NewBitXor(e sql.Expression) *BitXor

+ func (a *BitXor) Children() []sql.Expression

+ func (a *BitXor) Eval(ctx *sql.Context, row sql.Row) (interface{}, error)

+ func (a *BitXor) IsNullable() bool

+ func (a *BitXor) NewBuffer() (sql.AggregationBuffer, error)

+ func (a *BitXor) NewWindowFunction() (sql.WindowFunction, error)

+ func (a *BitXor) Resolved() bool

+ func (a *BitXor) String() string

+ func (a *BitXor) Type() sql.Type

+ func (a *BitXor) Window() *sql.WindowDefinition

+ func (a *BitXor) WithChildren(children ...sql.Expression) (sql.Expression, error)

+ func (a *BitXor) WithWindow(window *sql.WindowDefinition) (sql.Aggregation, error)

+ func (a BitXor) Description() string

+ func (a BitXor) FunctionName() string

+ type BitXorAgg struct

+ func NewBitXorAgg(e sql.Expression) *BitXorAgg

+ func (b *BitXorAgg) Compute(ctx *sql.Context, interval sql.WindowInterval, buf sql.WindowBuffer) interface{}

+ func (b *BitXorAgg) DefaultFramer() sql.WindowFramer

+ func (b *BitXorAgg) Dispose()

+ func (b *BitXorAgg) NewSlidingFrameInterval(added, dropped sql.WindowInterval)

+ func (b *BitXorAgg) StartPartition(ctx *sql.Context, interval sql.WindowInterval, buf sql.WindowBuffer) error

+ func (b *BitXorAgg) WithWindow(w *sql.WindowDefinition) (sql.WindowFunction, error)

+ type DenseRank struct

+ func NewDenseRank(orderBy []sql.Expression) *DenseRank

+ func (a *DenseRank) Compute(ctx *sql.Context, interval sql.WindowInterval, buf sql.WindowBuffer) interface{}

+ func (a DenseRank) DefaultFramer() sql.WindowFramer

+ func (a DenseRank) Dispose()

+ func (a DenseRank) NewSlidingFrameInterval(added, dropped sql.WindowInterval)

+ func (a DenseRank) StartPartition(ctx *sql.Context, interval sql.WindowInterval, buffer sql.WindowBuffer) error

+ func (a DenseRank) WithWindow(w *sql.WindowDefinition) (sql.WindowFunction, error)

+ type Rank struct

+ func NewRank(orderBy []sql.Expression) *Rank

+ func (a Rank) Compute(ctx *sql.Context, interval sql.WindowInterval, buf sql.WindowBuffer) interface{}

+ func (a Rank) DefaultFramer() sql.WindowFramer

+ func (a Rank) Dispose()

+ func (a Rank) NewSlidingFrameInterval(added, dropped sql.WindowInterval)

+ func (a Rank) StartPartition(ctx *sql.Context, interval sql.WindowInterval, buffer sql.WindowBuffer) error

+ func (a Rank) WithWindow(w *sql.WindowDefinition) (sql.WindowFunction, error)

v0.12.0

Jun 12, 2022

Changes in this version

+ var ErrNoPartitions = errors.New("no partitions")

+ var ErrPartitionNotSet = errors.New("attempted to general a window frame interval before framer partition was set")

+ var ErrRangeIntervalTypeMismatch = errors.New("range bound type must match the order by expression type")

+ var ErrRangeInvalidOrderBy = sqlerr.NewKind("a range's order by must be one expression; found: %d")

+ var UnaryAggDefs support.GenDefs = []support.AggDef

+ func NewAvgBuffer(child sql.Expression) *avgBuffer

+ func NewCountBuffer(child sql.Expression) *countBuffer

+ func NewCountDistinctBuffer(child sql.Expression) *countDistinctBuffer

+ func NewFirstBuffer(child sql.Expression) *firstBuffer

+ func NewJsonArrayBuffer(child sql.Expression) *jsonArrayBuffer

+ func NewLastBuffer(child sql.Expression) *lastBuffer

+ func NewMaxBuffer(child sql.Expression) *maxBuffer

+ func NewMinBuffer(child sql.Expression) *minBuffer

+ func NewRangeCurrentRowToCurrentRowFramer(frame sql.WindowFrame, window *sql.WindowDefinition) (sql.WindowFramer, error)

+ func NewRangeCurrentRowToNFollowingFramer(frame sql.WindowFrame, window *sql.WindowDefinition) (sql.WindowFramer, error)

+ func NewRangeCurrentRowToNPrecedingFramer(frame sql.WindowFrame, window *sql.WindowDefinition) (sql.WindowFramer, error)

+ func NewRangeCurrentRowToUnboundedFollowingFramer(frame sql.WindowFrame, window *sql.WindowDefinition) (sql.WindowFramer, error)

+ func NewRangeNFollowingToCurrentRowFramer(frame sql.WindowFrame, window *sql.WindowDefinition) (sql.WindowFramer, error)

+ func NewRangeNFollowingToNFollowingFramer(frame sql.WindowFrame, window *sql.WindowDefinition) (sql.WindowFramer, error)

+ func NewRangeNFollowingToNPrecedingFramer(frame sql.WindowFrame, window *sql.WindowDefinition) (sql.WindowFramer, error)

+ func NewRangeNFollowingToUnboundedFollowingFramer(frame sql.WindowFrame, window *sql.WindowDefinition) (sql.WindowFramer, error)

+ func NewRangeNPrecedingToCurrentRowFramer(frame sql.WindowFrame, window *sql.WindowDefinition) (sql.WindowFramer, error)

+ func NewRangeNPrecedingToNFollowingFramer(frame sql.WindowFrame, window *sql.WindowDefinition) (sql.WindowFramer, error)

+ func NewRangeNPrecedingToNPrecedingFramer(frame sql.WindowFrame, window *sql.WindowDefinition) (sql.WindowFramer, error)

+ func NewRangeNPrecedingToUnboundedFollowingFramer(frame sql.WindowFrame, window *sql.WindowDefinition) (sql.WindowFramer, error)

+ func NewRangeUnboundedPrecedingToCurrentRowFramer(frame sql.WindowFrame, window *sql.WindowDefinition) (sql.WindowFramer, error)

+ func NewRangeUnboundedPrecedingToNFollowingFramer(frame sql.WindowFrame, window *sql.WindowDefinition) (sql.WindowFramer, error)

+ func NewRangeUnboundedPrecedingToNPrecedingFramer(frame sql.WindowFrame, window *sql.WindowDefinition) (sql.WindowFramer, error)

+ func NewRangeUnboundedPrecedingToUnboundedFollowingFramer(frame sql.WindowFrame, window *sql.WindowDefinition) (sql.WindowFramer, error)

+ func NewRowsCurrentRowToCurrentRowFramer(frame sql.WindowFrame, window *sql.WindowDefinition) (sql.WindowFramer, error)

+ func NewRowsCurrentRowToNFollowingFramer(frame sql.WindowFrame, window *sql.WindowDefinition) (sql.WindowFramer, error)

+ func NewRowsCurrentRowToNPrecedingFramer(frame sql.WindowFrame, window *sql.WindowDefinition) (sql.WindowFramer, error)

+ func NewRowsCurrentRowToUnboundedFollowingFramer(frame sql.WindowFrame, window *sql.WindowDefinition) (sql.WindowFramer, error)

+ func NewRowsNFollowingToCurrentRowFramer(frame sql.WindowFrame, window *sql.WindowDefinition) (sql.WindowFramer, error)

+ func NewRowsNFollowingToNFollowingFramer(frame sql.WindowFrame, window *sql.WindowDefinition) (sql.WindowFramer, error)

+ func NewRowsNFollowingToNPrecedingFramer(frame sql.WindowFrame, window *sql.WindowDefinition) (sql.WindowFramer, error)

+ func NewRowsNFollowingToUnboundedFollowingFramer(frame sql.WindowFrame, window *sql.WindowDefinition) (sql.WindowFramer, error)

+ func NewRowsNPrecedingToCurrentRowFramer(frame sql.WindowFrame, window *sql.WindowDefinition) (sql.WindowFramer, error)

+ func NewRowsNPrecedingToNFollowingFramer(frame sql.WindowFrame, window *sql.WindowDefinition) (sql.WindowFramer, error)

+ func NewRowsNPrecedingToNPrecedingFramer(frame sql.WindowFrame, window *sql.WindowDefinition) (sql.WindowFramer, error)

+ func NewRowsNPrecedingToUnboundedFollowingFramer(frame sql.WindowFrame, window *sql.WindowDefinition) (sql.WindowFramer, error)

+ func NewRowsUnboundedPrecedingToCurrentRowFramer(frame sql.WindowFrame, window *sql.WindowDefinition) (sql.WindowFramer, error)

+ func NewRowsUnboundedPrecedingToNFollowingFramer(frame sql.WindowFrame, window *sql.WindowDefinition) (sql.WindowFramer, error)

+ func NewRowsUnboundedPrecedingToNPrecedingFramer(frame sql.WindowFrame, window *sql.WindowDefinition) (sql.WindowFramer, error)

+ func NewRowsUnboundedPrecedingToUnboundedFollowingFramer(frame sql.WindowFrame, window *sql.WindowDefinition) (sql.WindowFramer, error)

+ func NewSumBuffer(child sql.Expression) *sumBuffer

+ type Aggregation struct

+ func NewAggregation(a sql.WindowFunction, f sql.WindowFramer) *Aggregation

type Avg

+ func (a *Avg) Children() []sql.Expression

+ func (a *Avg) NewWindowFunction() (sql.WindowFunction, error)

+ func (a *Avg) Resolved() bool

+ func (a *Avg) Window() *sql.WindowDefinition

+ func (a *Avg) WithWindow(window *sql.WindowDefinition) (sql.Aggregation, error)

+ func (a Avg) Description() string

+ type AvgAgg struct

+ func NewAvgAgg(e sql.Expression) *AvgAgg

+ func (a *AvgAgg) Compute(ctx *sql.Context, interval sql.WindowInterval, buf sql.WindowBuffer) interface{}

+ func (a *AvgAgg) DefaultFramer() sql.WindowFramer

+ func (a *AvgAgg) Dispose()

+ func (a *AvgAgg) NewSlidingFrameInterval(added, dropped sql.WindowInterval)

+ func (a *AvgAgg) StartPartition(ctx *sql.Context, interval sql.WindowInterval, buf sql.WindowBuffer) error

+ func (a *AvgAgg) WithWindow(w *sql.WindowDefinition) (sql.WindowFunction, error)

type Count

+ func (a *Count) Children() []sql.Expression

+ func (a *Count) NewWindowFunction() (sql.WindowFunction, error)

+ func (a *Count) Window() *sql.WindowDefinition

+ func (a *Count) WithWindow(window *sql.WindowDefinition) (sql.Aggregation, error)

+ func (a Count) Description() string

+ type CountAgg struct

+ func NewCountAgg(e sql.Expression) *CountAgg

+ func NewCountDistinctAgg(e sql.Expression) *CountAgg

+ func (a *CountAgg) Compute(ctx *sql.Context, interval sql.WindowInterval, buf sql.WindowBuffer) interface{}

+ func (a *CountAgg) DefaultFramer() sql.WindowFramer

+ func (a *CountAgg) Dispose()

+ func (a *CountAgg) NewSlidingFrameInterval(added, dropped sql.WindowInterval)

+ func (a *CountAgg) StartPartition(ctx *sql.Context, interval sql.WindowInterval, buf sql.WindowBuffer) error

+ func (a *CountAgg) WithWindow(w *sql.WindowDefinition) (sql.WindowFunction, error)

type CountDistinct

+ func (a *CountDistinct) Children() []sql.Expression

+ func (a *CountDistinct) NewWindowFunction() (sql.WindowFunction, error)

+ func (a *CountDistinct) Window() *sql.WindowDefinition

+ func (a *CountDistinct) WithWindow(window *sql.WindowDefinition) (sql.Aggregation, error)

+ func (a CountDistinct) Description() string

type First

+ func (a *First) Children() []sql.Expression

+ func (a *First) IsNullable() bool

+ func (a *First) NewWindowFunction() (sql.WindowFunction, error)

+ func (a *First) Resolved() bool

+ func (a *First) Window() *sql.WindowDefinition

+ func (a *First) WithWindow(window *sql.WindowDefinition) (sql.Aggregation, error)

+ func (a First) Description() string

+ type FirstAgg struct

+ func NewFirstAgg(e sql.Expression) *FirstAgg

+ func (a *FirstAgg) Compute(ctx *sql.Context, interval sql.WindowInterval, buffer sql.WindowBuffer) interface{}

+ func (a *FirstAgg) DefaultFramer() sql.WindowFramer

+ func (a *FirstAgg) Dispose()

+ func (a *FirstAgg) NewSlidingFrameInterval(added, dropped sql.WindowInterval)

+ func (a *FirstAgg) StartPartition(ctx *sql.Context, interval sql.WindowInterval, buffer sql.WindowBuffer) error

+ func (a *FirstAgg) WithWindow(w *sql.WindowDefinition) (sql.WindowFunction, error)

+ type GroupByFramer struct

+ func NewGroupByFramer() *GroupByFramer

+ func (f *GroupByFramer) FirstIdx() int

+ func (f *GroupByFramer) Interval() (sql.WindowInterval, error)

+ func (f *GroupByFramer) LastIdx() int

+ func (f *GroupByFramer) NewFramer(interval sql.WindowInterval) (sql.WindowFramer, error)

+ func (f *GroupByFramer) Next(ctx *sql.Context, buffer sql.WindowBuffer) (sql.WindowInterval, error)

+ func (f *GroupByFramer) SlidingInterval(ctx sql.Context) (sql.WindowInterval, sql.WindowInterval, sql.WindowInterval)

type GroupConcat

+ func (g *GroupConcat) Description() string

+ func (g *GroupConcat) NewWindowFunction() (sql.WindowFunction, error)

+ func (g *GroupConcat) Window() *sql.WindowDefinition

+ func (g *GroupConcat) WithWindow(window *sql.WindowDefinition) (sql.Aggregation, error)

+ type GroupConcatAgg struct

+ func NewGroupConcatAgg(gc *GroupConcat) *GroupConcatAgg

+ func (a *GroupConcatAgg) Compute(ctx *sql.Context, interval sql.WindowInterval, buf sql.WindowBuffer) interface{}

+ func (a *GroupConcatAgg) DefaultFramer() sql.WindowFramer

+ func (a *GroupConcatAgg) Dispose()

+ func (a *GroupConcatAgg) NewSlidingFrameInterval(added, dropped sql.WindowInterval)

+ func (a *GroupConcatAgg) StartPartition(ctx *sql.Context, interval sql.WindowInterval, buf sql.WindowBuffer) error

+ func (a *GroupConcatAgg) WithWindow(w *sql.WindowDefinition) (sql.WindowFunction, error)

type JSONObjectAgg

+ func (j *JSONObjectAgg) Description() string

+ func (j *JSONObjectAgg) NewWindowFunction() (sql.WindowFunction, error)

+ func (j *JSONObjectAgg) Window() *sql.WindowDefinition

+ func (j *JSONObjectAgg) WithWindow(window *sql.WindowDefinition) (sql.Aggregation, error)

+ type JsonArray struct

+ func NewJsonArray(e sql.Expression) *JsonArray

+ func (a *JsonArray) Children() []sql.Expression

+ func (a *JsonArray) Eval(ctx *sql.Context, row sql.Row) (interface{}, error)

+ func (a *JsonArray) IsNullable() bool

+ func (a *JsonArray) NewBuffer() (sql.AggregationBuffer, error)

+ func (a *JsonArray) NewWindowFunction() (sql.WindowFunction, error)

+ func (a *JsonArray) Resolved() bool

+ func (a *JsonArray) String() string

+ func (a *JsonArray) Type() sql.Type

+ func (a *JsonArray) Window() *sql.WindowDefinition

+ func (a *JsonArray) WithChildren(children ...sql.Expression) (sql.Expression, error)

+ func (a *JsonArray) WithWindow(window *sql.WindowDefinition) (sql.Aggregation, error)

+ func (a JsonArray) Description() string

+ func (a JsonArray) FunctionName() string

+ type Lag struct

+ func NewLag(expr, def sql.Expression, offset int) *Lag

+ func (a *Lag) Compute(ctx *sql.Context, interval sql.WindowInterval, buffer sql.WindowBuffer) interface{}

+ func (a *Lag) DefaultFramer() sql.WindowFramer

+ func (a *Lag) Dispose()

+ func (a *Lag) NewSlidingFrameInterval(added, dropped sql.WindowInterval)

+ func (a *Lag) StartPartition(ctx *sql.Context, interval sql.WindowInterval, buffer sql.WindowBuffer) error

+ func (a *Lag) WithWindow(w *sql.WindowDefinition) (sql.WindowFunction, error)

type Last

+ func (a *Last) Children() []sql.Expression

+ func (a *Last) IsNullable() bool

+ func (a *Last) NewWindowFunction() (sql.WindowFunction, error)

+ func (a *Last) Resolved() bool

+ func (a *Last) Window() *sql.WindowDefinition

+ func (a *Last) WithWindow(window *sql.WindowDefinition) (sql.Aggregation, error)

+ func (a Last) Description() string

+ type LastAgg struct

+ func NewLastAgg(e sql.Expression) *LastAgg

+ func (a *LastAgg) Compute(ctx *sql.Context, interval sql.WindowInterval, buffer sql.WindowBuffer) interface{}

+ func (a *LastAgg) DefaultFramer() sql.WindowFramer

+ func (a *LastAgg) Dispose()

+ func (a *LastAgg) NewSlidingFrameInterval(added, dropped sql.WindowInterval)

+ func (a *LastAgg) StartPartition(ctx *sql.Context, interval sql.WindowInterval, buffer sql.WindowBuffer) error

+ func (a *LastAgg) WithWindow(w *sql.WindowDefinition) (sql.WindowFunction, error)

+ type Lead struct

+ func NewLead(expr, def sql.Expression, offset int) *Lead

+ func (a *Lead) Compute(ctx *sql.Context, interval sql.WindowInterval, buffer sql.WindowBuffer) interface{}

+ func (a *Lead) DefaultFramer() sql.WindowFramer

+ func (a *Lead) Dispose()

+ func (a *Lead) NewSlidingFrameInterval(added, dropped sql.WindowInterval)

+ func (a *Lead) StartPartition(ctx *sql.Context, interval sql.WindowInterval, buffer sql.WindowBuffer) error

+ func (a *Lead) WithWindow(w *sql.WindowDefinition) (sql.WindowFunction, error)

type Max

+ func (a *Max) Children() []sql.Expression

+ func (a *Max) NewWindowFunction() (sql.WindowFunction, error)

+ func (a *Max) Resolved() bool

+ func (a *Max) Window() *sql.WindowDefinition

+ func (a *Max) WithWindow(window *sql.WindowDefinition) (sql.Aggregation, error)

+ func (a Max) Description() string

+ type MaxAgg struct

+ func NewMaxAgg(e sql.Expression) *MaxAgg

+ func (a *MaxAgg) Compute(ctx *sql.Context, interval sql.WindowInterval, buffer sql.WindowBuffer) interface{}

+ func (a *MaxAgg) DefaultFramer() sql.WindowFramer

+ func (a *MaxAgg) Dispose()

+ func (a *MaxAgg) NewSlidingFrameInterval(added, dropped sql.WindowInterval)

+ func (a *MaxAgg) StartPartition(ctx *sql.Context, interval sql.WindowInterval, buffer sql.WindowBuffer) error

+ func (a *MaxAgg) WithWindow(w *sql.WindowDefinition) (sql.WindowFunction, error)

type Min

+ func (a *Min) Children() []sql.Expression

+ func (a *Min) NewWindowFunction() (sql.WindowFunction, error)

+ func (a *Min) Resolved() bool

+ func (a *Min) Window() *sql.WindowDefinition

+ func (a *Min) WithWindow(window *sql.WindowDefinition) (sql.Aggregation, error)

+ func (a Min) Description() string

+ type MinAgg struct

+ func NewMinAgg(e sql.Expression) *MinAgg

+ func (a *MinAgg) Compute(ctx *sql.Context, interval sql.WindowInterval, buf sql.WindowBuffer) interface{}

+ func (a *MinAgg) DefaultFramer() sql.WindowFramer

+ func (a *MinAgg) Dispose()

+ func (a *MinAgg) NewSlidingFrameInterval(added, dropped sql.WindowInterval)

+ func (a *MinAgg) StartPartition(ctx *sql.Context, interval sql.WindowInterval, buffer sql.WindowBuffer) error

+ func (a *MinAgg) WithWindow(w *sql.WindowDefinition) (sql.WindowFunction, error)

+ type PartitionFramer struct

+ func NewPartitionFramer() *PartitionFramer

+ func (f *PartitionFramer) Close()

+ func (f *PartitionFramer) FirstIdx() int

+ func (f *PartitionFramer) Interval() (sql.WindowInterval, error)

+ func (f *PartitionFramer) LastIdx() int

+ func (f *PartitionFramer) NewFramer(interval sql.WindowInterval) (sql.WindowFramer, error)

+ func (f *PartitionFramer) Next(ctx *sql.Context, buffer sql.WindowBuffer) (sql.WindowInterval, error)

+ func (f *PartitionFramer) SlidingInterval(ctx sql.Context) (sql.WindowInterval, sql.WindowInterval, sql.WindowInterval)

+ type PeerGroupFramer struct

+ func NewPeerGroupFramer(orderBy []sql.Expression) *PeerGroupFramer

+ func (f *PeerGroupFramer) FirstIdx() int

+ func (f *PeerGroupFramer) Interval() (sql.WindowInterval, error)

+ func (f *PeerGroupFramer) LastIdx() int

+ func (f *PeerGroupFramer) NewFramer(interval sql.WindowInterval) (sql.WindowFramer, error)

+ func (f *PeerGroupFramer) Next(ctx *sql.Context, buf sql.WindowBuffer) (sql.WindowInterval, error)

+ type PercentRank struct

+ func NewPercentRank(orderBy []sql.Expression) *PercentRank

+ func (a *PercentRank) Compute(ctx *sql.Context, interval sql.WindowInterval, buf sql.WindowBuffer) interface{}

+ func (a *PercentRank) DefaultFramer() sql.WindowFramer

+ func (a *PercentRank) Dispose()

+ func (a *PercentRank) NewSlidingFrameInterval(added, dropped sql.WindowInterval)

+ func (a *PercentRank) StartPartition(ctx *sql.Context, interval sql.WindowInterval, buffer sql.WindowBuffer) error

+ func (a *PercentRank) WithWindow(w *sql.WindowDefinition) (sql.WindowFunction, error)

+ type RangeCurrentRowToCurrentRowFramer struct

+ func (f *RangeCurrentRowToCurrentRowFramer) FirstIdx() int

+ func (f *RangeCurrentRowToCurrentRowFramer) Interval() (sql.WindowInterval, error)

+ func (f *RangeCurrentRowToCurrentRowFramer) LastIdx() int

+ func (f *RangeCurrentRowToCurrentRowFramer) NewFramer(interval sql.WindowInterval) (sql.WindowFramer, error)

+ func (f *RangeCurrentRowToCurrentRowFramer) Next(ctx *sql.Context, buf sql.WindowBuffer) (sql.WindowInterval, error)

+ type RangeCurrentRowToNFollowingFramer struct

+ func (f *RangeCurrentRowToNFollowingFramer) FirstIdx() int

+ func (f *RangeCurrentRowToNFollowingFramer) Interval() (sql.WindowInterval, error)

+ func (f *RangeCurrentRowToNFollowingFramer) LastIdx() int

+ func (f *RangeCurrentRowToNFollowingFramer) NewFramer(interval sql.WindowInterval) (sql.WindowFramer, error)

+ func (f *RangeCurrentRowToNFollowingFramer) Next(ctx *sql.Context, buf sql.WindowBuffer) (sql.WindowInterval, error)

+ type RangeCurrentRowToNPrecedingFramer struct

+ func (f *RangeCurrentRowToNPrecedingFramer) FirstIdx() int

+ func (f *RangeCurrentRowToNPrecedingFramer) Interval() (sql.WindowInterval, error)

+ func (f *RangeCurrentRowToNPrecedingFramer) LastIdx() int

+ func (f *RangeCurrentRowToNPrecedingFramer) NewFramer(interval sql.WindowInterval) (sql.WindowFramer, error)

+ func (f *RangeCurrentRowToNPrecedingFramer) Next(ctx *sql.Context, buf sql.WindowBuffer) (sql.WindowInterval, error)

+ type RangeCurrentRowToUnboundedFollowingFramer struct

+ func (f *RangeCurrentRowToUnboundedFollowingFramer) FirstIdx() int

+ func (f *RangeCurrentRowToUnboundedFollowingFramer) Interval() (sql.WindowInterval, error)

+ func (f *RangeCurrentRowToUnboundedFollowingFramer) LastIdx() int

+ func (f *RangeCurrentRowToUnboundedFollowingFramer) NewFramer(interval sql.WindowInterval) (sql.WindowFramer, error)

+ func (f *RangeCurrentRowToUnboundedFollowingFramer) Next(ctx *sql.Context, buf sql.WindowBuffer) (sql.WindowInterval, error)

+ type RangeNFollowingToCurrentRowFramer struct

+ func (f *RangeNFollowingToCurrentRowFramer) FirstIdx() int

+ func (f *RangeNFollowingToCurrentRowFramer) Interval() (sql.WindowInterval, error)

+ func (f *RangeNFollowingToCurrentRowFramer) LastIdx() int

+ func (f *RangeNFollowingToCurrentRowFramer) NewFramer(interval sql.WindowInterval) (sql.WindowFramer, error)

+ func (f *RangeNFollowingToCurrentRowFramer) Next(ctx *sql.Context, buf sql.WindowBuffer) (sql.WindowInterval, error)

+ type RangeNFollowingToNFollowingFramer struct

+ func (f *RangeNFollowingToNFollowingFramer) FirstIdx() int

+ func (f *RangeNFollowingToNFollowingFramer) Interval() (sql.WindowInterval, error)

+ func (f *RangeNFollowingToNFollowingFramer) LastIdx() int

+ func (f *RangeNFollowingToNFollowingFramer) NewFramer(interval sql.WindowInterval) (sql.WindowFramer, error)

+ func (f *RangeNFollowingToNFollowingFramer) Next(ctx *sql.Context, buf sql.WindowBuffer) (sql.WindowInterval, error)

+ type RangeNFollowingToNPrecedingFramer struct

+ func (f *RangeNFollowingToNPrecedingFramer) FirstIdx() int

+ func (f *RangeNFollowingToNPrecedingFramer) Interval() (sql.WindowInterval, error)

+ func (f *RangeNFollowingToNPrecedingFramer) LastIdx() int

+ func (f *RangeNFollowingToNPrecedingFramer) NewFramer(interval sql.WindowInterval) (sql.WindowFramer, error)

+ func (f *RangeNFollowingToNPrecedingFramer) Next(ctx *sql.Context, buf sql.WindowBuffer) (sql.WindowInterval, error)

+ type RangeNFollowingToUnboundedFollowingFramer struct

+ func (f *RangeNFollowingToUnboundedFollowingFramer) FirstIdx() int

+ func (f *RangeNFollowingToUnboundedFollowingFramer) Interval() (sql.WindowInterval, error)

+ func (f *RangeNFollowingToUnboundedFollowingFramer) LastIdx() int

+ func (f *RangeNFollowingToUnboundedFollowingFramer) NewFramer(interval sql.WindowInterval) (sql.WindowFramer, error)

+ func (f *RangeNFollowingToUnboundedFollowingFramer) Next(ctx *sql.Context, buf sql.WindowBuffer) (sql.WindowInterval, error)

+ type RangeNPrecedingToCurrentRowFramer struct

+ func (f *RangeNPrecedingToCurrentRowFramer) FirstIdx() int

+ func (f *RangeNPrecedingToCurrentRowFramer) Interval() (sql.WindowInterval, error)

+ func (f *RangeNPrecedingToCurrentRowFramer) LastIdx() int

+ func (f *RangeNPrecedingToCurrentRowFramer) NewFramer(interval sql.WindowInterval) (sql.WindowFramer, error)

+ func (f *RangeNPrecedingToCurrentRowFramer) Next(ctx *sql.Context, buf sql.WindowBuffer) (sql.WindowInterval, error)

+ type RangeNPrecedingToNFollowingFramer struct

+ func (f *RangeNPrecedingToNFollowingFramer) FirstIdx() int

+ func (f *RangeNPrecedingToNFollowingFramer) Interval() (sql.WindowInterval, error)

+ func (f *RangeNPrecedingToNFollowingFramer) LastIdx() int

+ func (f *RangeNPrecedingToNFollowingFramer) NewFramer(interval sql.WindowInterval) (sql.WindowFramer, error)

+ func (f *RangeNPrecedingToNFollowingFramer) Next(ctx *sql.Context, buf sql.WindowBuffer) (sql.WindowInterval, error)

+ type RangeNPrecedingToNPrecedingFramer struct

+ func (f *RangeNPrecedingToNPrecedingFramer) FirstIdx() int

+ func (f *RangeNPrecedingToNPrecedingFramer) Interval() (sql.WindowInterval, error)

+ func (f *RangeNPrecedingToNPrecedingFramer) LastIdx() int

+ func (f *RangeNPrecedingToNPrecedingFramer) NewFramer(interval sql.WindowInterval) (sql.WindowFramer, error)

+ func (f *RangeNPrecedingToNPrecedingFramer) Next(ctx *sql.Context, buf sql.WindowBuffer) (sql.WindowInterval, error)

+ type RangeNPrecedingToUnboundedFollowingFramer struct

+ func (f *RangeNPrecedingToUnboundedFollowingFramer) FirstIdx() int

+ func (f *RangeNPrecedingToUnboundedFollowingFramer) Interval() (sql.WindowInterval, error)

+ func (f *RangeNPrecedingToUnboundedFollowingFramer) LastIdx() int

+ func (f *RangeNPrecedingToUnboundedFollowingFramer) NewFramer(interval sql.WindowInterval) (sql.WindowFramer, error)

+ func (f *RangeNPrecedingToUnboundedFollowingFramer) Next(ctx *sql.Context, buf sql.WindowBuffer) (sql.WindowInterval, error)

+ type RangeUnboundedPrecedingToCurrentRowFramer struct

+ func (f *RangeUnboundedPrecedingToCurrentRowFramer) FirstIdx() int

+ func (f *RangeUnboundedPrecedingToCurrentRowFramer) Interval() (sql.WindowInterval, error)

+ func (f *RangeUnboundedPrecedingToCurrentRowFramer) LastIdx() int

+ func (f *RangeUnboundedPrecedingToCurrentRowFramer) NewFramer(interval sql.WindowInterval) (sql.WindowFramer, error)

+ func (f *RangeUnboundedPrecedingToCurrentRowFramer) Next(ctx *sql.Context, buf sql.WindowBuffer) (sql.WindowInterval, error)

+ type RangeUnboundedPrecedingToNFollowingFramer struct

+ func (f *RangeUnboundedPrecedingToNFollowingFramer) FirstIdx() int

+ func (f *RangeUnboundedPrecedingToNFollowingFramer) Interval() (sql.WindowInterval, error)

+ func (f *RangeUnboundedPrecedingToNFollowingFramer) LastIdx() int

+ func (f *RangeUnboundedPrecedingToNFollowingFramer) NewFramer(interval sql.WindowInterval) (sql.WindowFramer, error)

+ func (f *RangeUnboundedPrecedingToNFollowingFramer) Next(ctx *sql.Context, buf sql.WindowBuffer) (sql.WindowInterval, error)

+ type RangeUnboundedPrecedingToNPrecedingFramer struct

+ func (f *RangeUnboundedPrecedingToNPrecedingFramer) FirstIdx() int

+ func (f *RangeUnboundedPrecedingToNPrecedingFramer) Interval() (sql.WindowInterval, error)

+ func (f *RangeUnboundedPrecedingToNPrecedingFramer) LastIdx() int

+ func (f *RangeUnboundedPrecedingToNPrecedingFramer) NewFramer(interval sql.WindowInterval) (sql.WindowFramer, error)

+ func (f *RangeUnboundedPrecedingToNPrecedingFramer) Next(ctx *sql.Context, buf sql.WindowBuffer) (sql.WindowInterval, error)

+ type RangeUnboundedPrecedingToUnboundedFollowingFramer struct

+ func (f *RangeUnboundedPrecedingToUnboundedFollowingFramer) FirstIdx() int

+ func (f *RangeUnboundedPrecedingToUnboundedFollowingFramer) Interval() (sql.WindowInterval, error)

+ func (f *RangeUnboundedPrecedingToUnboundedFollowingFramer) LastIdx() int

+ func (f *RangeUnboundedPrecedingToUnboundedFollowingFramer) NewFramer(interval sql.WindowInterval) (sql.WindowFramer, error)

+ func (f *RangeUnboundedPrecedingToUnboundedFollowingFramer) Next(ctx *sql.Context, buf sql.WindowBuffer) (sql.WindowInterval, error)

+ type RowNumber struct

+ func NewRowNumber() *RowNumber

+ func (a *RowNumber) Compute(ctx *sql.Context, interval sql.WindowInterval, buffer sql.WindowBuffer) interface{}

+ func (a *RowNumber) DefaultFramer() sql.WindowFramer

+ func (a *RowNumber) Dispose()

+ func (a *RowNumber) NewSlidingFrameInterval(added, dropped sql.WindowInterval)

+ func (a *RowNumber) StartPartition(ctx *sql.Context, interval sql.WindowInterval, buffer sql.WindowBuffer) error

+ func (a *RowNumber) WithWindow(w *sql.WindowDefinition) (sql.WindowFunction, error)

+ type RowsCurrentRowToCurrentRowFramer struct

+ func (f *RowsCurrentRowToCurrentRowFramer) FirstIdx() int

+ func (f *RowsCurrentRowToCurrentRowFramer) Interval() (sql.WindowInterval, error)

+ func (f *RowsCurrentRowToCurrentRowFramer) LastIdx() int

+ func (f *RowsCurrentRowToCurrentRowFramer) NewFramer(interval sql.WindowInterval) (sql.WindowFramer, error)

+ func (f *RowsCurrentRowToCurrentRowFramer) Next(ctx *sql.Context, buffer sql.WindowBuffer) (sql.WindowInterval, error)

+ type RowsCurrentRowToNFollowingFramer struct

+ func (f *RowsCurrentRowToNFollowingFramer) FirstIdx() int

+ func (f *RowsCurrentRowToNFollowingFramer) Interval() (sql.WindowInterval, error)

+ func (f *RowsCurrentRowToNFollowingFramer) LastIdx() int

+ func (f *RowsCurrentRowToNFollowingFramer) NewFramer(interval sql.WindowInterval) (sql.WindowFramer, error)

+ func (f *RowsCurrentRowToNFollowingFramer) Next(ctx *sql.Context, buffer sql.WindowBuffer) (sql.WindowInterval, error)

+ type RowsCurrentRowToNPrecedingFramer struct

+ func (f *RowsCurrentRowToNPrecedingFramer) FirstIdx() int

+ func (f *RowsCurrentRowToNPrecedingFramer) Interval() (sql.WindowInterval, error)

+ func (f *RowsCurrentRowToNPrecedingFramer) LastIdx() int

+ func (f *RowsCurrentRowToNPrecedingFramer) NewFramer(interval sql.WindowInterval) (sql.WindowFramer, error)

+ func (f *RowsCurrentRowToNPrecedingFramer) Next(ctx *sql.Context, buffer sql.WindowBuffer) (sql.WindowInterval, error)

+ type RowsCurrentRowToUnboundedFollowingFramer struct

+ func (f *RowsCurrentRowToUnboundedFollowingFramer) FirstIdx() int

+ func (f *RowsCurrentRowToUnboundedFollowingFramer) Interval() (sql.WindowInterval, error)

+ func (f *RowsCurrentRowToUnboundedFollowingFramer) LastIdx() int

+ func (f *RowsCurrentRowToUnboundedFollowingFramer) NewFramer(interval sql.WindowInterval) (sql.WindowFramer, error)

+ func (f *RowsCurrentRowToUnboundedFollowingFramer) Next(ctx *sql.Context, buffer sql.WindowBuffer) (sql.WindowInterval, error)

+ type RowsNFollowingToCurrentRowFramer struct

+ func (f *RowsNFollowingToCurrentRowFramer) FirstIdx() int

+ func (f *RowsNFollowingToCurrentRowFramer) Interval() (sql.WindowInterval, error)

+ func (f *RowsNFollowingToCurrentRowFramer) LastIdx() int

+ func (f *RowsNFollowingToCurrentRowFramer) NewFramer(interval sql.WindowInterval) (sql.WindowFramer, error)

+ func (f *RowsNFollowingToCurrentRowFramer) Next(ctx *sql.Context, buffer sql.WindowBuffer) (sql.WindowInterval, error)

+ type RowsNFollowingToNFollowingFramer struct

+ func (f *RowsNFollowingToNFollowingFramer) FirstIdx() int

+ func (f *RowsNFollowingToNFollowingFramer) Interval() (sql.WindowInterval, error)

+ func (f *RowsNFollowingToNFollowingFramer) LastIdx() int

+ func (f *RowsNFollowingToNFollowingFramer) NewFramer(interval sql.WindowInterval) (sql.WindowFramer, error)

+ func (f *RowsNFollowingToNFollowingFramer) Next(ctx *sql.Context, buffer sql.WindowBuffer) (sql.WindowInterval, error)

+ type RowsNFollowingToNPrecedingFramer struct

+ func (f *RowsNFollowingToNPrecedingFramer) FirstIdx() int

+ func (f *RowsNFollowingToNPrecedingFramer) Interval() (sql.WindowInterval, error)

+ func (f *RowsNFollowingToNPrecedingFramer) LastIdx() int

+ func (f *RowsNFollowingToNPrecedingFramer) NewFramer(interval sql.WindowInterval) (sql.WindowFramer, error)

+ func (f *RowsNFollowingToNPrecedingFramer) Next(ctx *sql.Context, buffer sql.WindowBuffer) (sql.WindowInterval, error)

+ type RowsNFollowingToUnboundedFollowingFramer struct

+ func (f *RowsNFollowingToUnboundedFollowingFramer) FirstIdx() int

+ func (f *RowsNFollowingToUnboundedFollowingFramer) Interval() (sql.WindowInterval, error)

+ func (f *RowsNFollowingToUnboundedFollowingFramer) LastIdx() int

+ func (f *RowsNFollowingToUnboundedFollowingFramer) NewFramer(interval sql.WindowInterval) (sql.WindowFramer, error)

+ func (f *RowsNFollowingToUnboundedFollowingFramer) Next(ctx *sql.Context, buffer sql.WindowBuffer) (sql.WindowInterval, error)

+ type RowsNPrecedingToCurrentRowFramer struct

+ func (f *RowsNPrecedingToCurrentRowFramer) FirstIdx() int

+ func (f *RowsNPrecedingToCurrentRowFramer) Interval() (sql.WindowInterval, error)

+ func (f *RowsNPrecedingToCurrentRowFramer) LastIdx() int

+ func (f *RowsNPrecedingToCurrentRowFramer) NewFramer(interval sql.WindowInterval) (sql.WindowFramer, error)

+ func (f *RowsNPrecedingToCurrentRowFramer) Next(ctx *sql.Context, buffer sql.WindowBuffer) (sql.WindowInterval, error)

+ type RowsNPrecedingToNFollowingFramer struct

+ func (f *RowsNPrecedingToNFollowingFramer) FirstIdx() int

+ func (f *RowsNPrecedingToNFollowingFramer) Interval() (sql.WindowInterval, error)

+ func (f *RowsNPrecedingToNFollowingFramer) LastIdx() int

+ func (f *RowsNPrecedingToNFollowingFramer) NewFramer(interval sql.WindowInterval) (sql.WindowFramer, error)

+ func (f *RowsNPrecedingToNFollowingFramer) Next(ctx *sql.Context, buffer sql.WindowBuffer) (sql.WindowInterval, error)

+ type RowsNPrecedingToNPrecedingFramer struct

+ func (f *RowsNPrecedingToNPrecedingFramer) FirstIdx() int

+ func (f *RowsNPrecedingToNPrecedingFramer) Interval() (sql.WindowInterval, error)

+ func (f *RowsNPrecedingToNPrecedingFramer) LastIdx() int

+ func (f *RowsNPrecedingToNPrecedingFramer) NewFramer(interval sql.WindowInterval) (sql.WindowFramer, error)

+ func (f *RowsNPrecedingToNPrecedingFramer) Next(ctx *sql.Context, buffer sql.WindowBuffer) (sql.WindowInterval, error)

+ type RowsNPrecedingToUnboundedFollowingFramer struct

+ func (f *RowsNPrecedingToUnboundedFollowingFramer) FirstIdx() int

+ func (f *RowsNPrecedingToUnboundedFollowingFramer) Interval() (sql.WindowInterval, error)

+ func (f *RowsNPrecedingToUnboundedFollowingFramer) LastIdx() int

+ func (f *RowsNPrecedingToUnboundedFollowingFramer) NewFramer(interval sql.WindowInterval) (sql.WindowFramer, error)

+ func (f *RowsNPrecedingToUnboundedFollowingFramer) Next(ctx *sql.Context, buffer sql.WindowBuffer) (sql.WindowInterval, error)

+ type RowsUnboundedPrecedingToCurrentRowFramer struct

+ func NewUnboundedPrecedingToCurrentRowFramer() *RowsUnboundedPrecedingToCurrentRowFramer

+ func (f *RowsUnboundedPrecedingToCurrentRowFramer) FirstIdx() int

+ func (f *RowsUnboundedPrecedingToCurrentRowFramer) Interval() (sql.WindowInterval, error)

+ func (f *RowsUnboundedPrecedingToCurrentRowFramer) LastIdx() int

+ func (f *RowsUnboundedPrecedingToCurrentRowFramer) NewFramer(interval sql.WindowInterval) (sql.WindowFramer, error)

+ func (f *RowsUnboundedPrecedingToCurrentRowFramer) Next(ctx *sql.Context, buffer sql.WindowBuffer) (sql.WindowInterval, error)

+ type RowsUnboundedPrecedingToNFollowingFramer struct

+ func (f *RowsUnboundedPrecedingToNFollowingFramer) FirstIdx() int

+ func (f *RowsUnboundedPrecedingToNFollowingFramer) Interval() (sql.WindowInterval, error)

+ func (f *RowsUnboundedPrecedingToNFollowingFramer) LastIdx() int

+ func (f *RowsUnboundedPrecedingToNFollowingFramer) NewFramer(interval sql.WindowInterval) (sql.WindowFramer, error)

+ func (f *RowsUnboundedPrecedingToNFollowingFramer) Next(ctx *sql.Context, buffer sql.WindowBuffer) (sql.WindowInterval, error)

+ type RowsUnboundedPrecedingToNPrecedingFramer struct

+ func (f *RowsUnboundedPrecedingToNPrecedingFramer) FirstIdx() int

+ func (f *RowsUnboundedPrecedingToNPrecedingFramer) Interval() (sql.WindowInterval, error)

+ func (f *RowsUnboundedPrecedingToNPrecedingFramer) LastIdx() int

+ func (f *RowsUnboundedPrecedingToNPrecedingFramer) NewFramer(interval sql.WindowInterval) (sql.WindowFramer, error)

+ func (f *RowsUnboundedPrecedingToNPrecedingFramer) Next(ctx *sql.Context, buffer sql.WindowBuffer) (sql.WindowInterval, error)

+ type RowsUnboundedPrecedingToUnboundedFollowingFramer struct

+ func (f *RowsUnboundedPrecedingToUnboundedFollowingFramer) FirstIdx() int

+ func (f *RowsUnboundedPrecedingToUnboundedFollowingFramer) Interval() (sql.WindowInterval, error)

+ func (f *RowsUnboundedPrecedingToUnboundedFollowingFramer) LastIdx() int

+ func (f *RowsUnboundedPrecedingToUnboundedFollowingFramer) NewFramer(interval sql.WindowInterval) (sql.WindowFramer, error)

+ func (f *RowsUnboundedPrecedingToUnboundedFollowingFramer) Next(ctx *sql.Context, buffer sql.WindowBuffer) (sql.WindowInterval, error)

type Sum

+ func (a *Sum) Children() []sql.Expression

+ func (a *Sum) IsNullable() bool

+ func (a *Sum) NewWindowFunction() (sql.WindowFunction, error)

+ func (a *Sum) Resolved() bool

+ func (a *Sum) Window() *sql.WindowDefinition

+ func (a *Sum) WithWindow(window *sql.WindowDefinition) (sql.Aggregation, error)

+ func (a Sum) Description() string

+ type SumAgg struct

+ func NewSumAgg(e sql.Expression) *SumAgg

+ func (a *SumAgg) Compute(ctx *sql.Context, interval sql.WindowInterval, buf sql.WindowBuffer) interface{}

+ func (a *SumAgg) DefaultFramer() sql.WindowFramer

+ func (a *SumAgg) Dispose()

+ func (a *SumAgg) NewSlidingFrameInterval(added, dropped sql.WindowInterval)

+ func (a *SumAgg) StartPartition(ctx *sql.Context, interval sql.WindowInterval, buf sql.WindowBuffer) error

+ func (a *SumAgg) WithWindow(w *sql.WindowDefinition) (sql.WindowFunction, error)

+ type WindowIter struct

+ func NewWindowIter(partitionIters []*WindowPartitionIter, outputOrdinals [][]int, ...) *WindowIter

+ func (i *WindowIter) Close(ctx *sql.Context) error

+ func (i *WindowIter) Dispose()

+ func (i *WindowIter) Next(ctx *sql.Context) (sql.Row, error)

+ type WindowPartition struct

+ Aggs []*Aggregation

+ PartitionBy []sql.Expression

+ SortBy sql.SortFields

+ func NewWindowPartition(partitionBy []sql.Expression, sortBy sql.SortFields, aggs []*Aggregation) *WindowPartition

+ func (w *WindowPartition) AddAggregation(agg *Aggregation)

+ type WindowPartitionIter struct

+ func NewWindowPartitionIter(windowBlock *WindowPartition) *WindowPartitionIter

+ func (i *WindowPartitionIter) Close(ctx *sql.Context) error

+ func (i *WindowPartitionIter) Dispose()

+ func (i *WindowPartitionIter) Next(ctx *sql.Context) (sql.Row, error)

+ func (i *WindowPartitionIter) WindowBlock() *WindowPartition

+ type WindowedJSONArrayAgg struct

+ func NewJsonArrayAgg(expr sql.Expression) *WindowedJSONArrayAgg

+ func (a *WindowedJSONArrayAgg) Compute(ctx *sql.Context, interval sql.WindowInterval, buf sql.WindowBuffer) interface{}

+ func (a *WindowedJSONArrayAgg) DefaultFramer() sql.WindowFramer

+ func (a *WindowedJSONArrayAgg) Dispose()

+ func (a *WindowedJSONArrayAgg) NewSlidingFrameInterval(added, dropped sql.WindowInterval)

+ func (a *WindowedJSONArrayAgg) StartPartition(ctx *sql.Context, interval sql.WindowInterval, buf sql.WindowBuffer) error

+ func (a *WindowedJSONArrayAgg) WithWindow(w *sql.WindowDefinition) (sql.WindowFunction, error)

+ type WindowedJSONObjectAgg struct

+ func NewWindowedJSONObjectAgg(j *JSONObjectAgg) *WindowedJSONObjectAgg

+ func (a *WindowedJSONObjectAgg) Compute(ctx *sql.Context, interval sql.WindowInterval, buf sql.WindowBuffer) interface{}

+ func (a *WindowedJSONObjectAgg) DefaultFramer() sql.WindowFramer

+ func (a *WindowedJSONObjectAgg) Dispose()

+ func (a *WindowedJSONObjectAgg) NewSlidingFrameInterval(added, dropped sql.WindowInterval)

+ func (a *WindowedJSONObjectAgg) StartPartition(ctx *sql.Context, interval sql.WindowInterval, buf sql.WindowBuffer) error

+ func (a *WindowedJSONObjectAgg) WithWindow(w *sql.WindowDefinition) (sql.WindowFunction, error)

v0.11.0

Oct 20, 2021

Changes in this version

+ var ErrEvalUnsupportedOnAggregation = errors.NewKind(...)

type CountDistinct

+ func (c *CountDistinct) FunctionName() string

v0.10.0

Jun 2, 2021

Changes in this version

+ func NewEmptyGroupConcat() sql.Expression

+ type GroupConcat struct

+ func NewGroupConcat(distinct string, orderBy sql.SortFields, separator string, ...) (*GroupConcat, error)

+ func (g *GroupConcat) Children() []sql.Expression

+ func (g *GroupConcat) Eval(ctx *sql.Context, row sql.Row) (interface{}, error)

+ func (g *GroupConcat) FunctionName() string

+ func (g *GroupConcat) IsNullable() bool

+ func (g *GroupConcat) Merge(ctx *sql.Context, buffer, partial sql.Row) error

+ func (g *GroupConcat) NewBuffer() sql.Row

+ func (g *GroupConcat) Resolved() bool

+ func (g *GroupConcat) String() string

+ func (g *GroupConcat) Type() sql.Type

+ func (g *GroupConcat) Update(ctx *sql.Context, buffer, originalRow sql.Row) error

+ func (g *GroupConcat) WithChildren(children ...sql.Expression) (sql.Expression, error)

v0.9.0

Apr 2, 2021

Changes in this version

+ var ErrUnsupportedJSONFunction = errors.NewKind("unsupported JSON function: %s")

+ func NewJSONObjectAgg(key, value sql.Expression) sql.Expression

+ type JSONArrayAgg struct

+ func NewJSONArrayAgg(arg sql.Expression) *JSONArrayAgg

+ func (j *JSONArrayAgg) Eval(ctx *sql.Context, buffer sql.Row) (interface{}, error)

+ func (j *JSONArrayAgg) FunctionName() string

+ func (j *JSONArrayAgg) IsNullable() bool

+ func (j *JSONArrayAgg) Merge(ctx *sql.Context, buffer, partial sql.Row) error

+ func (j *JSONArrayAgg) NewBuffer() sql.Row

+ func (j *JSONArrayAgg) Resolved() bool

+ func (j *JSONArrayAgg) String() string

+ func (j *JSONArrayAgg) Type() sql.Type

+ func (j *JSONArrayAgg) Update(ctx *sql.Context, buffer, row sql.Row) error

+ func (j *JSONArrayAgg) WithChildren(children ...sql.Expression) (sql.Expression, error)

+ type JSONObjectAgg struct

+ func (j JSONObjectAgg) Children() []sql.Expression

+ func (j JSONObjectAgg) Eval(ctx *sql.Context, buffer sql.Row) (interface{}, error)

+ func (j JSONObjectAgg) FunctionName() string

+ func (j JSONObjectAgg) IsNullable() bool

+ func (j JSONObjectAgg) Merge(ctx *sql.Context, buffer, partial sql.Row) error

+ func (j JSONObjectAgg) NewBuffer() sql.Row

+ func (j JSONObjectAgg) Resolved() bool

+ func (j JSONObjectAgg) String() string

+ func (j JSONObjectAgg) Type() sql.Type

+ func (j JSONObjectAgg) Update(ctx *sql.Context, buffer, row sql.Row) error

+ func (j JSONObjectAgg) WithChildren(children ...sql.Expression) (sql.Expression, error)

v0.8.0

Feb 1, 2021

Changes in this version

+ type Avg struct

+ func NewAvg(e sql.Expression) *Avg

+ func (a *Avg) Eval(ctx *sql.Context, buffer sql.Row) (interface{}, error)

+ func (a *Avg) FunctionName() string

+ func (a *Avg) IsNullable() bool

+ func (a *Avg) Merge(ctx *sql.Context, buffer, partial sql.Row) error

+ func (a *Avg) NewBuffer() sql.Row

+ func (a *Avg) String() string

+ func (a *Avg) Type() sql.Type

+ func (a *Avg) Update(ctx *sql.Context, buffer, row sql.Row) error

+ func (a *Avg) WithChildren(children ...sql.Expression) (sql.Expression, error)

+ type Count struct

+ func NewCount(e sql.Expression) *Count

+ func (c *Count) Eval(ctx *sql.Context, buffer sql.Row) (interface{}, error)

+ func (c *Count) FunctionName() string

+ func (c *Count) IsNullable() bool

+ func (c *Count) Merge(ctx *sql.Context, buffer, partial sql.Row) error

+ func (c *Count) NewBuffer() sql.Row

+ func (c *Count) Resolved() bool

+ func (c *Count) String() string

+ func (c *Count) Type() sql.Type

+ func (c *Count) Update(ctx *sql.Context, buffer, row sql.Row) error

+ func (c *Count) WithChildren(children ...sql.Expression) (sql.Expression, error)

+ type CountDistinct struct

+ func NewCountDistinct(e sql.Expression) *CountDistinct

+ func (c *CountDistinct) Eval(ctx *sql.Context, buffer sql.Row) (interface{}, error)

+ func (c *CountDistinct) IsNullable() bool

+ func (c *CountDistinct) Merge(ctx *sql.Context, buffer, partial sql.Row) error

+ func (c *CountDistinct) NewBuffer() sql.Row

+ func (c *CountDistinct) Resolved() bool

+ func (c *CountDistinct) String() string

+ func (c *CountDistinct) Type() sql.Type

+ func (c *CountDistinct) Update(ctx *sql.Context, buffer, row sql.Row) error

+ func (c *CountDistinct) WithChildren(children ...sql.Expression) (sql.Expression, error)

+ type First struct

+ func NewFirst(e sql.Expression) *First

+ func (f *First) Eval(ctx *sql.Context, buffer sql.Row) (interface{}, error)

+ func (f *First) FunctionName() string

+ func (f *First) Merge(ctx *sql.Context, buffer, partial sql.Row) error

+ func (f *First) NewBuffer() sql.Row

+ func (f *First) String() string

+ func (f *First) Type() sql.Type

+ func (f *First) Update(ctx *sql.Context, buffer, row sql.Row) error

+ func (f *First) WithChildren(children ...sql.Expression) (sql.Expression, error)

+ type Last struct

+ func NewLast(e sql.Expression) *Last

+ func (l *Last) Eval(ctx *sql.Context, buffer sql.Row) (interface{}, error)

+ func (l *Last) FunctionName() string

+ func (l *Last) Merge(ctx *sql.Context, buffer, partial sql.Row) error

+ func (l *Last) NewBuffer() sql.Row

+ func (l *Last) String() string

+ func (l *Last) Type() sql.Type

+ func (l *Last) Update(ctx *sql.Context, buffer, row sql.Row) error

+ func (l *Last) WithChildren(children ...sql.Expression) (sql.Expression, error)

+ type Max struct

+ func NewMax(e sql.Expression) *Max

+ func (m *Max) DebugString() string

+ func (m *Max) Eval(ctx *sql.Context, buffer sql.Row) (interface{}, error)

+ func (m *Max) FunctionName() string

+ func (m *Max) IsNullable() bool

+ func (m *Max) Merge(ctx *sql.Context, buffer, partial sql.Row) error

+ func (m *Max) NewBuffer() sql.Row

+ func (m *Max) String() string

+ func (m *Max) Type() sql.Type

+ func (m *Max) Update(ctx *sql.Context, buffer, row sql.Row) error

+ func (m *Max) WithChildren(children ...sql.Expression) (sql.Expression, error)

+ type Min struct

+ func NewMin(e sql.Expression) *Min

+ func (m *Min) Eval(ctx *sql.Context, buffer sql.Row) (interface{}, error)

+ func (m *Min) FunctionName() string

+ func (m *Min) IsNullable() bool

+ func (m *Min) Merge(ctx *sql.Context, buffer, partial sql.Row) error

+ func (m *Min) NewBuffer() sql.Row

+ func (m *Min) String() string

+ func (m *Min) Type() sql.Type

+ func (m *Min) Update(ctx *sql.Context, buffer, row sql.Row) error

+ func (m *Min) WithChildren(children ...sql.Expression) (sql.Expression, error)

+ type Sum struct

+ func NewSum(e sql.Expression) *Sum

+ func (m *Sum) Eval(ctx *sql.Context, buffer sql.Row) (interface{}, error)

+ func (m *Sum) FunctionName() string

+ func (m *Sum) Merge(ctx *sql.Context, buffer, partial sql.Row) error

+ func (m *Sum) NewBuffer() sql.Row

+ func (m *Sum) String() string

+ func (m *Sum) Type() sql.Type

+ func (m *Sum) Update(ctx *sql.Context, buffer, row sql.Row) error

+ func (m *Sum) WithChildren(children ...sql.Expression) (sql.Expression, error)

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