org.gridgain.grid.kernal.processors.streamer

Class GridStreamerContextImpl

java.lang.Object

org.gridgain.grid.kernal.processors.streamer.GridStreamerContextImpl

All Implemented Interfaces:

GridStreamerContext

public class GridStreamerContextImpl
extends Object
implements GridStreamerContext

Streamer context implementation.

Constructor Summary

Constructors

Constructor and Description
GridStreamerContextImpl(GridKernalContext ctx, GridStreamerConfiguration cfg, GridStreamerEx streamer)

Method Summary

Methods

Modifier and Type	Method and Description
void	broadcast(GridInClosure<GridStreamerContext> clo) Queries all streamer nodes deployed within grid.
void	broadcast(GridInClosure<GridStreamerContext> clo, Collection<GridNode> nodes) Queries streamer nodes deployed within grid.
<K,V> ConcurrentMap<K,V>	localSpace() Gets streamer local space.
String	nextStageName() For context passed to GridStreamerStage.run(GridStreamerContext, Collection) this method will return next stage name in execution pipeline.
void	nextStageName(String nextStageName) Sets next stage name for main context.
GridProjection	projection() Gets instance of dynamic grid projection including all nodes on which this streamer is running.
<R> Collection<R>	query(GridClosure<GridStreamerContext,R> clo) Queries all streamer nodes deployed within grid.
<R> Collection<R>	query(GridClosure<GridStreamerContext,R> clo, Collection<GridNode> nodes) Queries streamer nodes deployed within grid.
<R1,R2> R2	reduce(GridClosure<GridStreamerContext,R1> clo, GridReducer<R1,R2> rdc) Queries all streamer nodes deployed within grid.
<R1,R2> R2	reduce(GridClosure<GridStreamerContext,R1> clo, GridReducer<R1,R2> rdc, Collection<GridNode> nodes) Queries streamer nodes deployed within grid.
<E> GridStreamerWindow<E>	window() Gets default event window, i.e.
<E> GridStreamerWindow<E>	window(String winName) Gets streamer event window by window name, if no window with such name was configured IllegalArgumentException will be thrown.

Methods inherited from class java.lang.Object

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

Constructor Detail

GridStreamerContextImpl

public GridStreamerContextImpl(GridKernalContext ctx,
                       GridStreamerConfiguration cfg,
                       GridStreamerEx streamer)

Parameters:

ctx - Kernal context.

cfg - Streamer configuration.

streamer - Streamer impl.

Method Detail

projection

public GridProjection projection()

Gets instance of dynamic grid projection including all nodes on which this streamer is running.

Specified by:

projection in interface GridStreamerContext

Returns:

Projection with all nodes on which streamer is configured.

localSpace

public <K,V> ConcurrentMap<K,V> localSpace()

Gets streamer local space. Note that all updates to this space will be local.

Specified by:

localSpace in interface GridStreamerContext

Returns:

Streamer local space.

window

public <E> GridStreamerWindow<E> window()

Gets default event window, i.e. window that is on the first place in streamer configuration.

Specified by:

window in interface GridStreamerContext

Returns:

Default window.

window

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

Gets streamer event window by window name, if no window with such name was configured IllegalArgumentException will be thrown.

Specified by:

window in interface GridStreamerContext

Parameters:

winName - Window name.

Returns:

Window instance.

nextStageName

public String nextStageName()

For context passed to GridStreamerStage.run(GridStreamerContext, Collection) this method will return next stage name in execution pipeline. For context obtained from streamer object, this method will return first stage name.

Specified by:

nextStageName in interface GridStreamerContext

Returns:

Next stage name depending on invocation context.

nextStageName

public void nextStageName(String nextStageName)

Sets next stage name for main context.

Parameters:

nextStageName - Next stage name.

query

public <R> Collection<R> query(GridClosure<GridStreamerContext,R> clo)
                    throws GridException

Queries all streamer nodes deployed within grid. Given closure will be executed on each node on which streamer is configured. Streamer context local for that node will be passed to closure during execution. All results returned by closure will be added to result collection.

Specified by:

query in interface GridStreamerContext

Parameters:

clo - Function to be executed on individual nodes.

Returns:

Result received from all streamers.

Throws:

GridException - If query execution failed.

query

public <R> Collection<R> query(GridClosure<GridStreamerContext,R> clo,
                      Collection<GridNode> nodes)
                    throws GridException

Queries streamer nodes deployed within grid. Given closure will be executed on those of passed nodes on which streamer is configured. Streamer context local for that node will be passed to closure during execution. All results returned by closure will be added to result collection.

Specified by:

query in interface GridStreamerContext

Parameters:

clo - Function to be executed on individual nodes.

nodes - Optional list of nodes to execute query on, if empty, then all nodes on which this streamer is running will be queried.

Returns:

Result received from all streamers.

Throws:

GridException - If query execution failed.

broadcast

public void broadcast(GridInClosure<GridStreamerContext> clo)
               throws GridException

Queries all streamer nodes deployed within grid. Given closure will be executed on each streamer node in the grid. No result is collected.

Specified by:

broadcast in interface GridStreamerContext

Parameters:

clo - Function to be executed on individual nodes.

Throws:

GridException - If closure execution failed.

broadcast

public void broadcast(GridInClosure<GridStreamerContext> clo,
             Collection<GridNode> nodes)
               throws GridException

Queries streamer nodes deployed within grid. Given closure will be executed on those of passed nodes on which streamer is configured. No result is collected.

Specified by:

broadcast in interface GridStreamerContext

Parameters:

clo - Function to be executed on individual nodes.

nodes - Optional list of nodes to execute query on, if empty, then all nodes on which this streamer is running will be queried.

Throws:

GridException - If closure execution failed.

reduce

public <R1,R2> R2 reduce(GridClosure<GridStreamerContext,R1> clo,
                GridReducer<R1,R2> rdc)
          throws GridException

Queries all streamer nodes deployed within grid. Given closure will be executed on each streamer node in the grid. Streamer context local for that node will be passed to closure during execution. Results returned by closure will be passed to given reducer.

Specified by:

reduce in interface GridStreamerContext

Parameters:

clo - Function to be executed on individual nodes.

rdc - Reducer to reduce results received from remote nodes.

Returns:

Reducer result.

Throws:

GridException - If query execution failed.

reduce

public <R1,R2> R2 reduce(GridClosure<GridStreamerContext,R1> clo,
                GridReducer<R1,R2> rdc,
                Collection<GridNode> nodes)
          throws GridException

Queries streamer nodes deployed within grid. Given closure will be executed on those of passed nodes on which streamer is configured. Streamer context local for that node will be passed to closure during execution. Results returned by closure will be passed to given reducer.

Specified by:

reduce in interface GridStreamerContext

Parameters:

clo - Function to be executed on individual nodes.

rdc - Reducer to reduce results received from remote nodes.

nodes - Optional list of nodes to execute query on, if empty, then all nodes on which this streamer is running will be queried.

Returns:

Reducer result.

Throws:

GridException - If query execution failed.