|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object cascading.pipe.Pipe cascading.pipe.Operator cascading.pipe.Every
public class Every
The Every operator applies an Aggregator
or Buffer
to every grouping.
GroupBy
, CoGroup
instance if they apply an Aggregator, not a Buffer.
If a Buffer, only one Every may follow a GroupBy or CoGroup.
Every operators create aggregate values for every grouping they encounter. This aggregate value is added to the current
grouping Tuple. Subsequent Every instances can continue to append values to the grouping Tuple. When an Each follows
and Every, the Each applies its operation to the grouping Tuple (thus all child values in the grouping are discarded
and only aggregate values are propagated).
Nested Class Summary | |
---|---|
class |
Every.EveryAggregatorHandler
|
class |
Every.EveryAssertionHandler
|
class |
Every.EveryBufferHandler
|
class |
Every.EveryHandler
Class EveryHandler is a helper class that wraps Every instances. |
Field Summary |
---|
Fields inherited from class cascading.pipe.Operator |
---|
argumentSelector, operation, outputSelector, plannerLevel |
Fields inherited from class cascading.pipe.Pipe |
---|
previous |
Constructor Summary | |
---|---|
Every(Pipe previous,
Aggregator aggregator)
Constructor Every creates a new Every instance. |
|
Every(Pipe previous,
Aggregator aggregator,
Fields outputSelector)
Constructor Every creates a new Every instance. |
|
Every(Pipe previous,
AssertionLevel assertionLevel,
GroupAssertion assertion)
Constructor Every creates a new Every instance. |
|
Every(Pipe previous,
Buffer buffer)
Constructor Every creates a new Every instance. |
|
Every(Pipe previous,
Buffer buffer,
Fields outputSelector)
Constructor Every creates a new Every instance. |
|
Every(Pipe previous,
Fields argumentSelector,
Aggregator aggregator)
Constructor Every creates a new Every instance. |
|
Every(Pipe previous,
Fields argumentSelector,
Aggregator aggregator,
Fields outputSelector)
Constructor Every creates a new Every instance. |
|
Every(Pipe previous,
Fields argumentSelector,
AssertionLevel assertionLevel,
GroupAssertion assertion)
Constructor Every creates a new Every instance. |
|
Every(Pipe previous,
Fields argumentSelector,
Buffer buffer)
Constructor Every creates a new Every instance. |
|
Every(Pipe previous,
Fields argumentSelector,
Buffer buffer,
Fields outputSelector)
Constructor Every creates a new Every instance. |
Method Summary | |
---|---|
Every.EveryHandler |
getHandler(Scope outgoingScope)
Method getHandler returns the Every.EveryHandler for this instnce. |
boolean |
isAggregator()
Method isReducer returns true if this Every instance holds a Aggregator operation. |
boolean |
isBuffer()
Method isBuffer returns true if this Every instance holds a Buffer operation. |
Scope |
outgoingScopeFor(Set<Scope> incomingScopes)
Method outgoingScopeFor returns the Scope this FlowElement hands off to the next FlowElement. |
Fields |
resolveFields(Scope scope)
Method resolveFields returns the actual field names represented by the given Scope. |
Fields |
resolveIncomingOperationFields(Scope incomingScope)
Method resolveIncomingOperationFields resolves the incoming scopes to the actual incoming operation field names. |
Methods inherited from class cascading.pipe.Operator |
---|
equals, getArgumentSelector, getAssertionLevel, getFieldDeclaration, getOperation, getOutputSelector, getPlannerLevel, hashCode, hasPlannerLevel, isAssertion, isEquivalentTo, makeResult, printInternal, resolveRemainderFields, toString, verifyOperation |
Methods inherited from class cascading.pipe.Pipe |
---|
getHeads, getName, getPrevious, getTrace, names, pipes, print |
Methods inherited from class java.lang.Object |
---|
clone, finalize, getClass, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
@ConstructorProperties(value={"previous","aggregator"}) public Every(Pipe previous, Aggregator aggregator)
previous
- previous Pipe to receive input Tuples fromaggregator
- Aggregator to be applied to every input Tuple grouping@ConstructorProperties(value={"previous","argumentSelector","aggregator"}) public Every(Pipe previous, Fields argumentSelector, Aggregator aggregator)
previous
- previous Pipe to receive input Tuples fromargumentSelector
- field selector that selects Function arguments from the input Tupleaggregator
- Aggregator to be applied to every input Tuple grouping@ConstructorProperties(value={"previous","argumentSelector","aggregator","outputSelector"}) public Every(Pipe previous, Fields argumentSelector, Aggregator aggregator, Fields outputSelector)
previous
- previous Pipe to receive input Tuples fromargumentSelector
- field selector that selects Function arguments from the input Tupleaggregator
- Aggregator to be applied to every input Tuple groupingoutputSelector
- field selector that selects the output Tuple from the grouping and Aggregator results Tuples@ConstructorProperties(value={"previous","aggregator","outputSelector"}) public Every(Pipe previous, Aggregator aggregator, Fields outputSelector)
previous
- previous Pipe to receive input Tuples fromaggregator
- Aggregator to be applied to every input Tuple groupingoutputSelector
- field selector that selects the output Tuple from the grouping and Aggregator results Tuples@ConstructorProperties(value={"previous","buffer"}) public Every(Pipe previous, Buffer buffer)
previous
- previous Pipe to receive input Tuples frombuffer
- Buffer to be applied to every input Tuple grouping@ConstructorProperties(value={"previous","argumentSelector","buffer"}) public Every(Pipe previous, Fields argumentSelector, Buffer buffer)
previous
- previous Pipe to receive input Tuples fromargumentSelector
- field selector that selects Function arguments from the input Tuplebuffer
- Buffer to be applied to every input Tuple grouping@ConstructorProperties(value={"previous","argumentSelector","buffer","outputSelector"}) public Every(Pipe previous, Fields argumentSelector, Buffer buffer, Fields outputSelector)
previous
- previous Pipe to receive input Tuples fromargumentSelector
- field selector that selects Function arguments from the input Tuplebuffer
- Buffer to be applied to every input Tuple groupingoutputSelector
- field selector that selects the output Tuple from the grouping and Buffer results Tuples@ConstructorProperties(value={"previous","buffer","outputSelector"}) public Every(Pipe previous, Buffer buffer, Fields outputSelector)
previous
- previous Pipe to receive input Tuples frombuffer
- Buffer to be applied to every input Tuple groupingoutputSelector
- field selector that selects the output Tuple from the grouping and Buffer results Tuples@ConstructorProperties(value={"previous","assertionLevel","assertion"}) public Every(Pipe previous, AssertionLevel assertionLevel, GroupAssertion assertion)
previous
- previous Pipe to receive input Tuples fromassertionLevel
- of type AssertionLevelassertion
- GroupAssertion to be applied to every input Tuple grouping@ConstructorProperties(value={"previous","argumentSelector","assertionLevel","assertion"}) public Every(Pipe previous, Fields argumentSelector, AssertionLevel assertionLevel, GroupAssertion assertion)
previous
- previous Pipe to receive input Tuples fromargumentSelector
- field selector that selects Function arguments from the input TupleassertionLevel
- AssertionLevel to associate with the Assertionassertion
- GroupAssertion to be applied to every input Tuple groupingMethod Detail |
---|
public boolean isBuffer()
Buffer
operation.
public boolean isAggregator()
Aggregator
operation.
public Fields resolveIncomingOperationFields(Scope incomingScope)
FlowElement
resolveIncomingOperationFields
in interface FlowElement
resolveIncomingOperationFields
in class Pipe
incomingScope
- of type Scope
FlowElement.resolveIncomingOperationFields(cascading.flow.Scope)
public Fields resolveFields(Scope scope)
FlowElement
resolveFields
in interface FlowElement
resolveFields
in class Pipe
scope
- of type Scope
FlowElement.resolveFields(Scope)
public Scope outgoingScopeFor(Set<Scope> incomingScopes)
FlowElement
outgoingScopeFor
in interface FlowElement
outgoingScopeFor
in class Operator
incomingScopes
- of type SetOperator.outgoingScopeFor(java.util.Set)
public Every.EveryHandler getHandler(Scope outgoingScope)
Every.EveryHandler
for this instnce.
outgoingScope
- of type Scope
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |