Package | Description |
---|---|
org.shared.parallel |
A framework for specifying and executing parallel dataflow engines.
|
Modifier and Type | Method and Description |
---|---|
Calculator<? super Object,? extends T> |
Engine.getInput()
Gets the initial
Calculator , which does nothing aside from repeating input given to it. |
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> void |
Engine.add(Calculator<I,O> calc,
Calculator<?,? extends I>... calcDeps)
Adds a non-output
Calculator along with its dependencies. |
<I,O> void |
Engine.add(Calculator<I,O> calc,
Calculator<?,? extends I>... calcDeps)
Adds a non-output
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. |
<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 |
---|---|
<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. |
Constructor and Description |
---|
Engine.EngineNode(Calculator<? super I,? extends O> calculator,
boolean hasOutput)
Default constructor.
|