Returns a PipelineStage that emits all items emitted by the source PipelineStage that are distinct by comparison from previous items.
Input PipelineStage
Optional function to select which value you want to check as distinct.
A PipelineStage that emits items from the source PipelineStage with distinct values.
Returns a PipelineStage that emits the items you specify as arguments after it finishes emitting items emitted by the source PipelineStage.
Input PipelineStage
Values to append
A PipelineStage that emits the items emitted by the source PipelineStage and then emits the additional values.
Flatten the output of a pipeline stage that emits array of values into single values.
Input PipelineStage
Output PipelineStage
Groups the items produced by a pipeline according to a specified criterion, and emits the resulting groups
Input PipelineStage
A function that extracts the grouping key for each item
(optional) A function that transforms items before inserting them in a group
Find the smallest value produced by a pipeline of iterators. It takes a ranking function as input, which is invoked with (x, y) and must returns True if x > y and False otherwise. Warning: this function needs to materialize all values of the pipeline.
Input PipelineStage
A pipeline stage that emits the highest value found
Find the smallest value produced by a pipeline of iterators. It takes a ranking function as input, which is invoked with (x, y) and must returns True if x < y and False otherwise. Warning: this function needs to materialize all values of the pipeline.
Input PipelineStage
A pipeline stage that emits the lowest value found
Peek values from the input pipeline stage, and use them to decide between two candidate pipeline stages to continue the pipeline.
Input pipeline stage
How many items to peek from the input?
Predicate function invoked with the values
Callback invoked if the predicate function evaluates to True
Callback invoked if the predicate function evaluates to False
A pipeline stage
Perform a side effect for every emission on the source PipelineStage, but return a PipelineStage that is identical to the source.
Input PipelineStage
Callback invoked on each item
A PipelineStage identical to the source, but runs the specified PipelineStage or callback(s) for each item.
Generated using TypeDoc
A pipeline implemented using VectorStage, i.e., all intermediate results are materialized in main memory. This approach is often called vectorized approach. This pipeline is more efficient CPU-wise than RxjsPipeline, but it also consumes much more memory, as it materializes evey stage of the pipeline before moving to the next. It should only be used when SPARQL queries generate few intermediate results.
P. A. Boncz, S. Manegold, and M. L. Kersten. "Database architecture evolution: Mammals flourished long before dinosaurs became extinct". PVLDB, (2009)
Thomas Minier