|
Class Summary |
| CoGroup |
The CoGroup pipe allows for two or more tuple streams to join into a single stream. |
| Each |
The Each operator applies either a Function or a Filter to each entry in the Tuple
stream. |
| EndPipe |
*** Experimental - May be removed in a future iteration ***
Class EndPipe marks the end of a branch in a pipe assembly. |
| Every |
The Every operator applies an Aggregator to every grouping. |
| Group |
The base class for GroupBy and CoGroup. |
| GroupBy |
The GroupBy pipe groups the Tuple stream by the given groupFields. |
| Operator |
An Opererator is a type of Pipe. |
| Pipe |
Pipes are chained together through their constructors. |
| SubAssembly |
Subclasses of SubAssembly encapsulate complex assemblies of Pipes so they my be reused in the same manner
a Pipe is used. |