Versions in this module Expand all Collapse all v1 v1.0.1 Jul 31, 2024 Changes in this version + var ErrEvalUnsupportedOnAggregation = errors.NewKind(...) + 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") + func NewAnyValueBuffer(child sql.Expression) *anyValueBuffer + func NewAvgBuffer(child sql.Expression) *avgBuffer + func NewBitAndBuffer(child sql.Expression) *bitAndBuffer + func NewBitOrBuffer(child sql.Expression) *bitOrBuffer + func NewBitXorBuffer(child sql.Expression) *bitXorBuffer + func NewCountBuffer(child sql.Expression) *countBuffer + func NewCountDistinctBuffer(children []sql.Expression) *countDistinctBuffer + func NewEmptyGroupConcat() sql.Expression + func NewFirstBuffer(child sql.Expression) *firstBuffer + func NewJSONObjectAgg(key, value sql.Expression) sql.Expression + 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 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) Id() sql.ColumnId + 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) WithId(id sql.ColumnId) sql.IdExpression + func (a *AnyValue) WithWindow(window *sql.WindowDefinition) sql.WindowAdaptableExpression + 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 struct + func NewAvg(e sql.Expression) *Avg + func (a *Avg) Children() []sql.Expression + func (a *Avg) CollationCoercibility(ctx *sql.Context) (collation sql.CollationID, coercibility byte) + func (a *Avg) DebugString() string + func (a *Avg) Eval(ctx *sql.Context, row sql.Row) (interface{}, error) + func (a *Avg) Id() sql.ColumnId + func (a *Avg) IsNullable() bool + func (a *Avg) NewBuffer() (sql.AggregationBuffer, error) + func (a *Avg) NewWindowFunction() (sql.WindowFunction, error) + func (a *Avg) Resolved() bool + func (a *Avg) String() string + func (a *Avg) Type() sql.Type + func (a *Avg) Window() *sql.WindowDefinition + func (a *Avg) WithChildren(children ...sql.Expression) (sql.Expression, error) + func (a *Avg) WithId(id sql.ColumnId) sql.IdExpression + func (a *Avg) WithWindow(window *sql.WindowDefinition) sql.WindowAdaptableExpression + func (a Avg) Description() string + func (a Avg) FunctionName() 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 BitAnd struct + func NewBitAnd(e sql.Expression) *BitAnd + func (a *BitAnd) Children() []sql.Expression + func (a *BitAnd) CollationCoercibility(ctx *sql.Context) (collation sql.CollationID, coercibility byte) + func (a *BitAnd) DebugString() string + func (a *BitAnd) Eval(ctx *sql.Context, row sql.Row) (interface{}, error) + func (a *BitAnd) Id() sql.ColumnId + 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) WithId(id sql.ColumnId) sql.IdExpression + func (a *BitAnd) WithWindow(window *sql.WindowDefinition) sql.WindowAdaptableExpression + 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) CollationCoercibility(ctx *sql.Context) (collation sql.CollationID, coercibility byte) + func (a *BitOr) DebugString() string + func (a *BitOr) Eval(ctx *sql.Context, row sql.Row) (interface{}, error) + func (a *BitOr) Id() sql.ColumnId + 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) WithId(id sql.ColumnId) sql.IdExpression + func (a *BitOr) WithWindow(window *sql.WindowDefinition) sql.WindowAdaptableExpression + 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) CollationCoercibility(ctx *sql.Context) (collation sql.CollationID, coercibility byte) + func (a *BitXor) DebugString() string + func (a *BitXor) Eval(ctx *sql.Context, row sql.Row) (interface{}, error) + func (a *BitXor) Id() sql.ColumnId + 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) WithId(id sql.ColumnId) sql.IdExpression + func (a *BitXor) WithWindow(window *sql.WindowDefinition) sql.WindowAdaptableExpression + 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 Count struct + func NewCount(e sql.Expression) *Count + func (a *Count) Children() []sql.Expression + func (a *Count) CollationCoercibility(ctx *sql.Context) (collation sql.CollationID, coercibility byte) + func (a *Count) DebugString() string + func (a *Count) Eval(ctx *sql.Context, row sql.Row) (interface{}, error) + func (a *Count) Id() sql.ColumnId + func (a *Count) IsNullable() bool + func (a *Count) NewBuffer() (sql.AggregationBuffer, error) + func (a *Count) NewWindowFunction() (sql.WindowFunction, error) + func (a *Count) Resolved() bool + func (a *Count) String() string + func (a *Count) Type() sql.Type + func (a *Count) Window() *sql.WindowDefinition + func (a *Count) WithChildren(children ...sql.Expression) (sql.Expression, error) + func (a *Count) WithId(id sql.ColumnId) sql.IdExpression + func (a *Count) WithWindow(window *sql.WindowDefinition) sql.WindowAdaptableExpression + func (a Count) Description() string + func (a Count) FunctionName() 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 struct + func NewCountDistinct(exprs ...sql.Expression) *CountDistinct + func (*CountDistinct) CollationCoercibility(ctx *sql.Context) (collation sql.CollationID, coercibility byte) + func (a *CountDistinct) Children() []sql.Expression + func (a *CountDistinct) Description() string + func (a *CountDistinct) Eval(ctx *sql.Context, row sql.Row) (interface{}, error) + func (a *CountDistinct) FunctionName() string + func (a *CountDistinct) Id() sql.ColumnId + func (a *CountDistinct) IsNullable() bool + func (a *CountDistinct) NewBuffer() (sql.AggregationBuffer, error) + func (a *CountDistinct) NewWindowFunction() (sql.WindowFunction, error) + func (a *CountDistinct) String() string + func (a *CountDistinct) Type() sql.Type + func (a *CountDistinct) Window() *sql.WindowDefinition + func (a *CountDistinct) WithChildren(children ...sql.Expression) (sql.Expression, error) + func (a *CountDistinct) WithId(id sql.ColumnId) sql.IdExpression + func (a *CountDistinct) WithWindow(window *sql.WindowDefinition) sql.WindowAdaptableExpression + 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 First struct + func NewFirst(e sql.Expression) *First + func (a *First) Children() []sql.Expression + func (a *First) CollationCoercibility(ctx *sql.Context) (collation sql.CollationID, coercibility byte) + func (a *First) DebugString() string + func (a *First) Eval(ctx *sql.Context, row sql.Row) (interface{}, error) + func (a *First) Id() sql.ColumnId + func (a *First) IsNullable() bool + func (a *First) NewBuffer() (sql.AggregationBuffer, error) + func (a *First) NewWindowFunction() (sql.WindowFunction, error) + func (a *First) Resolved() bool + func (a *First) String() string + func (a *First) Type() sql.Type + func (a *First) Window() *sql.WindowDefinition + func (a *First) WithChildren(children ...sql.Expression) (sql.Expression, error) + func (a *First) WithId(id sql.ColumnId) sql.IdExpression + func (a *First) WithWindow(window *sql.WindowDefinition) sql.WindowAdaptableExpression + func (a First) Description() string + func (a First) FunctionName() 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 struct + func NewGroupConcat(distinct string, orderBy sql.SortFields, separator string, ...) *GroupConcat + func (a *GroupConcat) Id() sql.ColumnId + func (a *GroupConcat) WithId(id sql.ColumnId) sql.IdExpression + func (g *GroupConcat) Children() []sql.Expression + func (g *GroupConcat) Description() string + 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) NewBuffer() (sql.AggregationBuffer, error) + func (g *GroupConcat) NewWindowFunction() (sql.WindowFunction, error) + func (g *GroupConcat) Resolved() bool + func (g *GroupConcat) String() string + func (g *GroupConcat) Type() sql.Type + func (g *GroupConcat) Window() *sql.WindowDefinition + func (g *GroupConcat) WithChildren(children ...sql.Expression) (sql.Expression, error) + func (g *GroupConcat) WithWindow(window *sql.WindowDefinition) sql.WindowAdaptableExpression + 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 struct + func (*JSONObjectAgg) CollationCoercibility(ctx *sql.Context) (collation sql.CollationID, coercibility byte) + func (j *JSONObjectAgg) Children() []sql.Expression + func (j *JSONObjectAgg) Description() string + func (j *JSONObjectAgg) Eval(ctx *sql.Context, row sql.Row) (interface{}, error) + func (j *JSONObjectAgg) FunctionName() string + func (j *JSONObjectAgg) Id() sql.ColumnId + func (j *JSONObjectAgg) IsNullable() bool + func (j *JSONObjectAgg) NewBuffer() (sql.AggregationBuffer, error) + func (j *JSONObjectAgg) NewWindowFunction() (sql.WindowFunction, error) + func (j *JSONObjectAgg) Resolved() bool + func (j *JSONObjectAgg) String() string + func (j *JSONObjectAgg) Type() sql.Type + func (j *JSONObjectAgg) Window() *sql.WindowDefinition + func (j *JSONObjectAgg) WithChildren(children ...sql.Expression) (sql.Expression, error) + func (j *JSONObjectAgg) WithId(id sql.ColumnId) sql.IdExpression + func (j *JSONObjectAgg) WithWindow(window *sql.WindowDefinition) sql.WindowAdaptableExpression + type JsonArray struct + func NewJsonArray(e sql.Expression) *JsonArray + func (a *JsonArray) Children() []sql.Expression + func (a *JsonArray) CollationCoercibility(ctx *sql.Context) (collation sql.CollationID, coercibility byte) + func (a *JsonArray) DebugString() string + func (a *JsonArray) Eval(ctx *sql.Context, row sql.Row) (interface{}, error) + func (a *JsonArray) Id() sql.ColumnId + 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) WithId(id sql.ColumnId) sql.IdExpression + func (a *JsonArray) WithWindow(window *sql.WindowDefinition) sql.WindowAdaptableExpression + 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 struct + func NewLast(e sql.Expression) *Last + func (a *Last) Children() []sql.Expression + func (a *Last) CollationCoercibility(ctx *sql.Context) (collation sql.CollationID, coercibility byte) + func (a *Last) DebugString() string + func (a *Last) Eval(ctx *sql.Context, row sql.Row) (interface{}, error) + func (a *Last) Id() sql.ColumnId + func (a *Last) IsNullable() bool + func (a *Last) NewBuffer() (sql.AggregationBuffer, error) + func (a *Last) NewWindowFunction() (sql.WindowFunction, error) + func (a *Last) Resolved() bool + func (a *Last) String() string + func (a *Last) Type() sql.Type + func (a *Last) Window() *sql.WindowDefinition + func (a *Last) WithChildren(children ...sql.Expression) (sql.Expression, error) + func (a *Last) WithId(id sql.ColumnId) sql.IdExpression + func (a *Last) WithWindow(window *sql.WindowDefinition) sql.WindowAdaptableExpression + func (a Last) Description() string + func (a Last) FunctionName() 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 struct + func NewMax(e sql.Expression) *Max + func (a *Max) Children() []sql.Expression + func (a *Max) CollationCoercibility(ctx *sql.Context) (collation sql.CollationID, coercibility byte) + func (a *Max) DebugString() string + func (a *Max) Eval(ctx *sql.Context, row sql.Row) (interface{}, error) + func (a *Max) Id() sql.ColumnId + func (a *Max) IsNullable() bool + func (a *Max) NewBuffer() (sql.AggregationBuffer, error) + func (a *Max) NewWindowFunction() (sql.WindowFunction, error) + func (a *Max) Resolved() bool + func (a *Max) String() string + func (a *Max) Type() sql.Type + func (a *Max) Window() *sql.WindowDefinition + func (a *Max) WithChildren(children ...sql.Expression) (sql.Expression, error) + func (a *Max) WithId(id sql.ColumnId) sql.IdExpression + func (a *Max) WithWindow(window *sql.WindowDefinition) sql.WindowAdaptableExpression + func (a Max) Description() string + func (a Max) FunctionName() 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 struct + func NewMin(e sql.Expression) *Min + func (a *Min) Children() []sql.Expression + func (a *Min) CollationCoercibility(ctx *sql.Context) (collation sql.CollationID, coercibility byte) + func (a *Min) DebugString() string + func (a *Min) Eval(ctx *sql.Context, row sql.Row) (interface{}, error) + func (a *Min) Id() sql.ColumnId + func (a *Min) IsNullable() bool + func (a *Min) NewBuffer() (sql.AggregationBuffer, error) + func (a *Min) NewWindowFunction() (sql.WindowFunction, error) + func (a *Min) Resolved() bool + func (a *Min) String() string + func (a *Min) Type() sql.Type + func (a *Min) Window() *sql.WindowDefinition + func (a *Min) WithChildren(children ...sql.Expression) (sql.Expression, error) + func (a *Min) WithId(id sql.ColumnId) sql.IdExpression + func (a *Min) WithWindow(window *sql.WindowDefinition) sql.WindowAdaptableExpression + func (a Min) Description() string + func (a Min) FunctionName() 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 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) + 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 struct + func NewSum(e sql.Expression) *Sum + func (a *Sum) Children() []sql.Expression + func (a *Sum) CollationCoercibility(ctx *sql.Context) (collation sql.CollationID, coercibility byte) + func (a *Sum) DebugString() string + func (a *Sum) Eval(ctx *sql.Context, row sql.Row) (interface{}, error) + func (a *Sum) Id() sql.ColumnId + func (a *Sum) IsNullable() bool + func (a *Sum) NewBuffer() (sql.AggregationBuffer, error) + func (a *Sum) NewWindowFunction() (sql.WindowFunction, error) + func (a *Sum) Resolved() bool + func (a *Sum) String() string + func (a *Sum) Type() sql.Type + func (a *Sum) Window() *sql.WindowDefinition + func (a *Sum) WithChildren(children ...sql.Expression) (sql.Expression, error) + func (a *Sum) WithId(id sql.ColumnId) sql.IdExpression + func (a *Sum) WithWindow(window *sql.WindowDefinition) sql.WindowAdaptableExpression + func (a Sum) Description() string + func (a Sum) FunctionName() 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)
Go to main page