Package | Description |
---|---|
org.apache.reef.vortex.common |
Vortex Code used both in Vortex Driver and Vortex Evaluator.
|
Modifier and Type | Class and Description |
---|---|
class |
TaskletAggregateExecutionRequest<TInput>
A request from the Vortex Driver to run an aggregate-able function.
|
class |
TaskletAggregationRequest<TInput,TOutput>
A request from the Vortex Driver for the
VortexWorker to
record aggregate functions for later execution. |
class |
TaskletCancellationRequest
A
VortexRequest to cancel tasklets. |
class |
TaskletExecutionRequest<TInput,TOutput>
Request to execute a tasklet.
|
Modifier and Type | Method and Description |
---|---|
VortexRequest |
VortexAvroUtils.toVortexRequest(byte[] bytes)
Deserialize byte array to VortexRequest.
|
Modifier and Type | Method and Description |
---|---|
byte[] |
VortexAvroUtils.toBytes(VortexRequest vortexRequest)
Serialize VortexRequest to byte array.
|
Copyright © 2016 The Apache Software Foundation. All rights reserved.