org.apache.reef.vortex.api

Class VortexThreadPool

java.lang.Object

org.apache.reef.vortex.api.VortexThreadPool

public final class VortexThreadPool
extends Object

Distributed thread pool.

Method Summary

Methods

Modifier and Type	Method and Description
<TInput,TOutput> VortexAggregateFuture<TInput,TOutput>	submit(VortexAggregateFunction<TOutput> aggregateFunction, VortexFunction<TInput,TOutput> function, VortexAggregatePolicy policy, List<TInput> inputs)
<TInput,TOutput> VortexAggregateFuture<TInput,TOutput>	submit(VortexAggregateFunction<TOutput> aggregateFunction, VortexFunction<TInput,TOutput> function, VortexAggregatePolicy policy, List<TInput> inputs, FutureCallback<AggregateResult<TInput,TOutput>> callback)
<TInput,TOutput> VortexFuture<TOutput>	submit(VortexFunction<TInput,TOutput> function, TInput input)
<TInput,TOutput> VortexFuture<TOutput>	submit(VortexFunction<TInput,TOutput> function, TInput input, FutureCallback<TOutput> callback)

Methods inherited from class java.lang.Object

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

Method Detail

submit

public <TInput,TOutput> VortexFuture<TOutput> submit(VortexFunction<TInput,TOutput> function,
                                            TInput input)

Type Parameters:

TInput - input type

TOutput - output type

Parameters:

function - to run on Vortex

input - of the function

Returns:

VortexFuture for tracking execution progress

submit

public <TInput,TOutput> VortexFuture<TOutput> submit(VortexFunction<TInput,TOutput> function,
                                            TInput input,
                                            FutureCallback<TOutput> callback)

Type Parameters:

TInput - input type

TOutput - output type

Parameters:

function - to run on Vortex

input - of the function

callback - of the function

Returns:

VortexFuture for tracking execution progress

submit

public <TInput,TOutput> VortexAggregateFuture<TInput,TOutput> submit(VortexAggregateFunction<TOutput> aggregateFunction,
                                                            VortexFunction<TInput,TOutput> function,
                                                            VortexAggregatePolicy policy,
                                                            List<TInput> inputs)

Type Parameters:

TInput - input type

TOutput - output type

Parameters:

aggregateFunction - to run on VortexFunction outputs

function - to run on Vortex

policy - on aggregation

inputs - of the function

Returns:

VortexAggregationFuture for tracking execution progress of aggregate-able functions

submit

public <TInput,TOutput> VortexAggregateFuture<TInput,TOutput> submit(VortexAggregateFunction<TOutput> aggregateFunction,
                                                            VortexFunction<TInput,TOutput> function,
                                                            VortexAggregatePolicy policy,
                                                            List<TInput> inputs,
                                                            FutureCallback<AggregateResult<TInput,TOutput>> callback)

Type Parameters:

TInput - input type

TOutput - output type

Parameters:

aggregateFunction - to run on VortexFunction outputs

function - to run on Vortex

policy - on aggregation

inputs - of the function

callback - of the aggregation

Returns:

VortexAggregationFuture for tracking execution progress of aggregate-able functions