com.banda.serverbase.grid

Interface ComputationalGrid

All Known Implementing Classes:

GridGainComputationalGrid

public interface ComputationalGrid

Method Summary

Methods

Modifier and Type	Method and Description
void	cancelTask(String taskId)
com.banda.core.grid.GridMetrics	getMetrics()
int	getTotalActiveJobs()
<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)

Method Detail

getTotalActiveJobs

int getTotalActiveJobs()

getMetrics

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

cancelTask

void cancelTask(String taskId)

runOnGridSync

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

runOnGridSync

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

runOnGridAndMergeResultsSync

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

runOnGridAndMergeOutputsAsync

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

runOnGridAsync

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

runSerialLocal

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

runOnGridAndMergeOutputsAsync

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

runOnGridAsync

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

runOnGridAndMergeOutputsAsync

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

runOnGridAsync

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

runOnGridAndMergeResultsSync

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

runOnGridSync

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

runOnGridAndMergeResultsSync

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

runOnGridSync

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