org.gridgain.grid.kernal.processors.streamer

Interface GridStreamerEx

All Superinterfaces:

GridStreamer

All Known Implementing Classes:

GridStreamerImpl

public interface GridStreamerEx
extends GridStreamer

Extended streamer context with methods intended for internal use.

Method Summary

Methods

Modifier and Type	Method and Description
GridStreamerEventRouter	eventRouter()
GridKernalContext	kernalContext()
void	onFutureCompleted(GridStreamerStageExecutionFuture fut) Called when future is completed and parent should be notified, if any.
void	onFutureMapped(GridStreamerStageExecutionFuture fut) Called before execution requests are sent to remote nodes or scheduled for local execution.
void	onQueryCompleted(long time, int nodes) Callback executed when streamer query completes.
void	onUndeploy(UUID leftNodeId, ClassLoader undeployedLdr) Callback for undeployed class loaders.
void	scheduleExecutions(GridStreamerStageExecutionFuture fut, Map<UUID,GridStreamerExecutionBatch> execs) Schedules batch executions either on local or on remote nodes.
<E> GridStreamerWindow<E>	window() Gets streamer default window (the first one in configuration list).
<E> GridStreamerWindow<E>	window(String windowName) Gets streamer window by window name.

Methods inherited from interface org.gridgain.grid.streamer.GridStreamer

addEvent, addEvents, addEventsToStage, addEventToStage, addStreamerFailureListener, configuration, context, deployClass, metrics, name, removeStreamerFailureListener, reset, resetMetrics

Method Detail

kernalContext

GridKernalContext kernalContext()

Returns:

Kernal context.

window

<E> GridStreamerWindow<E> window()

Gets streamer default window (the first one in configuration list).

Returns:

Streamer window.

window

@Nullable
<E> GridStreamerWindow<E> window(String windowName)

Gets streamer window by window name.

Parameters:

windowName - Window name.

Returns:

Streamer window.

onFutureMapped

void onFutureMapped(GridStreamerStageExecutionFuture fut)

Called before execution requests are sent to remote nodes or scheduled for local execution.

Parameters:

fut - Future.

onFutureCompleted

void onFutureCompleted(GridStreamerStageExecutionFuture fut)

Called when future is completed and parent should be notified, if any.

Parameters:

fut - Future.

eventRouter

GridStreamerEventRouter eventRouter()

Returns:

Streamer event router.

scheduleExecutions

void scheduleExecutions(GridStreamerStageExecutionFuture fut,
                      Map<UUID,GridStreamerExecutionBatch> execs)
                        throws GridException

Schedules batch executions either on local or on remote nodes.

Parameters:

fut - Future.

execs - Executions grouped by node ID.

Throws:

GridException - If failed.

onUndeploy

void onUndeploy(UUID leftNodeId,
              ClassLoader undeployedLdr)

Callback for undeployed class loaders. All deployed events will be removed from window and local storage.

Parameters:

leftNodeId - Left node ID which caused undeployment.

undeployedLdr - Undeployed class loader.

onQueryCompleted

void onQueryCompleted(long time,
                    int nodes)

Callback executed when streamer query completes.

Parameters:

time - Consumed time.

nodes - Participating nodes count.