Package cascading.pipe.assembly

Interface Summary

AggregateBy.Functor

Interface Functor provides a means to create a simple function for use with the AggregateBy.CompositeFunction class.

Class Summary

AggregateBy	Class AggregateBy is a SubAssembly that serves two roles for handling aggregate operations.
AggregateBy.CompositeFunction	Class CompositeFunction takes multiple Functor instances and manages them as a single Function.
AggregateBy.CompositeFunction.Context
AverageBy	Class AverageBy is used to average values associated with duplicate keys in a tuple stream.
AverageBy.AverageFinal	Class AverageFinal is used to finalize the average operation on the Reduce side of the process.
AverageBy.AverageFinal.Context	Class Context is used to hold intermediate values.
AverageBy.AveragePartials	Class AveragePartials is a AggregateBy.Functor that is used to count and sum observed duplicates from the tuple stream.
Coerce	Class Coerce is a SubAssembly that will coerce all incoming Tuple values to the given types.
CountBy	Class CountBy is used to count duplicates in a tuple stream.
CountBy.CountPartials	Class CountPartials is a AggregateBy.Functor that is used to count observed duplicates from the tuple stream.
Discard	Class Discard is a SubAssembly that will retain all incoming fields except those given on the constructor.
FirstBy	Class FirstBy is used to return the first encountered Tuple in a tuple stream grouping.
FirstBy.FirstPartials	Class CountPartials is a AggregateBy.Functor that is used to count observed duplicates from the tuple stream.
MaxBy	Class MaxBy is used to find the maximum value in a grouping.
MaxBy.MaxPartials
MinBy	Class MinBy is used to find the minimum value in a grouping.
MinBy.MinPartials
Rename	Class Rename is a SubAssembly that will rename the fromFields to the names in toFields.
Retain	Class Retain is a SubAssembly that will discard all incoming fields except those given on the constructor.
SumBy	Class SumBy is used to sum values associated with duplicate keys in a tuple stream.
SumBy.SumPartials	Class SumPartials is a AggregateBy.Functor that is used to sum observed duplicates from the tuple stream.
Unique	Class Unique SubAssembly is used to filter all duplicates out of a tuple stream.
Unique.FilterPartialDuplicates	Class FilterPartialDuplicates is a Filter that is used to remove observed duplicates from the tuple stream.

Enum Summary

AggregateBy.Flush
AverageBy.Include
CountBy.Include
Unique.Include