Distinct filters duplicate documents based on one or more expressions.

Documents creates a DocumentsOperator that iterates over the given values.

Expressions creates an operator that iterates over the given expressions.

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

GroupBy applies e on each value of the stream and stores the result in the _group variable in the output stream.

HashAggregate consumes the incoming stream and outputs one value per group.

IndexScan creates an iterator that iterates over each document of the given table.

IndexScanReverse creates an iterator that iterates over each document of the given table in reverse order.

IterRename iterates over all fields of the incoming document in order and renames them.

Map evaluates e on each value of the stream and outputs the result.

PkScan creates an iterator that iterates over each document of the given table.

PkScanReverse creates an iterator that iterates over each document of the given table in reverse order.

Project creates a ProjectOperator.

SeqScan creates an iterator that iterates over each document of the given table.

SeqScanReverse creates an iterator that iterates over each document of the given table in reverse order.

Set filters duplicate documents based on one or more expressions.

Skip ignores the first n values of the stream.

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

SortReverse does the same as Sort but in descending order.

TableDelete deletes documents from the table.

TableInsert inserts incoming documents to the table.

TableReplace replaces documents in the table.

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

Unset filters duplicate documents based on one or more expressions.

ErrInvalidResult is returned when an expression supposed to evaluate to a document returns something else.

ErrStreamClosed is used to indicate that a stream must be closed.

A DistinctOperator filters duplicate documents.

A FilterOperator filters values based on a given expression.

A GroupByOperator applies an expression on each value of the stream and stores the result in the _group variable in the output stream.

A HashAggregateOperator consumes the given stream and outputs one value per group.

IndexRange represents a range to select indexed values after or before a given boundary.

A IndexScanOperator iterates over the documents of an index.

An IterRenameOperator iterates over all fields of the incoming document in order and renames them.

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

A PkScanOperator iterates over the documents of a table.

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

A SeqScanOperator iterates over the documents of a table.

A SetOperator filters duplicate documents.

A SkipOperator skips the n first values of the stream.

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

A TableDeleteOperator replaces documents in the table.

A TableInsertOperator inserts incoming documents to the table.

A TableReplaceOperator replaces documents in the table.

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

A UnsetOperator filters duplicate documents.

An Operator is used to modify a stream.

An OperatorFunc is the function that will receive each value of the stream.