Package | Description |
---|---|
org.shared.parallel |
A framework for specifying and executing parallel dataflow engines.
|
Modifier and Type | Class and Description |
---|---|
protected class |
Engine.EngineEdge<O>
An output-input relationship between two
Engine.EngineNode s. |
protected class |
Engine.EngineNode<I,O>
A computation node that is part of some topology of nodes.
|
Modifier and Type | Method and Description |
---|---|
<I,O> Handle<O> |
Engine.add(Calculator<I,O> calc,
boolean hasOutput,
Collection<? extends Calculator<?,? extends I>> calcDeps)
Adds a
Calculator along with its dependencies. |
<I,O> Handle<O> |
Engine.addOutput(Calculator<I,O> calc,
Calculator<?,? extends I>... calcDeps)
Adds an output
Calculator along with its dependencies. |
Modifier and Type | Method and Description |
---|---|
O |
Calculator.calculate(List<? extends Handle<? extends I>> inputs)
Performs an atomic calculation.
|