Package | Description |
---|---|
org.apache.reef.vortex.api |
Vortex user api for running jobs on Vortex.
|
org.apache.reef.vortex.driver |
Vortex Code that runs as part of REEF Driver.
|
org.apache.reef.vortex.examples.sumones |
A Simple Vortex addition and aggregation example.
|
org.apache.reef.vortex.protocol.mastertoworker |
Protocol from VortexMaster to VortexWorker.
|
Modifier and Type | Method and Description |
---|---|
<TInput,TOutput> |
VortexThreadPool.submit(VortexAggregateFunction<TOutput> aggregateFunction,
VortexFunction<TInput,TOutput> function,
VortexAggregatePolicy policy,
List<TInput> inputs) |
<TInput,TOutput> |
VortexThreadPool.submit(VortexAggregateFunction<TOutput> aggregateFunction,
VortexFunction<TInput,TOutput> function,
VortexAggregatePolicy policy,
List<TInput> inputs,
FutureCallback<AggregateResult<TInput,TOutput>> callback) |
<TInput,TOutput> |
VortexThreadPool.submit(VortexFunction<TInput,TOutput> function,
TInput input) |
<TInput,TOutput> |
VortexThreadPool.submit(VortexFunction<TInput,TOutput> function,
TInput input,
FutureCallback<TOutput> callback) |
Modifier and Type | Method and Description |
---|---|
<TInput,TOutput> |
VortexMaster.enqueueTasklet(VortexFunction<TInput,TOutput> vortexFunction,
TInput input,
Optional<FutureCallback<TOutput>> callback)
Submit a new Tasklet to be run sometime in the future, with an optional callback function on the result.
|
<TInput,TOutput> |
VortexMaster.enqueueTasklets(VortexAggregateFunction<TOutput> aggregateFunction,
VortexFunction<TInput,TOutput> vortexFunction,
VortexAggregatePolicy policy,
List<TInput> inputs,
Optional<FutureCallback<AggregateResult<TInput,TOutput>>> callback)
Submits aggregate-able Tasklets to be run sometime in the future, with an optional callback function on
the aggregation progress.
|
Modifier and Type | Class and Description |
---|---|
class |
IdentityFunction
Identity function.
|
Modifier and Type | Method and Description |
---|---|
VortexFunction |
TaskletExecutionRequest.getFunction()
Get function of the tasklet.
|
VortexFunction |
TaskletAggregationRequest.getFunction() |
Constructor and Description |
---|
TaskletAggregationRequest(int aggregateFunctionId,
VortexAggregateFunction<TOutput> aggregateFunction,
VortexFunction<TInput,TOutput> function,
VortexAggregatePolicy policy) |
TaskletExecutionRequest(int taskletId,
VortexFunction<TInput,TOutput> userFunction,
TInput input)
Request from Vortex Master to Vortex Worker to execute a tasklet.
|
Copyright © 2017 The Apache Software Foundation. All rights reserved.