Emit 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.

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

Project creates a ProjectOperator.

Skip ignores the first n values of the stream.

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

TempTreeSort consumes every value of the stream, sorts them by the given expr and outputs them in order.

TempTreeSortReverse does the same as TempTreeSort but in descending order.

A FilterOperator filters values based on a given expression.

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

A SkipOperator skips the n first values of the stream.

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

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