org.gridgain.grid.kernal.processors.streamer

Class GridStreamerImpl

java.lang.Object

org.gridgain.grid.kernal.processors.streamer.GridStreamerImpl

All Implemented Interfaces:

Externalizable, Serializable, GridStreamerEx, GridStreamer

public class GridStreamerImpl
extends Object
implements GridStreamerEx, Externalizable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
GridStreamerImpl() Empty constructor required by Externalizable.
GridStreamerImpl(GridKernalContext ctx, GridStreamerConfiguration c)

Method Summary

Methods

Modifier and Type	Method and Description
void	addEvent(Object evt, Object... evts) Submits group of events for processing.
void	addEvents(Collection<?> evts) Submits group of events for processing.
void	addEventsToStage(String stageName, Collection<?> evts) Submits events to streamer.
void	addEventToStage(String stageName, Object evt, Object... evts) Submits group of events to streamer.
void	addStreamerFailureListener(GridStreamerFailureListener lsnr) Adds streamer failure listener.
boolean	cancelled(GridUuid futId) Checks if cancel request was received for this future ID.
GridStreamerConfiguration	configuration() Gets streamer configuration.
GridStreamerContext	context() Gets streamer context.
void	deployClass(Class<?> depCls) Explicitly sets deployment class.
GridStreamerEventRouter	eventRouter()
GridKernalContext	kernalContext()
GridStreamerMetrics	metrics() Gets current streamer metrics.
String	name() Gets streamer name.
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	onKernalStop(boolean cancel) On kernal stop callback.
void	onQueryCompleted(long time, int nodes) Callback executed when streamer query completes.
void	onUndeploy(UUID leftNodeId, ClassLoader undeployedLdr) Callback for undeployed class loaders.
void	readExternal(ObjectInput in)
protected Object	readResolve() Reconstructs object on unmarshalling.
void	removeStreamerFailureListener(GridStreamerFailureListener lsnr) Removes streamer failure listener.
void	reset() Resets all configured streamer windows by calling GridStreamerWindow.reset() on each and clears local space.
void	resetMetrics() Resets all streamer metrics.
void	scheduleExecutions(GridStreamerStageExecutionFuture fut, Map<UUID,GridStreamerExecutionBatch> execs) Schedules batch executions either on local or on remote nodes.
void	start()
void	stop(boolean cancel)
String	toString()
<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.
void	writeExternal(ObjectOutput out)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

GridStreamerImpl

public GridStreamerImpl()

Empty constructor required by Externalizable.

GridStreamerImpl

public GridStreamerImpl(GridKernalContext ctx,
                GridStreamerConfiguration c)

Parameters:

ctx - Kernal context.

c - Configuration.

Method Detail

start

public void start()
           throws GridException

Throws:

GridException - If failed.

onKernalStop

public void onKernalStop(boolean cancel)

On kernal stop callback.

Parameters:

cancel - Cancel.

stop

public void stop(boolean cancel)

Parameters:

cancel - Whether currently running tasks should be cancelled.

name

@Nullable
public String name()

Gets streamer name.

Specified by:

name in interface GridStreamer

Returns:

Streamer name.

configuration

public GridStreamerConfiguration configuration()

Gets streamer configuration.

Specified by:

configuration in interface GridStreamer

Returns:

Streamer configuration.

addEvent

public void addEvent(Object evt,
            Object... evts)
              throws GridException

Submits group of events for processing. This group of events will be processed on default stage, i.e. stage that is the first in the streamer stages list.

Specified by:

addEvent in interface GridStreamer

Parameters:

evt - Event to add.

evts - Optional events to add.

Throws:

GridException - If event submission failed.

addEventToStage

public void addEventToStage(String stageName,
                   Object evt,
                   Object... evts)
                     throws GridException

Submits group of events to streamer. Events will be processed from a stage with specified name.

Specified by:

addEventToStage in interface GridStreamer

Parameters:

stageName - Stage name to start with.

evt - Event tp process.

evts - Optional events.

Throws:

GridException - If event submission failed.

addEvents

public void addEvents(Collection<?> evts)
               throws GridException

Submits group of events for processing. This group of events will be processed on default stage, i.e. stage that is the first in the streamer stages list.

Specified by:

addEvents in interface GridStreamer

Parameters:

evts - Events to add.

Throws:

GridException - If event submission failed.

addEventsToStage

public void addEventsToStage(String stageName,
                    Collection<?> evts)
                      throws GridException

Submits events to streamer. Events will be processed from a stage with specified name.

Specified by:

addEventsToStage in interface GridStreamer

Parameters:

stageName - Stage name to start with.

evts - Events to process.

Throws:

GridException - If event submission failed.

context

public GridStreamerContext context()

Gets streamer context. Streamer context provides access to streamer local space on this node, configured streamer windows and provides various methods to run streamer queries.

Specified by:

context in interface GridStreamer

Returns:

Streamer context.

addStreamerFailureListener

public void addStreamerFailureListener(GridStreamerFailureListener lsnr)

Adds streamer failure listener. Listener will be notified on node on which failure occurred in case if GridStreamerConfiguration.isAtLeastOnce() is set to false and on node which originated pipeline execution otherwise.

Specified by:

addStreamerFailureListener in interface GridStreamer

Parameters:

lsnr - Listener to add.

removeStreamerFailureListener

public void removeStreamerFailureListener(GridStreamerFailureListener lsnr)

Removes streamer failure listener.

Specified by:

removeStreamerFailureListener in interface GridStreamer

Parameters:

lsnr - Listener to remove.

metrics

public GridStreamerMetrics metrics()

Gets current streamer metrics.

Specified by:

metrics in interface GridStreamer

Returns:

Streamer metrics.

reset

public void reset()

Resets all configured streamer windows by calling GridStreamerWindow.reset() on each and clears local space.

This is local method, it will clear only local windows and local space. Note that windows and space will not be cleaned while stages are executing, i.e. all currently running stages will have to complete before streamer can be reset.

Specified by:

reset in interface GridStreamer

resetMetrics

public void resetMetrics()

Resets all streamer metrics.

Specified by:

resetMetrics in interface GridStreamer

deployClass

public void deployClass(Class<?> depCls)

Explicitly sets deployment class. Will be used only if peer-to-peer class loading is enabled.

Specified by:

deployClass in interface GridStreamer

Parameters:

depCls - Deployment class.

window

public <E> GridStreamerWindow<E> window()

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

Specified by:

window in interface GridStreamerEx

Returns:

Streamer window.

window

public <E> GridStreamerWindow<E> window(String windowName)

Gets streamer window by window name.

Specified by:

window in interface GridStreamerEx

Parameters:

windowName - Window name.

Returns:

Streamer window.

kernalContext

public GridKernalContext kernalContext()

Specified by:

kernalContext in interface GridStreamerEx

Returns:

Kernal context.

onFutureMapped

public void onFutureMapped(GridStreamerStageExecutionFuture fut)

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

Specified by:

onFutureMapped in interface GridStreamerEx

Parameters:

fut - Future.

onFutureCompleted

public void onFutureCompleted(GridStreamerStageExecutionFuture fut)

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

Specified by:

onFutureCompleted in interface GridStreamerEx

Parameters:

fut - Future.

eventRouter

public GridStreamerEventRouter eventRouter()

Specified by:

eventRouter in interface GridStreamerEx

Returns:

Streamer event router.

scheduleExecutions

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

Schedules batch executions either on local or on remote nodes.

Specified by:

scheduleExecutions in interface GridStreamerEx

Parameters:

fut - Future.

execs - Executions grouped by node ID.

Throws:

GridException - If failed.

onUndeploy

public void onUndeploy(UUID leftNodeId,
              ClassLoader undeployedLdr)

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

Specified by:

onUndeploy in interface GridStreamerEx

Parameters:

leftNodeId - Left node ID which caused undeployment.

undeployedLdr - Undeployed class loader.

onQueryCompleted

public void onQueryCompleted(long time,
                    int nodes)

Callback executed when streamer query completes.

Specified by:

onQueryCompleted in interface GridStreamerEx

Parameters:

time - Consumed time.

nodes - Participating nodes count.

cancelled

public boolean cancelled(GridUuid futId)

Checks if cancel request was received for this future ID.

Parameters:

futId - Future ID.

Returns:

True if future was cancelled, false otherwise.

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Throws:

IOException

ClassNotFoundException

readResolve

protected Object readResolve()

Reconstructs object on unmarshalling.

Returns:

Reconstructed object.

toString

public String toString()

Overrides:

toString in class Object