cascading.flow

Interface FlowElement

All Superinterfaces:

Serializable

All Known Subinterfaces:

Group

All Known Implementing Classes:

AggregateBy, AverageBy, BasePartitionTap, Boundary, Checkpoint, Coerce, CoGroup, CountBy, DecoratorTap, Discard, Each, Every, Extent, FirstBy, GroupBy, HashJoin, MaxBy, Merge, MinBy, MultiSinkTap, MultiSourceTap, Operator, Pipe, Rename, Retain, SinkTap, SourceTap, Splice, SubAssembly, SumBy, Tap, Unique

public interface FlowElement
extends Serializable

Interface FlowElement is a utility interface used internally to simplify DAG management. It is not intended for users to interact with these methods directly.

Method Summary

Methods

Modifier and Type	Method and Description
ConfigDef	getConfigDef()
ConfigDef	getNodeConfigDef()
ConfigDef	getStepConfigDef()
boolean	hasConfigDef()
boolean	hasNodeConfigDef()
boolean	hasStepConfigDef()
boolean	isEquivalentTo(FlowElement element)
Scope	outgoingScopeFor(Set<Scope> incomingScopes) Method outgoingScopeFor returns the Scope this FlowElement hands off to the next FlowElement.
Fields	resolveIncomingOperationArgumentFields(Scope incomingScope) Method resolveIncomingOperationArgumentFields returns the Fields outgoing from the previous FlowElement that are consumable by this FlowElement when preparing Operation arguments.
Fields	resolveIncomingOperationPassThroughFields(Scope incomingScope) Method resolveIncomingOperationPassThroughFields returns the Fields outgoing from the previous FlowElement that are consumable by this FlowElement when preparing the Pipe outgoing tuple.

Method Detail

outgoingScopeFor

Scope outgoingScopeFor(Set<Scope> incomingScopes)

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

Parameters:

incomingScopes - of type Set

Returns:

Scope

resolveIncomingOperationArgumentFields

Fields resolveIncomingOperationArgumentFields(Scope incomingScope)

Method resolveIncomingOperationArgumentFields returns the Fields outgoing from the previous FlowElement that are consumable by this FlowElement when preparing Operation arguments.

Parameters:

incomingScope - of type Scope

Returns:

Fields

resolveIncomingOperationPassThroughFields

Fields resolveIncomingOperationPassThroughFields(Scope incomingScope)

Method resolveIncomingOperationPassThroughFields returns the Fields outgoing from the previous FlowElement that are consumable by this FlowElement when preparing the Pipe outgoing tuple.

Parameters:

incomingScope - of type Scope

Returns:

Fields

isEquivalentTo

boolean isEquivalentTo(FlowElement element)

getConfigDef

ConfigDef getConfigDef()

hasConfigDef

boolean hasConfigDef()

getNodeConfigDef

ConfigDef getNodeConfigDef()

hasNodeConfigDef

boolean hasNodeConfigDef()

getStepConfigDef

ConfigDef getStepConfigDef()

hasStepConfigDef

boolean hasStepConfigDef()