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.
|
Modifier and Type | Method and Description |
---|---|
<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.
|
Copyright © 2016 The Apache Software Foundation. All rights reserved.