rows

package
v0.18.0 Latest Latest
Warning

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

 Go to latest Published: Nov 5, 2025 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type EmitIterator added in v0.17.0 

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

func (*EmitIterator) Close added in v0.17.0 

func (it *EmitIterator) Close() error

func (*EmitIterator) Env added in v0.17.0 

func (it *EmitIterator) Env() *environment.Environment

func (*EmitIterator) Error added in v0.17.0 

func (it *EmitIterator) Error() error

func (*EmitIterator) Next added in v0.17.0 

func (it *EmitIterator) Next() bool

func (*EmitIterator) Row added in v0.17.0 

func (it *EmitIterator) Row() (database.Row, error)

func (*EmitIterator) Valid added in v0.17.0 

func (it *EmitIterator) Valid() bool

type EmitOperator 

type EmitOperator struct {
	stream.BaseOperator
	Rows []expr.Row
	// contains filtered or unexported fields
}

func Emit 

func Emit(columns []string, rows ...expr.Row) *EmitOperator

Emit creates an operator that iterates over the given expressions. Each expression must evaluate to an row.

func (*EmitOperator) Columns added in v0.17.0 

func (it *EmitOperator) Columns(env *environment.Environment) ([]string, error)

func (*EmitOperator) Iterator added in v0.17.0 

func (op *EmitOperator) Iterator(in *environment.Environment) (stream.Iterator, error)

func (*EmitOperator) String 

func (op *EmitOperator) String() string

type ExprIterator added in v0.17.0 

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

func (*ExprIterator) Close added in v0.17.0 

func (it *ExprIterator) Close() error

func (*ExprIterator) Error added in v0.17.0 

func (it *ExprIterator) Error() error

func (*ExprIterator) Next added in v0.17.0 

func (it *ExprIterator) Next() bool

func (*ExprIterator) Row added in v0.17.0 

func (it *ExprIterator) Row() (database.Row, error)

type FilterIterator added in v0.17.0 

type FilterIterator struct {
	stream.Iterator
	// contains filtered or unexported fields
}

func (*FilterIterator) Error added in v0.17.0 

func (it *FilterIterator) Error() error

func (*FilterIterator) Next added in v0.17.0 

func (it *FilterIterator) Next() bool

func (*FilterIterator) Row added in v0.17.0 

func (it *FilterIterator) Row() (database.Row, error)

type FilterOperator 

type FilterOperator struct {
	stream.BaseOperator
	Expr expr.Expr
}

A FilterOperator filters values based on a given expression.

func Filter 

func Filter(e expr.Expr) *FilterOperator

Filter evaluates e for each incoming value and filters any value whose result is not truthy.

func (*FilterOperator) Iterator added in v0.17.0 

func (op *FilterOperator) Iterator(in *environment.Environment) (stream.Iterator, error)

Iterate implements the Operator interface.

func (*FilterOperator) String 

func (op *FilterOperator) String() string

type GroupAggregateOperator 

type GroupAggregateOperator struct {
	stream.BaseOperator
	Builders []expr.AggregatorBuilder
	E        expr.Expr
}

func GroupAggregate 

func GroupAggregate(groupBy expr.Expr, builders ...expr.AggregatorBuilder) *GroupAggregateOperator

GroupAggregate consumes the incoming stream and outputs one value per group. It assumes the stream is sorted by the groupBy expression.

func (*GroupAggregateOperator) Columns added in v0.17.0 

func (op *GroupAggregateOperator) Columns(env *environment.Environment) ([]string, error)

func (*GroupAggregateOperator) Iterator added in v0.17.0 

func (op *GroupAggregateOperator) Iterator(in *environment.Environment) (stream.Iterator, error)

func (*GroupAggregateOperator) String 

func (op *GroupAggregateOperator) String() string

type GroupAggregatorIterator added in v0.17.0 

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

func (*GroupAggregatorIterator) Close added in v0.17.0 

func (it *GroupAggregatorIterator) Close() error

func (*GroupAggregatorIterator) Error added in v0.17.0 

func (it *GroupAggregatorIterator) Error() error

func (*GroupAggregatorIterator) Next added in v0.17.0 

func (it *GroupAggregatorIterator) Next() bool

func (*GroupAggregatorIterator) Row added in v0.17.0 

func (it *GroupAggregatorIterator) Row() (database.Row, error)

type ProjectIterator added in v0.17.0 

type ProjectIterator struct {
	stream.Iterator
	// contains filtered or unexported fields
}

func (*ProjectIterator) Error added in v0.17.0 

func (it *ProjectIterator) Error() error

func (*ProjectIterator) Next added in v0.17.0 

func (it *ProjectIterator) Next() bool

func (*ProjectIterator) Row added in v0.17.0 

func (it *ProjectIterator) Row() (database.Row, error)

type ProjectOperator 

type ProjectOperator struct {
	stream.BaseOperator
	Exprs []expr.Expr
}

A ProjectOperator applies an expression on each value of the stream and returns a new value.

func Project 

func Project(exprs ...expr.Expr) *ProjectOperator

Project creates a ProjectOperator.

func (*ProjectOperator) Columns added in v0.17.0 

func (op *ProjectOperator) Columns(env *environment.Environment) ([]string, error)

func (*ProjectOperator) Iterator added in v0.17.0 

func (op *ProjectOperator) Iterator(in *environment.Environment) (stream.Iterator, error)

func (*ProjectOperator) String 

func (op *ProjectOperator) String() string

type SkipIterator added in v0.17.0 

type SkipIterator struct {
	stream.Iterator
	// contains filtered or unexported fields
}

func (*SkipIterator) Next added in v0.17.0 

func (it *SkipIterator) Next() bool

type SkipOperator 

type SkipOperator struct {
	stream.BaseOperator
	E expr.Expr
}

A SkipOperator skips the n first values of the stream.

func Skip 

func Skip(e expr.Expr) *SkipOperator

Skip ignores the first n values of the stream.

func (*SkipOperator) Iterator added in v0.17.0 

func (op *SkipOperator) Iterator(in *environment.Environment) (stream.Iterator, error)

func (*SkipOperator) String 

func (op *SkipOperator) String() string

type TakeIterator added in v0.17.0 

type TakeIterator struct {
	stream.Iterator
	// contains filtered or unexported fields
}

func (*TakeIterator) Next added in v0.17.0 

func (it *TakeIterator) Next() bool

type TakeOperator 

type TakeOperator struct {
	stream.BaseOperator
	E expr.Expr
}

A TakeOperator closes the stream after a certain number of values.

func Take 

func Take(e expr.Expr) *TakeOperator

Take closes the stream after n values have passed through the operator.

func (*TakeOperator) Iterator added in v0.17.0 

func (op *TakeOperator) Iterator(in *environment.Environment) (stream.Iterator, error)

Iterate implements the Operator interface.

func (*TakeOperator) String 

func (op *TakeOperator) String() string

type TempTreeSortIterator added in v0.17.0 

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

func (*TempTreeSortIterator) Close added in v0.17.0 

func (it *TempTreeSortIterator) Close() error

func (*TempTreeSortIterator) Error added in v0.17.0 

func (it *TempTreeSortIterator) Error() error

func (*TempTreeSortIterator) Next added in v0.17.0 

func (it *TempTreeSortIterator) Next() bool

func (*TempTreeSortIterator) Row added in v0.17.0 

func (it *TempTreeSortIterator) Row() (database.Row, error)

type TempTreeSortOperator 

type TempTreeSortOperator struct {
	stream.BaseOperator
	Expr expr.Expr
	Desc bool
}

A TempTreeSortOperator consumes every value of the stream and outputs them in order.

func TempTreeSort 

func TempTreeSort(e expr.Expr) *TempTreeSortOperator

TempTreeSort consumes every value of the stream, sorts them by the given expr and outputs them in order. It creates a temporary index and uses it to sort the stream.

func TempTreeSortReverse 

func TempTreeSortReverse(e expr.Expr) *TempTreeSortOperator

TempTreeSortReverse does the same as TempTreeSort but in descending order.

func (*TempTreeSortOperator) Iterator added in v0.17.0 

func (op *TempTreeSortOperator) Iterator(in *environment.Environment) (stream.Iterator, error)

func (*TempTreeSortOperator) String 

func (op *TempTreeSortOperator) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.