Namespace spl.relational
This namespace contains components that can transform streams using relational predicates.
By default this namespace is in scope for SPL programs, so no explicit use statement is required to use them.
Operators
- Aggregate: The Aggregate operator is used to compute user-specified aggregations over tuples that are gathered in a window.
- Filter: The Filter operator removes tuples from a stream by passing along only those tuples that satisfy a user-specified condition.
- Functor: The Functor operator is used to transform input tuples into output ones, and optionally filter them as in a Filter operator.
- Join: The Join operator is used to correlate tuples from two streams that are based on user-specified match predicates and window configurations.
- Punctor: The Punctor operator is used to transform input tuples into output ones and add window punctuation to the output.
- Sort: The Sort operator is used to order tuples that are based on user-specified ordering expressions and window configurations.