|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object cascading.pipe.Pipe
public class Pipe
Class Pipe is used to name branches in pipe assemblies, and as a base class for core
processing model types, specifically Each
, Every
, GroupBy
, and
CoGroup
.
CoGroup
pipe.
A merge can be achieved by passing two or more Pipe instances to a GroupBy
pipe.
Each
,
Every
,
GroupBy
,
CoGroup
,
Serialized FormField Summary | |
---|---|
protected Pipe |
previous
Field previous |
Constructor Summary | |
---|---|
protected |
Pipe()
|
protected |
Pipe(Pipe previous)
|
|
Pipe(String name)
Constructor Pipe creates a new Pipe instance with the given name. |
|
Pipe(String name,
Pipe previous)
Constructor Pipe creates a new Pipe instance with the given name and previous Pipe instance. |
Method Summary | |
---|---|
boolean |
equals(Object object)
|
Pipe[] |
getHeads()
Method getHeads returns the first Pipe instances in this pipe assembly. |
String |
getName()
Get the name of this pipe. |
Pipe[] |
getPrevious()
Get all the upstream pipes this pipe is connected to. |
String |
getTrace()
Method getTrace returns a String that pinpoint where this instance was created for debugging. |
int |
hashCode()
|
boolean |
isEquivalentTo(FlowElement element)
|
static String[] |
names(Pipe... tails)
Convenience method for finding all Pipe names in an assembly. |
Scope |
outgoingScopeFor(Set<Scope> incomingScopes)
Method outgoingScopeFor returns the Scope this FlowElement hands off to the next FlowElement. |
static Pipe[] |
pipes(Pipe... pipes)
Convenience method to create an array of Pipe instances. |
String |
print(Scope scope)
Method print is used internally. |
protected void |
printInternal(StringBuffer buffer,
Scope scope)
|
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. |
String |
toString()
|
Methods inherited from class java.lang.Object |
---|
clone, finalize, getClass, notify, notifyAll, wait, wait, wait |
Field Detail |
---|
protected Pipe previous
Constructor Detail |
---|
protected Pipe()
@ConstructorProperties(value="previous") protected Pipe(Pipe previous)
@ConstructorProperties(value="name") public Pipe(String name)
name
- name for this branch of Pipes@ConstructorProperties(value={"name","previous"}) public Pipe(String name, Pipe previous)
name
- name for this branch of Pipesprevious
- previous Pipe to receive input Tuples fromMethod Detail |
---|
public static Pipe[] pipes(Pipe... pipes)
pipes
- vararg list of pipes
public static String[] names(Pipe... tails)
tails
- vararg list of all tails in given assembly
public String getName()
public Pipe[] getPrevious()
public Pipe[] getHeads()
public Scope outgoingScopeFor(Set<Scope> incomingScopes)
FlowElement
outgoingScopeFor
in interface FlowElement
incomingScopes
- of type SetFlowElement.outgoingScopeFor(java.util.Set)
public Fields resolveIncomingOperationFields(Scope incomingScope)
FlowElement
resolveIncomingOperationFields
in interface FlowElement
incomingScope
- of type Scope
FlowElement.resolveIncomingOperationFields(cascading.flow.Scope)
public Fields resolveFields(Scope scope)
FlowElement
resolveFields
in interface FlowElement
scope
- of type Scope
FlowElement.resolveFields(Scope)
public String getTrace()
public String toString()
toString
in class Object
public boolean isEquivalentTo(FlowElement element)
isEquivalentTo
in interface FlowElement
public boolean equals(Object object)
equals
in class Object
public int hashCode()
hashCode
in class Object
public String print(Scope scope)
scope
- of type Scope
protected void printInternal(StringBuffer buffer, Scope scope)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |