Interface | Description |
---|---|
AggregateBy.Functor |
Interface Functor provides a means to create a simple function for use with the
AggregateBy.CompositeFunction class. |
Class | Description |
---|---|
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 | |
AggregateByProps |
Class AggregateByProps is a fluent helper for setting various properties related to the cache used in
AggregateBy . |
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, where "duplicates" means all tuples with the same
values for the groupingFields fields.
|
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. |
UniqueProps |
Class UniqueProps is a fluent helper for setting various properties related to the cache used in
Unique . |
Enum | Description |
---|---|
AggregateBy.Cache | |
AverageBy.Include | |
CountBy.Include | |
Unique.Cache | |
Unique.Include |
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.