cascading.flow
Interface FlowElement

All Superinterfaces:
Serializable
All Known Subinterfaces:
Group
All Known Implementing Classes:
AggregateBy, AverageBy, BaseTemplateTap, Checkpoint, Coerce, CoGroup, CountBy, Dfs, Discard, Each, Every, FileTap, GlobHfs, GroupBy, HashJoin, Hfs, Lfs, Merge, MultiSinkTap, MultiSourceTap, Operator, Pipe, Rename, Retain, SinkTap, SourceTap, Splice, StdErrTap, StdInTap, StdOutTap, SubAssembly, SumBy, Tap, TempHfs, TemplateTap, TemplateTap, 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
 ConfigDef getConfigDef()
           
 ConfigDef getStepConfigDef()
           
 boolean hasConfigDef()
           
 boolean hasStepConfigDef()
           
 boolean isEquivalentTo(FlowElement element)
           
 cascading.flow.planner.Scope outgoingScopeFor(Set<cascading.flow.planner.Scope> incomingScopes)
          Method outgoingScopeFor returns the Scope this FlowElement hands off to the next FlowElement.
 Fields resolveFields(cascading.flow.planner.Scope scope)
          Method resolveFields returns the actual field names represented by the given Scope.
 Fields resolveIncomingOperationFields(cascading.flow.planner.Scope incomingScope)
          Method resolveIncomingOperationFields resolves the incoming scopes to the actual incoming operation field names.
 

Method Detail

outgoingScopeFor

cascading.flow.planner.Scope outgoingScopeFor(Set<cascading.flow.planner.Scope> incomingScopes)
Method outgoingScopeFor returns the Scope this FlowElement hands off to the next FlowElement.

Parameters:
incomingScopes - of type Set
Returns:
Scope

resolveIncomingOperationFields

Fields resolveIncomingOperationFields(cascading.flow.planner.Scope incomingScope)
Method resolveIncomingOperationFields resolves the incoming scopes to the actual incoming operation field names.

Parameters:
incomingScope - of type Scope
Returns:
Fields

resolveFields

Fields resolveFields(cascading.flow.planner.Scope scope)
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.

Parameters:
scope - of type Scope
Returns:
Fields

isEquivalentTo

boolean isEquivalentTo(FlowElement element)

getStepConfigDef

ConfigDef getStepConfigDef()

hasStepConfigDef

boolean hasStepConfigDef()

getConfigDef

ConfigDef getConfigDef()

hasConfigDef

boolean hasConfigDef()


Copyright © 2007-2012 Concurrent, Inc. All Rights Reserved.