Search Java Classes and Packages

Search Java Frameworks and Libraries

255581 classes and counting ...
Search Tips Index Status



#Cascading.pipe Classes and Interfaces - 58 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
BaseJoinerClasscascading.pipe.joinerCascading
BoundaryThe Boundary class is only used internally by the planner to mark the boundaries between partitions within In MapReduce, Taps are used.Classcascading.pipeCascading
BufferJoin will implement a custom join strategy.Classcascading.pipe.joinerCascading
CheckpointThe 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.Classcascading.pipeCascading
Coerce If the given type is a primitive (long), and the tuple value is null, 0 is returned.Classcascading.pipe.assemblyCascading
CoGroupThe CoGroup pipe allows for two or more tuple streams to join into a single stream via an optional Joiner.Classcascading.pipeCascading
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
EachThe Each operator applies either a Function or a Filter to each entry in the Tuple stream.Classcascading.pipeCascading
EveryThe Every operator applies an Aggregator or Buffer to every grouping.Classcascading.pipeCascading
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
GroupInterfacecascading.pipeCascading
GroupByThe GroupBy pipe groups the Tuple stream by the given groupFields.Classcascading.pipeCascading
HashJoinThe 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.Classcascading.pipeCascading
InnerJoin and inner join of the CoGrouper internal grouped tuple collections.Classcascading.pipe.joinerCascading
InnerJoin .JoinIteratorClasscascading.pipe.joiner.InnerJoinCascading
Joiner Joins perform based on the equality of the join keys.Interfacecascading.pipe.joinerCascading
JoinerClosure This class is provided to a Joiner.Classcascading.pipe.joinerCascading
LeftJoin a left inner, right outer join of the CoGrouper internal grouped tuple collections.Classcascading.pipe.joinerCascading
LeftJoin .JoinIteratorClasscascading.pipe.joiner.LeftJoinCascading
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
MergeThe Merge Pipe allows for multiple branches, with the same fields to be spliced back into a single stream.Classcascading.pipeCascading
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
MixedJoin Joiner and return tuples that represent a join as defined by the given boolean array.Classcascading.pipe.joinerCascading
OperatorAn Operator is a type of Pipe.Classcascading.pipeCascading
OperatorExceptionClasscascading.pipeCascading
OuterJoin and outer join of the CoGrouper internal grouped tuple collections.Classcascading.pipe.joinerCascading
OuterJoin .JoinIteratorClasscascading.pipe.joiner.OuterJoinCascading
Pipe processing model types, specifically Each, Every, GroupBy, CoGroup, Merge, HashJoin, and SubAssembly.Classcascading.pipeCascading
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
RightJoin a left outer, right inner join of the CoGrouper internal grouped tuple collections.Classcascading.pipe.joinerCascading
RightJoin .JoinIteratorClasscascading.pipe.joiner.RightJoinCascading
SpliceThe base class for GroupBy, CoGroup, Merge, and HashJoin.Classcascading.pipeCascading
SubAssemblySubclasses 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 fewClasscascading.pipeCascading
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