Uses of Class
org.apache.ignite.internal.processors.streamer.GridStreamerStageExecutionFuture

Packages that use GridStreamerStageExecutionFuture

Package	Description
org.apache.ignite.internal.processors.streamer	TODO.

Uses of GridStreamerStageExecutionFuture in org.apache.ignite.internal.processors.streamer

Methods in org.apache.ignite.internal.processors.streamer with parameters of type GridStreamerStageExecutionFuture

Modifier and Type	Method and Description
void	IgniteStreamerImpl.onFutureCompleted(GridStreamerStageExecutionFuture fut) Called when future is completed and parent should be notified, if any.
void	IgniteStreamerEx.onFutureCompleted(GridStreamerStageExecutionFuture fut) Called when future is completed and parent should be notified, if any.
void	IgniteStreamerImpl.onFutureMapped(GridStreamerStageExecutionFuture fut) Called before execution requests are sent to remote nodes or scheduled for local execution.
void	IgniteStreamerEx.onFutureMapped(GridStreamerStageExecutionFuture fut) Called before execution requests are sent to remote nodes or scheduled for local execution.
void	IgniteStreamerImpl.scheduleExecutions(GridStreamerStageExecutionFuture fut, Map<UUID,GridStreamerExecutionBatch> execs) Schedules batch executions either on local or on remote nodes.
void	IgniteStreamerEx.scheduleExecutions(GridStreamerStageExecutionFuture fut, Map<UUID,GridStreamerExecutionBatch> execs) Schedules batch executions either on local or on remote nodes.