cascading.pipe
Class Every

java.lang.Object
  cascading.pipe.Pipe
      cascading.pipe.Operator
          cascading.pipe.Every

All Implemented Interfaces:

FlowElement, Serializable

public class Every
extends Operator

The Every operator applies an Aggregator to every grouping. Any number of Every instances may follow other Every or Group instance.

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 values in the grouping are discarded).

See Also:

Serialized Form

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, assertionLevel, operation, outputSelector

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 outFieldSelector)
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 reducer)
Constructor Every creates a new Every instance.

Every(Pipe previous, Buffer reducer, Fields outFieldSelector)
Constructor Every creates a new Every instance.

Every(Pipe previous, Fields argumentFieldSelector, Aggregator aggregator)
Constructor Every creates a new Every instance.

Every(Pipe previous, Fields argumentFieldSelector, Aggregator aggregator, Fields outFieldSelector)
Constructor Every creates a new Every instance.

Every(Pipe previous, Fields argumentFieldSelector, AssertionLevel assertionLevel, GroupAssertion assertion)
Constructor Every creates a new Every instance.

Every(Pipe previous, Fields argumentFieldSelector, Buffer reducer)
Constructor Every creates a new Every instance.

Every(Pipe previous, Fields argumentFieldSelector, Buffer reducer, Fields outFieldSelector)
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, hashCode, isAssertion, makeResult, printInternal, toString, verifyOperation

Methods inherited from class cascading.pipe.Pipe

getHeads, getName, getPrevious, getTrace, pipes, print

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

Every

public Every(Pipe previous,
             Aggregator aggregator)

Constructor Every creates a new Every instance.

Parameters:

previous - of type Pipe

aggregator - of type Aggregator

Every

public Every(Pipe previous,
             Fields argumentFieldSelector,
             Aggregator aggregator)

Constructor Every creates a new Every instance.

Parameters:

previous - of type Pipe

argumentFieldSelector - of type Fields

aggregator - of type Aggregator

Every

public Every(Pipe previous,
             Fields argumentFieldSelector,
             Aggregator aggregator,
             Fields outFieldSelector)

Constructor Every creates a new Every instance.

Parameters:

previous - of type Pipe

argumentFieldSelector - of type Fields

aggregator - of type Aggregator

outFieldSelector - of type Fields

Every

public Every(Pipe previous,
             Aggregator aggregator,
             Fields outFieldSelector)

Constructor Every creates a new Every instance.

Parameters:

previous - of type Pipe

aggregator - of type Aggregator

outFieldSelector - of type Fields

Every

public Every(Pipe previous,
             Buffer reducer)

Constructor Every creates a new Every instance.

Parameters:

previous - of type Pipe

reducer - of type Reducer

Every

public Every(Pipe previous,
             Fields argumentFieldSelector,
             Buffer reducer)

Constructor Every creates a new Every instance.

Parameters:

previous - of type Pipe

argumentFieldSelector - of type Fields

reducer - of type Reducer

Every

public Every(Pipe previous,
             Fields argumentFieldSelector,
             Buffer reducer,
             Fields outFieldSelector)

Constructor Every creates a new Every instance.

Parameters:

previous - of type Pipe

argumentFieldSelector - of type Fields

reducer - of type Reducer

outFieldSelector - of type Fields

Every

public Every(Pipe previous,
             Buffer reducer,
             Fields outFieldSelector)

Constructor Every creates a new Every instance.

Parameters:

previous - of type Pipe

reducer - of type Reducer

outFieldSelector - of type Fields

Every

public Every(Pipe previous,
             AssertionLevel assertionLevel,
             GroupAssertion assertion)

Constructor Every creates a new Every instance.

Parameters:

previous - of type Pipe

assertionLevel - of type AssertionLevel

assertion - of type ValueAssertion

Every

public Every(Pipe previous,
             Fields argumentFieldSelector,
             AssertionLevel assertionLevel,
             GroupAssertion assertion)

Constructor Every creates a new Every instance.

Parameters:

previous - of type Pipe

argumentFieldSelector - of type Fields

assertionLevel - of type AssertionLevel

assertion - of type ValueAssertion

Method Detail

isBuffer

public boolean isBuffer()

Method isBuffer returns true if this Every instance holds a Buffer operation.

Returns:

boolean

isAggregator

public boolean isAggregator()

Method isReducer returns true if this Every instance holds a Aggregator operation.

Returns:

boolean

resolveIncomingOperationFields

public Fields resolveIncomingOperationFields(Scope incomingScope)

Description copied from interface: FlowElement

Method resolveIncomingOperationFields resolves the incoming scopes to the actual incoming operation field names.

Specified by:

resolveIncomingOperationFields in interface FlowElement

Overrides:

resolveIncomingOperationFields in class Pipe

Parameters:

incomingScope - of type Scope

Returns:

Fields

See Also:

FlowElement.resolveIncomingOperationFields(Scope)

resolveFields

public Fields resolveFields(Scope scope)

Description copied from interface: FlowElement

Method resolveFields returns the actual field names represented by the given Scope. The scope may be incoming or outgoing in relation to this FlowElement instance.

Specified by:

resolveFields in interface FlowElement

Overrides:

resolveFields in class Pipe

Parameters:

scope - of type Scope

Returns:

Fields

See Also:

FlowElement.resolveFields(Scope)

outgoingScopeFor

public Scope outgoingScopeFor(Set<Scope> incomingScopes)

Description copied from interface: FlowElement

Method outgoingScopeFor returns the Scope this FlowElement hands off to the next FlowElement.

Specified by:

outgoingScopeFor in interface FlowElement

Specified by:

outgoingScopeFor in class Operator

Parameters:

incomingScopes - of type Set

Returns:

Scope

See Also:

Operator#outgoingScopeFor(Set)

getHandler

public Every.EveryHandler getHandler(Scope outgoingScope)

Method getHandler returns the Every.EveryHandler for this instnce.

Parameters:

outgoingScope - of type Scope

Returns:

EveryHandler