Database Reference
In-Depth Information
The
CoGroup
pipe joins multiple tuple streams together by common field names, and
it also groups the tuples by the common grouping fields. All standard join types (inner,
outer, etc.) and custom joins can be used across two or more tuple streams.
Every
The
Every
pipe processes a single grouping of tuples at a time, where the group was
grouped by a
GroupBy
or
CoGroup
pipe. The
Every
pipe may apply either an
Ag-
gregator
or a
Buffer
operation to the grouping.
SubAssembly
The
SubAssembly
pipe allows for nesting of assemblies inside a single pipe, which
can, in turn, be nested in more complex assemblies.
Figure 24-3. Pipe types
All these pipes are chained together by the developer into “pipe assemblies,” in which
each assembly can have many input tuple streams (sources) and many output tuple
streams (sinks). See
Figure 24-4
.
