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  
 



Copyright © 2007-2013 Concurrent, Inc. All Rights Reserved.