public class FanSubflow extends Object implements EmbeddingCodelet
EmbeddingCodelet
that embeds a fan-out followed by fan-in of size equal to the number of incoming
HandleEdge
s.Constructor and Description |
---|
FanSubflow()
Default constructor.
|
Modifier and Type | Method and Description |
---|---|
void |
build(Flow flow,
List<FlowEdge> inEdges,
List<FlowNode> outNodes)
|
Node |
getEmbeddingParameters()
Gets the server-side embedding parameters.
|
void |
run(List<Resource> inResources,
List<Resource> outResources,
Node parameters)
Executes a unit of work.
|
void |
setEmbeddingParameters(Node parameters)
Sets the client-side embedding parameters.
|
String |
toString()
Creates a human-readable description of this
Codelet . |
public void build(Flow flow, List<FlowEdge> inEdges, List<FlowNode> outNodes)
FlowBuilder
build
in interface FlowBuilder
flow
- the Flow
.inEdges
- the assignable incoming FlowEdge
s.outNodes
- the assignable outgoing FlowNode
s.public void run(List<Resource> inResources, List<Resource> outResources, Node parameters)
Codelet
public Node getEmbeddingParameters()
EmbeddingCodelet
getEmbeddingParameters
in interface EmbeddingCodelet
public void setEmbeddingParameters(Node parameters)
EmbeddingCodelet
setEmbeddingParameters
in interface EmbeddingCodelet