See: Description
Interface | Description |
---|---|
TaskletReport |
The interface for a status report from the
VortexWorker . |
VortexFutureDelegate |
Exposes functions to be called by the
VortexMaster
to note that a list of Tasklets associated with a Future has completed. |
VortexRequest |
Master-to-Worker protocol.
|
Class | Description |
---|---|
AggregateFunctionRepository |
A repository for
VortexAggregateFunction and its associated VortexFunction ,
used to pass functions between VortexMaster and RunningWorkers, as well as used to cache functions
for VortexWorkers on AggregateRequests and AggregateExecutionRequests. |
TaskletAggregateExecutionRequest<TInput> |
A request from the Vortex Driver to run an aggregate-able function.
|
TaskletAggregationFailureReport |
Report of a tasklet exception on aggregation.
|
TaskletAggregationRequest<TInput,TOutput> |
A request from the Vortex Driver for the
VortexWorker to
record aggregate functions for later execution. |
TaskletAggregationResultReport |
Report of a Tasklet aggregation execution result.
|
TaskletCancellationRequest |
A
VortexRequest to cancel tasklets. |
TaskletCancelledReport |
The report of a cancelled Tasklet.
|
TaskletExecutionRequest<TInput,TOutput> |
Request to execute a tasklet.
|
TaskletFailureReport |
Report of a Tasklet exception.
|
TaskletResultReport |
Report of a tasklet execution result.
|
VortexAvroUtils |
Serialize and deserialize Vortex message to/from byte array.
|
WorkerReport |
Worker-to-Master protocol.
|
Enum | Description |
---|---|
TaskletReport.TaskletReportType |
Type of TaskletReport.
|
VortexRequest.RequestType |
Type of Request.
|
Copyright © 2016 The Apache Software Foundation. All rights reserved.