Uses of Interface
org.gridgain.grid.streamer.GridStreamerContext

Packages that use GridStreamerContext

Package	Description
org.gridgain.grid.kernal.processors.streamer	TODO.
org.gridgain.grid.kernal.processors.streamer.task
org.gridgain.grid.streamer	Contains main Streaming APIs.
org.gridgain.grid.streamer.router	Contains streamer event router implementations.

Uses of GridStreamerContext in org.gridgain.grid.kernal.processors.streamer

Classes in org.gridgain.grid.kernal.processors.streamer that implement GridStreamerContext

Modifier and Type	Class and Description
class	GridStreamerContextDelegate Context delegate allowing to override next stage name.
class	GridStreamerContextImpl Streamer context implementation.

Methods in org.gridgain.grid.kernal.processors.streamer that return GridStreamerContext

Modifier and Type	Method and Description
GridStreamerContext	GridStreamerImpl.context() Gets streamer context.

Methods in org.gridgain.grid.kernal.processors.streamer with parameters of type GridStreamerContext

Modifier and Type	Method and Description
Map<String,Collection<?>>	GridStreamerStageWrapper.run(GridStreamerContext ctx, Collection<Object> evts) Stage execution routine.

Method parameters in org.gridgain.grid.kernal.processors.streamer with type arguments of type GridStreamerContext

Modifier and Type	Method and Description
void	GridStreamerContextDelegate.broadcast(GridInClosure<GridStreamerContext> clo) Queries all streamer nodes deployed within grid.
void	GridStreamerContextImpl.broadcast(GridInClosure<GridStreamerContext> clo) Queries all streamer nodes deployed within grid.
void	GridStreamerContextDelegate.broadcast(GridInClosure<GridStreamerContext> clo, Collection<GridNode> nodes) Queries streamer nodes deployed within grid.
void	GridStreamerContextImpl.broadcast(GridInClosure<GridStreamerContext> clo, Collection<GridNode> nodes) Queries streamer nodes deployed within grid.
<R> Collection<R>	GridStreamerContextDelegate.query(GridClosure<GridStreamerContext,R> clo) Queries all streamer nodes deployed within grid.
<R> Collection<R>	GridStreamerContextImpl.query(GridClosure<GridStreamerContext,R> clo) Queries all streamer nodes deployed within grid.
<R> Collection<R>	GridStreamerContextDelegate.query(GridClosure<GridStreamerContext,R> clo, Collection<GridNode> nodes) Queries streamer nodes deployed within grid.
<R> Collection<R>	GridStreamerContextImpl.query(GridClosure<GridStreamerContext,R> clo, Collection<GridNode> nodes) Queries streamer nodes deployed within grid.
<R1,R2> R2	GridStreamerContextDelegate.reduce(GridClosure<GridStreamerContext,R1> clo, GridReducer<R1,R2> rdc) Queries all streamer nodes deployed within grid.
<R1,R2> R2	GridStreamerContextImpl.reduce(GridClosure<GridStreamerContext,R1> clo, GridReducer<R1,R2> rdc) Queries all streamer nodes deployed within grid.
<R1,R2> R2	GridStreamerContextDelegate.reduce(GridClosure<GridStreamerContext,R1> clo, GridReducer<R1,R2> rdc, Collection<GridNode> nodes) Queries streamer nodes deployed within grid.
<R1,R2> R2	GridStreamerContextImpl.reduce(GridClosure<GridStreamerContext,R1> clo, GridReducer<R1,R2> rdc, Collection<GridNode> nodes) Queries streamer nodes deployed within grid.

Constructors in org.gridgain.grid.kernal.processors.streamer with parameters of type GridStreamerContext

Constructor and Description
GridStreamerContextDelegate(GridStreamerContext delegate, String nextStageName)

Uses of GridStreamerContext in org.gridgain.grid.kernal.processors.streamer.task

Constructor parameters in org.gridgain.grid.kernal.processors.streamer.task with type arguments of type GridStreamerContext

Constructor and Description
GridStreamerBroadcastTask(GridInClosure<GridStreamerContext> clo, String streamer)
GridStreamerQueryTask(GridClosure<GridStreamerContext,R> qryClos, String streamer)
GridStreamerReduceTask(GridClosure<GridStreamerContext,R1> clos, GridReducer<R1,R2> rdc, String streamer)

Uses of GridStreamerContext in org.gridgain.grid.streamer

Methods in org.gridgain.grid.streamer that return GridStreamerContext

Modifier and Type	Method and Description
GridStreamerContext	GridStreamer.context() Gets streamer context.

Methods in org.gridgain.grid.streamer with parameters of type GridStreamerContext

Modifier and Type	Method and Description
<T> Map<GridNode,Collection<T>>	GridStreamerEventRouter.route(GridStreamerContext ctx, String stageName, Collection<T> evts) Selects a node for given events that should be processed by a stage with given name.
<T> Map<GridNode,Collection<T>>	GridStreamerEventRouterAdapter.route(GridStreamerContext ctx, String stageName, Collection<T> evts) Selects a node for given events that should be processed by a stage with given name.
<T> GridNode	GridStreamerEventRouter.route(GridStreamerContext ctx, String stageName, T evt) Selects a node for given event that should be processed by a stage with given name.
Map<String,Collection<?>>	GridStreamerStage.run(GridStreamerContext ctx, Collection<IN> evts) Stage execution routine.

Method parameters in org.gridgain.grid.streamer with type arguments of type GridStreamerContext

Modifier and Type	Method and Description
void	GridStreamerContext.broadcast(GridInClosure<GridStreamerContext> clo) Queries all streamer nodes deployed within grid.
void	GridStreamerContext.broadcast(GridInClosure<GridStreamerContext> clo, Collection<GridNode> nodes) Queries streamer nodes deployed within grid.
<R> Collection<R>	GridStreamerContext.query(GridClosure<GridStreamerContext,R> clo) Queries all streamer nodes deployed within grid.
<R> Collection<R>	GridStreamerContext.query(GridClosure<GridStreamerContext,R> clo, Collection<GridNode> nodes) Queries streamer nodes deployed within grid.
<R1,R2> R2	GridStreamerContext.reduce(GridClosure<GridStreamerContext,R1> clo, GridReducer<R1,R2> rdc) Queries all streamer nodes deployed within grid.
<R1,R2> R2	GridStreamerContext.reduce(GridClosure<GridStreamerContext,R1> clo, GridReducer<R1,R2> rdc, Collection<GridNode> nodes) Queries streamer nodes deployed within grid.

Uses of GridStreamerContext in org.gridgain.grid.streamer.router

Methods in org.gridgain.grid.streamer.router with parameters of type GridStreamerContext

Modifier and Type	Method and Description
<T> Map<GridNode,Collection<T>>	GridStreamerLocalEventRouter.route(GridStreamerContext ctx, String stageName, Collection<T> evts) Selects a node for given events that should be processed by a stage with given name.
GridNode	GridStreamerRandomEventRouter.route(GridStreamerContext ctx, String stageName, Object evt) Selects a node for given event that should be processed by a stage with given name.
GridNode	GridStreamerRoundRobinEventRouter.route(GridStreamerContext ctx, String stageName, Object evt) Selects a node for given event that should be processed by a stage with given name.
<T> GridNode	GridStreamerLocalEventRouter.route(GridStreamerContext ctx, String stageName, T evt) Selects a node for given event that should be processed by a stage with given name.
<T> GridNode	GridStreamerAffinityEventRouter.route(GridStreamerContext ctx, String stageName, T evt) Selects a node for given event that should be processed by a stage with given name.
<T> GridNode	GridStreamerCacheAffinityEventRouter.route(GridStreamerContext ctx, String stageName, T evt) Selects a node for given event that should be processed by a stage with given name.