-
Book Overview & Buying
-
Table Of Contents
-
Feedback & Rating
Learning Cascading
By :
Now, we know what the Cascading record looks like. How do we process these records? How do we move and manipulate data? Cascading provides us with the concept of pipes. Pipes control how data is managed during the processing segment.
Pipes are things that do stuff. The Cascading API allows the developer to assemble pipe assemblies that split, merge, group, or join streams. As data moves through pipes, streams may be separated or combined for various purposes:

Figure 2.3 – Pipe definition
Some pipes, such as Merge, GroupBy, and the Join classes, perform single actions on entire Tuple streams. Others, such as Each and Every require an operation to be attached to them. It is the operation code that performs the desired task. We will look at operations briefly in this chapter, though Chapter 3, Understanding Custom Operations will explore them in detail.
Pipes are created through both declaration and instantiation...
Change the font size
Change margin width
Change background colour