Documentation
¶
Index ¶
- func NewCollectClause(src core.SourceMap, dataSource collections.Iterable, params *Collect) (collections.Iterable, error)
- func NewFilterClause(src core.SourceMap, dataSource collections.Iterable, predicate core.Expression) (collections.Iterable, error)
- func NewLimitClause(src core.SourceMap, dataSource collections.Iterable, count int, offset int) (collections.Iterable, error)
- func NewSortClause(src core.SourceMap, dataSource collections.Iterable, ...) (collections.Iterable, error)
- type Collect
- type CollectAggregate
- type CollectAggregateSelector
- type CollectClause
- type CollectCount
- type CollectGroup
- type CollectIterator
- type CollectProjection
- type CollectSelector
- type FilterClause
- type LimitClause
- type SortClause
- type SorterExpression
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewCollectClause ¶ added in v0.4.0
func NewCollectClause( src core.SourceMap, dataSource collections.Iterable, params *Collect, ) (collections.Iterable, error)
func NewFilterClause ¶
func NewFilterClause( src core.SourceMap, dataSource collections.Iterable, predicate core.Expression, ) (collections.Iterable, error)
func NewLimitClause ¶
func NewLimitClause( src core.SourceMap, dataSource collections.Iterable, count int, offset int, ) (collections.Iterable, error)
func NewSortClause ¶
func NewSortClause( src core.SourceMap, dataSource collections.Iterable, sorters ...*SorterExpression, ) (collections.Iterable, error)
Types ¶
type Collect ¶ added in v0.4.0
type Collect struct {
// contains filtered or unexported fields
}
func NewCollect ¶ added in v0.4.0
func NewCollect( selectors []*CollectSelector, projection *CollectProjection, count *CollectCount, aggregate *CollectAggregate, ) (*Collect, error)
type CollectAggregate ¶ added in v0.4.0
type CollectAggregate struct {
// contains filtered or unexported fields
}
func NewCollectAggregate ¶ added in v0.4.0
func NewCollectAggregate(selectors []*CollectAggregateSelector) (*CollectAggregate, error)
type CollectAggregateSelector ¶ added in v0.4.0
type CollectAggregateSelector struct {
// contains filtered or unexported fields
}
func NewCollectAggregateSelector ¶ added in v0.4.0
func NewCollectAggregateSelector(variable string, aggr []core.Expression, reducer core.Function) (*CollectAggregateSelector, error)
func (*CollectAggregateSelector) Aggregators ¶ added in v0.4.0
func (selector *CollectAggregateSelector) Aggregators() []core.Expression
func (*CollectAggregateSelector) Expression ¶ added in v0.4.0
func (selector *CollectAggregateSelector) Expression() core.Function
func (*CollectAggregateSelector) Variable ¶ added in v0.4.0
func (selector *CollectAggregateSelector) Variable() string
type CollectClause ¶ added in v0.4.0
type CollectClause struct {
// contains filtered or unexported fields
}
func (*CollectClause) Iterate ¶ added in v0.4.0
func (clause *CollectClause) Iterate(ctx context.Context, scope *core.Scope) (collections.Iterator, error)
func (*CollectClause) Variables ¶ added in v0.4.0
func (clause *CollectClause) Variables() collections.Variables
type CollectCount ¶ added in v0.4.0
type CollectCount struct {
// contains filtered or unexported fields
}
func NewCollectCount ¶ added in v0.4.0
func NewCollectCount(variable string) (*CollectCount, error)
type CollectGroup ¶ added in v0.4.0
type CollectGroup struct {
// contains filtered or unexported fields
}
type CollectIterator ¶ added in v0.4.0
type CollectIterator struct {
// contains filtered or unexported fields
}
func NewCollectIterator ¶ added in v0.4.0
func NewCollectIterator( src core.SourceMap, params *Collect, dataSource collections.Iterator, variables collections.Variables, ctx context.Context, scope *core.Scope, ) (*CollectIterator, error)
func (*CollectIterator) HasNext ¶ added in v0.4.0
func (iterator *CollectIterator) HasNext() bool
func (*CollectIterator) Next ¶ added in v0.4.0
func (iterator *CollectIterator) Next() (collections.DataSet, error)
type CollectProjection ¶ added in v0.4.0
type CollectProjection struct {
// contains filtered or unexported fields
}
func NewCollectProjection ¶ added in v0.4.0
func NewCollectProjection(selector *CollectSelector) (*CollectProjection, error)
type CollectSelector ¶ added in v0.4.0
type CollectSelector struct {
// contains filtered or unexported fields
}
func NewCollectSelector ¶ added in v0.4.0
func NewCollectSelector(variable string, exp core.Expression) (*CollectSelector, error)
func (*CollectSelector) Expression ¶ added in v0.4.0
func (selector *CollectSelector) Expression() core.Expression
func (*CollectSelector) Variable ¶ added in v0.4.0
func (selector *CollectSelector) Variable() string
type FilterClause ¶
type FilterClause struct {
// contains filtered or unexported fields
}
func (*FilterClause) Iterate ¶
func (clause *FilterClause) Iterate(ctx context.Context, scope *core.Scope) (collections.Iterator, error)
func (*FilterClause) Variables ¶ added in v0.4.0
func (clause *FilterClause) Variables() collections.Variables
type LimitClause ¶
type LimitClause struct {
// contains filtered or unexported fields
}
func (*LimitClause) Iterate ¶
func (clause *LimitClause) Iterate(ctx context.Context, scope *core.Scope) (collections.Iterator, error)
func (*LimitClause) Variables ¶ added in v0.4.0
func (clause *LimitClause) Variables() collections.Variables
type SortClause ¶
type SortClause struct {
// contains filtered or unexported fields
}
func (*SortClause) Iterate ¶
func (clause *SortClause) Iterate(ctx context.Context, scope *core.Scope) (collections.Iterator, error)
func (*SortClause) Variables ¶ added in v0.4.0
func (clause *SortClause) Variables() collections.Variables
type SorterExpression ¶
type SorterExpression struct {
// contains filtered or unexported fields
}
func NewSorterExpression ¶
func NewSorterExpression(expression core.Expression, direction collections.SortDirection) (*SorterExpression, error)
Source Files
Click to show internal directories.
Click to hide internal directories.