Search Java Classes and Packages

Search Java Frameworks and Libraries

255581 classes and counting ...
Search Tips Index Status



#Cascading.pipe.assembly Classes and Interfaces - 31 results found.
NameDescriptionTypePackageFramework
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.Classcascading.pipe.assemblyCascading
AggregateBy .CacheClasscascading.pipe.assembly.AggregateByCascading
AggregateBy .CompositeFunctionSee Also:AggregateBy.Classcascading.pipe.assembly.AggregateByCascading
AggregateBy .CompositeFunction .ContextClasscascading.pipe.assembly.AggregateBy.CompositeFunctionCascading
AggregateBy .Functor Note the FlowProcess argument provides access to the underlying properties and counter APIs.Interfacecascading.pipe.assembly.AggregateByCascading
AggregateByPropsClasscascading.pipe.assemblyCascading
AverageBy Typically finding the average value in a tuple stream relies on a GroupBy and a Average Aggregator operation.Classcascading.pipe.assemblyCascading
AverageBy .AverageFinal in tandem with a AverageBy.Classcascading.pipe.assembly.AverageByCascading
AverageBy .AverageFinal .ContextClasscascading.pipe.assembly.AverageBy.AverageFinalCascading
AverageBy .AveragePartialsClasscascading.pipe.assembly.AverageByCascading
AverageBy .IncludeClasscascading.pipe.assembly.AverageByCascading
Coerce If the given type is a primitive (long), and the tuple value is null, 0 is returned.Classcascading.pipe.assemblyCascading
CountBy values for the groupingFields fields.Classcascading.pipe.assemblyCascading
CountBy .CountPartials Use this class typically in tandem with a Sum Aggregator in order to improve counting performance by removing as many valuesClasscascading.pipe.assembly.CountByCascading
CountBy .IncludeClasscascading.pipe.assembly.CountByCascading
Discard Use this pipe to narrow a stream of tuples, removing unused data.Classcascading.pipe.assemblyCascading
FirstBy Typically finding the first Tuple in a tuple stream grouping relies on a GroupBy and a First Aggregator operation.Classcascading.pipe.assemblyCascading
FirstBy .FirstPartials Use this class typically in tandem with a Sum Aggregator in order to improve counting performance by removing as many valuesClasscascading.pipe.assembly.FirstByCascading
MaxBy Typically finding the max value of a field in a tuple stream relies on a GroupBy and a MaxValue Aggregator operation.Classcascading.pipe.assemblyCascading
MaxBy .MaxPartialsClasscascading.pipe.assembly.MaxByCascading
MinBy Typically finding the min value of a field in a tuple stream relies on a GroupBy and a MinValue Aggregator operation.Classcascading.pipe.assemblyCascading
MinBy .MinPartialsClasscascading.pipe.assembly.MinByCascading
Rename Note that if any input field names are not given, they will retain their names.Classcascading.pipe.assemblyCascading
Retain Use this pipe to narrow a stream of tuples, removing unused data.Classcascading.pipe.assemblyCascading
SumBy Typically finding the sum of field in a tuple stream relies on a GroupBy and a Sum Aggregator operation.Classcascading.pipe.assemblyCascading
SumBy .SumPartials Use this class typically in tandem with a Sum Aggregator in order to improve counting performance by removing as many valuesClasscascading.pipe.assembly.SumByCascading
Unique Typically finding unique value in a tuple stream relies on a GroupBy and a FirstNBuffer If the include value is set to Unique.Classcascading.pipe.assemblyCascading
Unique .CacheClasscascading.pipe.assembly.UniqueCascading
Unique .FilterPartialDuplicates Use this class typically in tandem with a First Aggregator in order to improve de-duping performance by removing as many valuesClasscascading.pipe.assembly.UniqueCascading
Unique .IncludeClasscascading.pipe.assembly.UniqueCascading
UniquePropsClasscascading.pipe.assemblyCascading