org.gridgain.grid.streamer

Interface GridStreamerContext

All Known Implementing Classes:

GridStreamerContextDelegate, GridStreamerContextImpl

public interface GridStreamerContext

Streamer context. Provides access to streamer local store, configured windows and various methods to run streamer queries.

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.
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.

Method Detail

projection

GridProjection projection()

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

Returns:

Projection with all nodes on which streamer is configured.

localSpace

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

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

Returns:

Streamer local space.

window

<E> GridStreamerWindow<E> window()

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

Returns:

Default window.

window

<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.

Parameters:

winName - Window name.

Returns:

Window instance.

nextStageName

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.

Returns:

Next stage name depending on invocation context.

query

<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.

Parameters:

clo - Function to be executed on individual nodes.

Returns:

Result received from all streamers.

Throws:

GridException - If query execution failed.

query

<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.

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

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.

Parameters:

clo - Function to be executed on individual nodes.

Throws:

GridException - If closure execution failed.

broadcast

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.

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

<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.

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

<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.

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.