|
|||||||||
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.Each
public class Each
The Each operator applies either a Function
or a Filter
to each entry in the Tuple
stream. Any number of Each operators can follow an Each, Group
, or Every
operator.
Nested Class Summary | |
---|---|
class |
Each.EachAssertionHandler
|
class |
Each.EachFilterHandler
|
class |
Each.EachFunctionHandler
|
class |
Each.EachHandler
Class EachHandler is a helper class that wraps Each instances. |
Field Summary |
---|
Fields inherited from class cascading.pipe.Operator |
---|
argumentSelector, operation, outputSelector, plannerLevel |
Fields inherited from class cascading.pipe.Pipe |
---|
previous |
Constructor Summary | |
---|---|
Each(Pipe previous,
AssertionLevel assertionLevel,
Assertion assertion)
|
|
Each(Pipe previous,
DebugLevel debugLevel,
Debug debug)
|
|
Each(Pipe previous,
Fields argumentSelector,
AssertionLevel assertionLevel,
Assertion assertion)
|
|
Each(Pipe previous,
Fields argumentSelector,
DebugLevel debugLevel,
Debug debug)
|
|
Each(Pipe previous,
Fields argumentSelector,
Filter filter)
Constructor Each creates a new Each instance. |
|
Each(Pipe previous,
Fields argumentSelector,
Function function)
Only pass argumentFields to the given function, only return fields declared by the function. |
|
Each(Pipe previous,
Fields argumentSelector,
Function function,
Fields outputSelector)
Only pass argumentFields to the given function, only return fields selected by the outputSelector. |
|
Each(Pipe previous,
Filter filter)
Constructor Each creates a new Each instance. |
|
Each(Pipe previous,
Function function)
Pass all fields to the given function, only return fields declared by the function. |
|
Each(Pipe previous,
Function function,
Fields outputSelector)
Only pass argumentFields to the given function, only return fields selected by the outputSelector. |
|
Each(String name,
AssertionLevel assertionLevel,
Assertion assertion)
Constructor Each creates a new Each instance. |
|
Each(String name,
Fields argumentSelector,
AssertionLevel assertionLevel,
Assertion assertion)
|
|
Each(String name,
Fields argumentSelector,
DebugLevel debugLevel,
Debug debug)
|
|
Each(String name,
Fields argumentSelector,
Filter filter)
Constructor Each creates a new Each instance. |
|
Each(String name,
Fields argumentSelector,
Function function)
Only pass argumentFields to the given function, only return fields declared by the function. |
|
Each(String name,
Fields argumentSelector,
Function function,
Fields outputSelector)
Only pass argumentFields to the given function, only return fields selected by the outputSelector. |
|
Each(String name,
Filter filter)
Constructor Each creates a new Each instance. |
|
Each(String name,
Function function)
Pass all fields to the given function, only return fields declared by the function. |
|
Each(String name,
Function function,
Fields outputSelector)
Only return fields selected by the outputSelector. |
Method Summary | |
---|---|
Each.EachHandler |
getHandler(FlowCollector flowCollector,
Scope scope)
|
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. |
protected void |
verifyOperation()
|
Methods inherited from class cascading.pipe.Operator |
---|
equals, getArgumentSelector, getAssertionLevel, getFieldDeclaration, getOperation, getOutputSelector, getPlannerLevel, hashCode, hasPlannerLevel, isAssertion, isEquivalentTo, makeResult, printInternal, resolveRemainderFields, toString |
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={"name","function"}) public Each(String name, Function function)
name
- name for this branch of Pipesfunction
- Function to be applied to each input Tuple@ConstructorProperties(value={"name","argumentSelector","function"}) public Each(String name, Fields argumentSelector, Function function)
name
- name for this branch of PipesargumentSelector
- field selector that selects Function arguments from the input Tuplefunction
- Function to be applied to each input Tuple@ConstructorProperties(value={"name","argumentSelector","function","outputSelector"}) public Each(String name, Fields argumentSelector, Function function, Fields outputSelector)
name
- name for this branch of PipesargumentSelector
- field selector that selects Function arguments from the input Tuplefunction
- Function to be applied to each input TupleoutputSelector
- field selector that selects the output Tuple from the input and Function results Tuples@ConstructorProperties(value={"name","function","outputSelector"}) public Each(String name, Function function, Fields outputSelector)
name
- name for this branch of Pipesfunction
- Function to be applied to each input TupleoutputSelector
- field selector that selects the output Tuple from the input and Function results Tuples@ConstructorProperties(value={"previous","function"}) public Each(Pipe previous, Function function)
previous
- previous Pipe to receive input Tuples fromfunction
- Function to be applied to each input Tuple@ConstructorProperties(value={"previoud","argumentSelector","function"}) public Each(Pipe previous, Fields argumentSelector, Function function)
previous
- previous Pipe to receive input Tuples fromargumentSelector
- field selector that selects Function arguments from the input Tuplefunction
- Function to be applied to each input Tuple@ConstructorProperties(value={"previous","argumentSelector","function","outputSelector"}) public Each(Pipe previous, Fields argumentSelector, Function function, Fields outputSelector)
previous
- previous Pipe to receive input Tuples fromargumentSelector
- field selector that selects Function arguments from the input Tuplefunction
- Function to be applied to each input TupleoutputSelector
- field selector that selects the output Tuple from the input and Function results Tuples@ConstructorProperties(value={"previous","function","outputSelector"}) public Each(Pipe previous, Function function, Fields outputSelector)
previous
- previous Pipe to receive input Tuples fromfunction
- Function to be applied to each input TupleoutputSelector
- field selector that selects the output Tuple from the input and Function results Tuples@ConstructorProperties(value={"name","filter"}) public Each(String name, Filter filter)
name
- name for this branch of Pipesfilter
- Filter to be applied to each input Tuple@ConstructorProperties(value={"name","argumentSelector","filter"}) public Each(String name, Fields argumentSelector, Filter filter)
name
- name for this branch of PipesargumentSelector
- field selector that selects Function arguments from the input Tuplefilter
- Filter to be applied to each input Tuple@ConstructorProperties(value={"previous","filter"}) public Each(Pipe previous, Filter filter)
previous
- previous Pipe to receive input Tuples fromfilter
- Filter to be applied to each input Tuple@ConstructorProperties(value={"previous","argumentSelector","filter"}) public Each(Pipe previous, Fields argumentSelector, Filter filter)
previous
- previous Pipe to receive input Tuples fromargumentSelector
- field selector that selects Function arguments from the input Tuplefilter
- Filter to be applied to each input Tuple@ConstructorProperties(value={"name","assertionLevel","assertion"}) public Each(String name, AssertionLevel assertionLevel, Assertion assertion)
name
- name for this branch of PipesassertionLevel
- AssertionLevel to associate with the Assertionassertion
- Assertion to be applied to each input Tuple@ConstructorProperties(value={"name","argumentSelector","assertionLevel","assertion"}) public Each(String name, Fields argumentSelector, AssertionLevel assertionLevel, Assertion assertion)
name
- name for this branch of PipesargumentSelector
- field selector that selects Function arguments from the input TupleassertionLevel
- AssertionLevel to associate with the Assertionassertion
- Assertion to be applied to each input Tuple@ConstructorProperties(value={"previous","assertionLevel","assertion"}) public Each(Pipe previous, AssertionLevel assertionLevel, Assertion assertion)
previous
- previous Pipe to receive input Tuples fromassertionLevel
- AssertionLevel to associate with the Assertionassertion
- Assertion to be applied to each input Tuple@ConstructorProperties(value={"previous","argumentSelector","assertionLevel","assertion"}) public Each(Pipe previous, Fields argumentSelector, AssertionLevel assertionLevel, Assertion 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
- Assertion to be applied to each input Tuple@ConstructorProperties(value={"name","argumentSelector","debugLevel","debug"}) public Each(String name, Fields argumentSelector, DebugLevel debugLevel, Debug debug)
name
- name for this branch of PipesargumentSelector
- field selector that selects Function arguments from the input TupledebugLevel
- DebugLevel to associate with the Debugdebug
- Debug to be applied to each input Tuple@ConstructorProperties(value={"previous","debuglevel","debug"}) public Each(Pipe previous, DebugLevel debugLevel, Debug debug)
previous
- previous Pipe to receive input Tuples fromdebugLevel
- DebugLevel to associate with the Debugdebug
- Debug to be applied to each input Tuple@ConstructorProperties(value={"previous","argumentSelector","debugLevel","debug"}) public Each(Pipe previous, Fields argumentSelector, DebugLevel debugLevel, Debug debug)
previous
- previous Pipe to receive input Tuples fromargumentSelector
- field selector that selects Function arguments from the input TupledebugLevel
- DebugLevel to associate with the Debugdebug
- Debug to be applied to each input TupleMethod Detail |
---|
protected void verifyOperation()
verifyOperation
in class Operator
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(Set)
public Each.EachHandler getHandler(FlowCollector flowCollector, Scope scope)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |