| Package | Description |
|---|---|
| org.gridgain.grid.kernal.processors.streamer |
TODO. |
| Modifier and Type | Method and Description |
|---|---|
void |
GridStreamerImpl.onFutureCompleted(GridStreamerStageExecutionFuture fut)
Called when future is completed and parent should be notified, if any.
|
void |
GridStreamerEx.onFutureCompleted(GridStreamerStageExecutionFuture fut)
Called when future is completed and parent should be notified, if any.
|
void |
GridStreamerImpl.onFutureMapped(GridStreamerStageExecutionFuture fut)
Called before execution requests are sent to remote nodes or scheduled for local execution.
|
void |
GridStreamerEx.onFutureMapped(GridStreamerStageExecutionFuture fut)
Called before execution requests are sent to remote nodes or scheduled for local execution.
|
void |
GridStreamerImpl.scheduleExecutions(GridStreamerStageExecutionFuture fut,
Map<UUID,GridStreamerExecutionBatch> execs)
Schedules batch executions either on local or on remote nodes.
|
void |
GridStreamerEx.scheduleExecutions(GridStreamerStageExecutionFuture fut,
Map<UUID,GridStreamerExecutionBatch> execs)
Schedules batch executions either on local or on remote nodes.
|
Copyright © 2014. All rights reserved.