Help us shape the future of Go! Take the 2026 Go Developer Survey

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.