com.banda.serverbase.grid

Class GridGainComputationalGrid

java.lang.Object

com.banda.serverbase.grid.GridGainComputationalGrid

All Implemented Interfaces:

ComputationalGrid

public class GridGainComputationalGrid
extends Object
implements ComputationalGrid

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.commons.logging.Log	log

Constructor Summary

Constructors

Constructor and Description
GridGainComputationalGrid()

Method Summary

Methods

Modifier and Type	Method and Description
void	cancelTask(String taskId)
org.gridgain.grid.Grid	getGrid()
com.banda.core.grid.GridMetrics	getMetrics()
int	getTotalActiveJobs()
Integer	runHelloWorld(String phrase)
<IN,OUT> Future<Collection<OUT>>	runOnGridAndMergeOutputsAsync(ArgumentCallable<IN,Collection<OUT>> call, Collection<IN> inputs)
<IN,OUT> Future<Collection<OUT>>	runOnGridAndMergeOutputsAsync(ArgumentCallable<IN,Collection<OUT>> call, Collection<IN> inputs, int jobsInSequenceNum)
<IN,OUT> Future<Collection<OUT>>	runOnGridAndMergeOutputsAsync(ArgumentCallable<IN,Collection<OUT>> call, IN input, int repetitions, int jobsInSequenceNum)
<IN,OUT> Collection<OUT>	runOnGridAndMergeResultsSync(ArgumentCallable<IN,Collection<OUT>> call, Collection<IN> inputs)
<IN,OUT> Collection<OUT>	runOnGridAndMergeResultsSync(ArgumentCallable<IN,Collection<OUT>> call, Collection<IN> inputs, int jobsInSequenceNum)
<IN,OUT> Collection<OUT>	runOnGridAndMergeResultsSync(ArgumentCallable<IN,Collection<OUT>> call, IN input, int repetitions, Integer maxJobsInParallelNum)
<IN,OUT> Future<Collection<OUT>>	runOnGridAsync(ArgumentCallable<IN,OUT> call, Collection<IN> inputs)
<IN,OUT> Future<Collection<OUT>>	runOnGridAsync(ArgumentCallable<IN,OUT> call, Collection<IN> inputs, int jobsInSequenceNum)
<IN,OUT> Future<Collection<OUT>>	runOnGridAsync(ArgumentCallable<IN,OUT> call, IN input, int repetitions, int jobsInSequenceNum)
<IN,OUT> Collection<OUT>	runOnGridSync(ArgumentCallable<IN,OUT> call, Collection<IN> inputs)
<IN,OUT> Collection<OUT>	runOnGridSync(ArgumentCallable<IN,OUT> call, Collection<IN> inputs, int jobsInSequenceNum)
<IN,OUT> Collection<OUT>	runOnGridSync(ArgumentCallable<IN,OUT> call, Collection<IN> inputs, int jobsInSequenceNum, Integer maxJobsInParallelNum)
<IN,OUT> Collection<OUT>	runOnGridSync(ArgumentCallable<IN,OUT> call, IN input, int repetitions, int jobsInSequenceNum, Integer maxJobsInParallelNum)
<IN,OUT> Collection<OUT>	runSerialLocal(ArgumentCallable<IN,OUT> call, IN input, int repetitions)
void	setGrid(org.gridgain.grid.Grid grid)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

log

protected final org.apache.commons.logging.Log log

Constructor Detail

GridGainComputationalGrid

public GridGainComputationalGrid()

Method Detail

getTotalActiveJobs

public int getTotalActiveJobs()

Specified by:

getTotalActiveJobs in interface ComputationalGrid

getMetrics

public com.banda.core.grid.GridMetrics getMetrics()

Specified by:

getMetrics in interface ComputationalGrid

cancelTask

public void cancelTask(String taskId)

Specified by:

cancelTask in interface ComputationalGrid

runOnGridSync

public <IN,OUT> Collection<OUT> runOnGridSync(ArgumentCallable<IN,OUT> call,
                                     IN input,
                                     int repetitions,
                                     int jobsInSequenceNum,
                                     Integer maxJobsInParallelNum)

Specified by:

runOnGridSync in interface ComputationalGrid

runOnGridSync

public <IN,OUT> Collection<OUT> runOnGridSync(ArgumentCallable<IN,OUT> call,
                                     Collection<IN> inputs,
                                     int jobsInSequenceNum,
                                     Integer maxJobsInParallelNum)

Specified by:

runOnGridSync in interface ComputationalGrid

runOnGridAndMergeResultsSync

public <IN,OUT> Collection<OUT> runOnGridAndMergeResultsSync(ArgumentCallable<IN,Collection<OUT>> call,
                                                    IN input,
                                                    int repetitions,
                                                    Integer maxJobsInParallelNum)

Specified by:

runOnGridAndMergeResultsSync in interface ComputationalGrid

runOnGridAndMergeOutputsAsync

public <IN,OUT> Future<Collection<OUT>> runOnGridAndMergeOutputsAsync(ArgumentCallable<IN,Collection<OUT>> call,
                                                             IN input,
                                                             int repetitions,
                                                             int jobsInSequenceNum)

Specified by:

runOnGridAndMergeOutputsAsync in interface ComputationalGrid

runOnGridAsync

public <IN,OUT> Future<Collection<OUT>> runOnGridAsync(ArgumentCallable<IN,OUT> call,
                                              IN input,
                                              int repetitions,
                                              int jobsInSequenceNum)

Specified by:

runOnGridAsync in interface ComputationalGrid

runSerialLocal

public <IN,OUT> Collection<OUT> runSerialLocal(ArgumentCallable<IN,OUT> call,
                                      IN input,
                                      int repetitions)

Specified by:

runSerialLocal in interface ComputationalGrid

runOnGridAndMergeOutputsAsync

public <IN,OUT> Future<Collection<OUT>> runOnGridAndMergeOutputsAsync(ArgumentCallable<IN,Collection<OUT>> call,
                                                             Collection<IN> inputs,
                                                             int jobsInSequenceNum)

Specified by:

runOnGridAndMergeOutputsAsync in interface ComputationalGrid

runOnGridAsync

public <IN,OUT> Future<Collection<OUT>> runOnGridAsync(ArgumentCallable<IN,OUT> call,
                                              Collection<IN> inputs,
                                              int jobsInSequenceNum)

Specified by:

runOnGridAsync in interface ComputationalGrid

runOnGridAndMergeOutputsAsync

public <IN,OUT> Future<Collection<OUT>> runOnGridAndMergeOutputsAsync(ArgumentCallable<IN,Collection<OUT>> call,
                                                             Collection<IN> inputs)

Specified by:

runOnGridAndMergeOutputsAsync in interface ComputationalGrid

runOnGridAsync

public <IN,OUT> Future<Collection<OUT>> runOnGridAsync(ArgumentCallable<IN,OUT> call,
                                              Collection<IN> inputs)

Specified by:

runOnGridAsync in interface ComputationalGrid

runOnGridAndMergeResultsSync

public <IN,OUT> Collection<OUT> runOnGridAndMergeResultsSync(ArgumentCallable<IN,Collection<OUT>> call,
                                                    Collection<IN> inputs,
                                                    int jobsInSequenceNum)

Specified by:

runOnGridAndMergeResultsSync in interface ComputationalGrid

runOnGridSync

public <IN,OUT> Collection<OUT> runOnGridSync(ArgumentCallable<IN,OUT> call,
                                     Collection<IN> inputs,
                                     int jobsInSequenceNum)

Specified by:

runOnGridSync in interface ComputationalGrid

runOnGridAndMergeResultsSync

public <IN,OUT> Collection<OUT> runOnGridAndMergeResultsSync(ArgumentCallable<IN,Collection<OUT>> call,
                                                    Collection<IN> inputs)

Specified by:

runOnGridAndMergeResultsSync in interface ComputationalGrid

runOnGridSync

public <IN,OUT> Collection<OUT> runOnGridSync(ArgumentCallable<IN,OUT> call,
                                     Collection<IN> inputs)

Specified by:

runOnGridSync in interface ComputationalGrid

runHelloWorld

public Integer runHelloWorld(String phrase)

getGrid

public org.gridgain.grid.Grid getGrid()

setGrid

public void setGrid(org.gridgain.grid.Grid grid)