Name | Description | Type | Package | Framework |
AggregateBy | The first role is as a base class for composable aggregate operations that have a MapReduce Map side optimization for the Reduce side aggregation. | Class | cascading.pipe.assembly | Cascading |
|
AggregateBy .Cache | | Class | cascading.pipe.assembly.AggregateBy | Cascading |
|
AggregateBy .CompositeFunction | See Also:AggregateBy. | Class | cascading.pipe.assembly.AggregateBy | Cascading |
|
AggregateBy .CompositeFunction .Context | | Class | cascading.pipe.assembly.AggregateBy.CompositeFunction | Cascading |
|
AggregateBy .Functor | Note the FlowProcess argument provides access to the underlying properties and counter APIs. | Interface | cascading.pipe.assembly.AggregateBy | Cascading |
|
AggregateByProps | | Class | cascading.pipe.assembly | Cascading |
|
AverageBy | Typically finding the average value in a tuple stream relies on a GroupBy and a Average Aggregator operation. | Class | cascading.pipe.assembly | Cascading |
|
AverageBy .AverageFinal | in tandem with a AverageBy. | Class | cascading.pipe.assembly.AverageBy | Cascading |
|
AverageBy .AverageFinal .Context | | Class | cascading.pipe.assembly.AverageBy.AverageFinal | Cascading |
|
AverageBy .AveragePartials | | Class | cascading.pipe.assembly.AverageBy | Cascading |
|
AverageBy .Include | | Class | cascading.pipe.assembly.AverageBy | Cascading |
|
BaseJoiner | | Class | cascading.pipe.joiner | Cascading |
|
Boundary | The Boundary class is only used internally by the planner to mark the boundaries between partitions within In MapReduce, Taps are used. | Class | cascading.pipe | Cascading |
|
BufferJoin | will implement a custom join strategy. | Class | cascading.pipe.joiner | Cascading |
|
Checkpoint | The Checkpoint pipe, if supported by the current planner, will force data to be persisted at the point in the tuple stream an instance of Checkpoint is inserted into the pipe assembly. | Class | cascading.pipe | Cascading |
|
Coerce | If the given type is a primitive (long), and the tuple value is null, 0 is returned. | Class | cascading.pipe.assembly | Cascading |
|
CoGroup | The CoGroup pipe allows for two or more tuple streams to join into a single stream via an optional Joiner. | Class | cascading.pipe | Cascading |
|
CountBy | values for the groupingFields fields. | Class | cascading.pipe.assembly | Cascading |
|
CountBy .CountPartials | Use this class typically in tandem with a Sum Aggregator in order to improve counting performance by removing as many values | Class | cascading.pipe.assembly.CountBy | Cascading |
|
CountBy .Include | | Class | cascading.pipe.assembly.CountBy | Cascading |
|
Discard | Use this pipe to narrow a stream of tuples, removing unused data. | Class | cascading.pipe.assembly | Cascading |
|
Each | The Each operator applies either a Function or a Filter to each entry in the Tuple stream. | Class | cascading.pipe | Cascading |
|
Every | The Every operator applies an Aggregator or Buffer to every grouping. | Class | cascading.pipe | Cascading |
|
FirstBy | Typically finding the first Tuple in a tuple stream grouping relies on a GroupBy and a First Aggregator operation. | Class | cascading.pipe.assembly | Cascading |
|
FirstBy .FirstPartials | Use this class typically in tandem with a Sum Aggregator in order to improve counting performance by removing as many values | Class | cascading.pipe.assembly.FirstBy | Cascading |
|
Group | | Interface | cascading.pipe | Cascading |
|
GroupBy | The GroupBy pipe groups the Tuple stream by the given groupFields. | Class | cascading.pipe | Cascading |
|
HashJoin | The HashJoin pipe allows for two or more tuple streams to join into a single stream via a Joiner when all but one tuple stream is considered small enough to fit into memory. | Class | cascading.pipe | Cascading |
|
InnerJoin | and inner join of the CoGrouper internal grouped tuple collections. | Class | cascading.pipe.joiner | Cascading |
|
InnerJoin .JoinIterator | | Class | cascading.pipe.joiner.InnerJoin | Cascading |
|
Joiner | Joins perform based on the equality of the join keys. | Interface | cascading.pipe.joiner | Cascading |
|
JoinerClosure | This class is provided to a Joiner. | Class | cascading.pipe.joiner | Cascading |
|
LeftJoin | a left inner, right outer join of the CoGrouper internal grouped tuple collections. | Class | cascading.pipe.joiner | Cascading |
|
LeftJoin .JoinIterator | | Class | cascading.pipe.joiner.LeftJoin | Cascading |
|
MaxBy | Typically finding the max value of a field in a tuple stream relies on a GroupBy and a MaxValue Aggregator operation. | Class | cascading.pipe.assembly | Cascading |
|
MaxBy .MaxPartials | | Class | cascading.pipe.assembly.MaxBy | Cascading |
|
Merge | The Merge Pipe allows for multiple branches, with the same fields to be spliced back into a single stream. | Class | cascading.pipe | Cascading |
|
MinBy | Typically finding the min value of a field in a tuple stream relies on a GroupBy and a MinValue Aggregator operation. | Class | cascading.pipe.assembly | Cascading |
|
MinBy .MinPartials | | Class | cascading.pipe.assembly.MinBy | Cascading |
|
MixedJoin | Joiner and return tuples that represent a join as defined by the given boolean array. | Class | cascading.pipe.joiner | Cascading |
|
Operator | An Operator is a type of Pipe. | Class | cascading.pipe | Cascading |
|
OperatorException | | Class | cascading.pipe | Cascading |
|
OuterJoin | and outer join of the CoGrouper internal grouped tuple collections. | Class | cascading.pipe.joiner | Cascading |
|
OuterJoin .JoinIterator | | Class | cascading.pipe.joiner.OuterJoin | Cascading |
|
Pipe | processing model types, specifically Each, Every, GroupBy, CoGroup, Merge, HashJoin, and SubAssembly. | Class | cascading.pipe | Cascading |
|
Rename | Note that if any input field names are not given, they will retain their names. | Class | cascading.pipe.assembly | Cascading |
|
Retain | Use this pipe to narrow a stream of tuples, removing unused data. | Class | cascading.pipe.assembly | Cascading |
|
RightJoin | a left outer, right inner join of the CoGrouper internal grouped tuple collections. | Class | cascading.pipe.joiner | Cascading |
|
RightJoin .JoinIterator | | Class | cascading.pipe.joiner.RightJoin | Cascading |
|
Splice | The base class for GroupBy, CoGroup, Merge, and HashJoin. | Class | cascading.pipe | Cascading |
|
SubAssembly | Subclasses of SubAssembly encapsulate complex assemblies of Pipes so they my be reused in the same manner That is, a typical SubAssembly subclass will accept a 'previous' Pipe instance, and a few | Class | cascading.pipe | Cascading |
|
SumBy | Typically finding the sum of field in a tuple stream relies on a GroupBy and a Sum Aggregator operation. | Class | cascading.pipe.assembly | Cascading |
|
SumBy .SumPartials | Use this class typically in tandem with a Sum Aggregator in order to improve counting performance by removing as many values | Class | cascading.pipe.assembly.SumBy | Cascading |
|
Unique | Typically finding unique value in a tuple stream relies on a GroupBy and a FirstNBuffer If the include value is set to Unique. | Class | cascading.pipe.assembly | Cascading |
|
Unique .Cache | | Class | cascading.pipe.assembly.Unique | Cascading |
|
Unique .FilterPartialDuplicates | Use this class typically in tandem with a First Aggregator in order to improve de-duping performance by removing as many values | Class | cascading.pipe.assembly.Unique | Cascading |
|
Unique .Include | | Class | cascading.pipe.assembly.Unique | Cascading |
|
UniqueProps | | Class | cascading.pipe.assembly | Cascading |