cascading.pipe
Class Operator

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

All Implemented Interfaces:

FlowElement, Serializable

Direct Known Subclasses:

Each, Every

public abstract class Operator
extends Pipe

An Opererator is a type of Pipe. Operators pass specified arguments to a given BaseOperation.

The argFields value select the input fields used by the operation. By default the whole input Tuple is passes as arguments. The outFields value select the fields in the result Tuple returned by this Pipe. By default, the operation results of the given operation replace the input Tuple.

See Also:

Serialized Form

Field Summary

protected Fields	argumentSelector Field argumentSelector
protected AssertionLevel	assertionLevel Field assertionLevel
protected Operation	operation Field operation
protected Fields	outputSelector Field outputSelector

Fields inherited from class cascading.pipe.Pipe

previous

Constructor Summary

protected	Operator(Operation operation)
protected	Operator(Pipe previous, AssertionLevel assertionLevel, Operation operation, Fields outputSelector)
protected	Operator(Pipe previous, Fields argumentSelector, AssertionLevel assertionLevel, Operation operation, Fields outputSelector)
protected	Operator(Pipe previous, Fields argumentSelector, Operation operation)
protected	Operator(Pipe previous, Fields argumentSelector, Operation operation, Fields outputSelector)
protected	Operator(Pipe previous, Operation operation)
protected	Operator(Pipe previous, Operation operation, Fields outputSelector)
protected	Operator(String name, AssertionLevel assertionLevel, Operation operation, Fields outputSelector)
protected	Operator(String name, Fields argumentSelector, AssertionLevel assertionLevel, Operation operation, Fields outputSelector)
protected	Operator(String name, Fields argumentSelector, Operation operation)
protected	Operator(String name, Fields argumentSelector, Operation operation, Fields outputSelector)
protected	Operator(String name, Operation operation)
protected	Operator(String name, Operation operation, Fields outputSelector)

Method Summary

boolean	equals(Object object)
Fields	getArgumentSelector() Method getArgumentSelector returns the argumentSelector of this Operator object.
AssertionLevel	getAssertionLevel() Method getAssertionLevel returns the assertionLevel of this Operator object.
Fields	getFieldDeclaration() Method getFieldDeclaration returns the fieldDeclaration of this Operator object.
Operation	getOperation() Method getOperation returns the operation managed by this Operator object.
Fields	getOutputSelector() Method getOutputSelector returns the outputSelector of this Operator object.
int	hashCode()
boolean	isAssertion() Method isAssertion returns true if this Operation represents an Assertion.
protected Tuple	makeResult(Fields outgoingSelector, TupleEntry input, TupleEntry declaredEntry, Tuple output)
abstract Scope	outgoingScopeFor(Set<Scope> incomingScopes) Method outgoingScopeFor returns the Scope this FlowElement hands off to the next FlowElement.
protected void	printInternal(StringBuffer buffer, Scope scope)
String	toString()
protected void	verifyOperation()

Methods inherited from class cascading.pipe.Pipe

getHeads, getName, getPrevious, getTrace, pipes, print, resolveFields, resolveIncomingOperationFields

Methods inherited from class java.lang.Object

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

Field Detail

operation

protected final Operation operation

Field operation

argumentSelector

protected Fields argumentSelector

Field argumentSelector

outputSelector

protected Fields outputSelector

Field outputSelector

assertionLevel

protected AssertionLevel assertionLevel

Field assertionLevel

Constructor Detail

Operator

protected Operator(Operation operation)

Operator

protected Operator(String name,
                   Operation operation)

Operator

protected Operator(String name,
                   Operation operation,
                   Fields outputSelector)

Operator

protected Operator(String name,
                   Fields argumentSelector,
                   Operation operation)

Operator

protected Operator(String name,
                   Fields argumentSelector,
                   Operation operation,
                   Fields outputSelector)

Operator

protected Operator(Pipe previous,
                   Operation operation)

Operator

protected Operator(Pipe previous,
                   Fields argumentSelector,
                   Operation operation)

Operator

protected Operator(Pipe previous,
                   Fields argumentSelector,
                   Operation operation,
                   Fields outputSelector)

Operator

protected Operator(Pipe previous,
                   Operation operation,
                   Fields outputSelector)

Operator

protected Operator(String name,
                   AssertionLevel assertionLevel,
                   Operation operation,
                   Fields outputSelector)

Operator

protected Operator(String name,
                   Fields argumentSelector,
                   AssertionLevel assertionLevel,
                   Operation operation,
                   Fields outputSelector)

Operator

protected Operator(Pipe previous,
                   AssertionLevel assertionLevel,
                   Operation operation,
                   Fields outputSelector)

Operator

protected Operator(Pipe previous,
                   Fields argumentSelector,
                   AssertionLevel assertionLevel,
                   Operation operation,
                   Fields outputSelector)

Method Detail

verifyOperation

protected void verifyOperation()

getOperation

public Operation getOperation()

Method getOperation returns the operation managed by this Operator object.

Returns:

the operation (type Operation) of this Operator object.

getArgumentSelector

public Fields getArgumentSelector()

Method getArgumentSelector returns the argumentSelector of this Operator object.

Returns:

the argumentSelector (type Fields) of this Operator object.

getFieldDeclaration

public Fields getFieldDeclaration()

Method getFieldDeclaration returns the fieldDeclaration of this Operator object.

Returns:

the fieldDeclaration (type Fields) of this Operator object.

getOutputSelector

public Fields getOutputSelector()

Method getOutputSelector returns the outputSelector of this Operator object.

Returns:

the outputSelector (type Fields) of this Operator object.

getAssertionLevel

public AssertionLevel getAssertionLevel()

Method getAssertionLevel returns the assertionLevel of this Operator object. Only used if the Operation is an Assertion.

Returns:

the assertionLevel (type Assertion.Level) of this Operator object.

isAssertion

public boolean isAssertion()

Method isAssertion returns true if this Operation represents an Assertion.

Returns:

the assertion (type boolean) of this Operator object.

makeResult

protected Tuple makeResult(Fields outgoingSelector,
                           TupleEntry input,
                           TupleEntry declaredEntry,
                           Tuple output)

outgoingScopeFor

public abstract 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

Overrides:

outgoingScopeFor in class Pipe

Parameters:

incomingScopes - of type Set

Returns:

Scope

See Also:

FlowElement#outgoingScopeFor(Set)

toString

public String toString()

Overrides:

toString in class Pipe

printInternal

protected void printInternal(StringBuffer buffer,
                             Scope scope)

Overrides:

printInternal in class Pipe

equals

public boolean equals(Object object)

Overrides:

equals in class Pipe

hashCode

public int hashCode()

Overrides:

hashCode in class Pipe