## Uses of Interface
org.apache.ignite.streamer.StreamerContext

Packages that use StreamerContext
Package | Description
--- | ---
org.apache.ignite | Contains entry-point Ignite & HPC APIs.
org.apache.ignite.internal.processors.streamer | TODO.
org.apache.ignite.internal.processors.streamer.task |
org.apache.ignite.streamer | Contains main Streaming APIs.
org.apache.ignite.streamer.router | Contains streamer event router implementations.

### Uses of StreamerContext in org.apache.ignite

Methods in org.apache.ignite that return StreamerContext
Modifier and Type | Method and Description
--- | ---
`StreamerContext` | IgniteStreamer.`context()` Gets streamer context.

### Uses of StreamerContext in org.apache.ignite.internal.processors.streamer

Classes in org.apache.ignite.internal.processors.streamer that implement StreamerContext
Modifier and Type | Class and Description
--- | ---
`class` | `GridStreamerContextDelegate` Context delegate allowing to override next stage name.
`class` | `GridStreamerContextImpl` Streamer context implementation.

Methods in org.apache.ignite.internal.processors.streamer that return StreamerContext
Modifier and Type | Method and Description
--- | ---
`StreamerContext` | IgniteStreamerImpl.`context()` Gets streamer context.

Methods in org.apache.ignite.internal.processors.streamer with parameters of type StreamerContext
Modifier and Type | Method and Description
--- | ---
`Map<String,Collection<?>>` | StreamerStageWrapper.`run(StreamerContext ctx, Collection<Object> evts)` Stage execution routine.

Method parameters in org.apache.ignite.internal.processors.streamer with type arguments of type StreamerContext
Modifier and Type | Method and Description
--- | ---
`void` | GridStreamerContextImpl.`broadcast(IgniteInClosure<StreamerContext> clo)` Queries all streamer nodes deployed within grid.
`void` | GridStreamerContextDelegate.`broadcast(IgniteInClosure<StreamerContext> clo)` Queries all streamer nodes deployed within grid.
`void` | GridStreamerContextImpl.`broadcast(IgniteInClosure<StreamerContext> clo, Collection<ClusterNode> nodes)` Queries streamer nodes deployed within grid.
`void` | GridStreamerContextDelegate.`broadcast(IgniteInClosure<StreamerContext> clo, Collection<ClusterNode> nodes)` Queries streamer nodes deployed within grid.
`<R> Collection<R>` | GridStreamerContextImpl.`query(IgniteClosure<StreamerContext,R> clo)` Queries all streamer nodes deployed within grid.
`<R> Collection<R>` | GridStreamerContextDelegate.`query(IgniteClosure<StreamerContext,R> clo)` Queries all streamer nodes deployed within grid.
`<R> Collection<R>` | GridStreamerContextImpl.`query(IgniteClosure<StreamerContext,R> clo, Collection<ClusterNode> nodes)` Queries streamer nodes deployed within grid.
`<R> Collection<R>` | GridStreamerContextDelegate.`query(IgniteClosure<StreamerContext,R> clo, Collection<ClusterNode> nodes)` Queries streamer nodes deployed within grid.
`<R1,R2> R2` | GridStreamerContextImpl.`reduce(IgniteClosure<StreamerContext,R1> clo, IgniteReducer<R1,R2> rdc)` Queries all streamer nodes deployed within grid.
`<R1,R2> R2` | GridStreamerContextDelegate.`reduce(IgniteClosure<StreamerContext,R1> clo, IgniteReducer<R1,R2> rdc)` Queries all streamer nodes deployed within grid.
`<R1,R2> R2` | GridStreamerContextImpl.`reduce(IgniteClosure<StreamerContext,R1> clo, IgniteReducer<R1,R2> rdc, Collection<ClusterNode> nodes)` Queries streamer nodes deployed within grid.
`<R1,R2> R2` | GridStreamerContextDelegate.`reduce(IgniteClosure<StreamerContext,R1> clo, IgniteReducer<R1,R2> rdc, Collection<ClusterNode> nodes)` Queries streamer nodes deployed within grid.

Constructors in org.apache.ignite.internal.processors.streamer with parameters of type StreamerContext
Constructor and Description
`GridStreamerContextDelegate(StreamerContext delegate, String nextStageName)`

### Uses of StreamerContext in org.apache.ignite.internal.processors.streamer.task

Constructor parameters in org.apache.ignite.internal.processors.streamer.task with type arguments of type StreamerContext
Constructor and Description
`GridStreamerBroadcastTask(IgniteInClosure<StreamerContext> clo, String streamer)`
`GridStreamerQueryTask(IgniteClosure<StreamerContext,R> qryClos, String streamer)`
`GridStreamerReduceTask(IgniteClosure<StreamerContext,R1> clos, IgniteReducer<R1,R2> rdc, String streamer)`

### Uses of StreamerContext in org.apache.ignite.streamer

Methods in org.apache.ignite.streamer with parameters of type StreamerContext
Modifier and Type | Method and Description
--- | ---
`<T> Map<ClusterNode,Collection<T>>` | StreamerEventRouter.`route(StreamerContext ctx, String stageName, Collection<T> evts)` Selects a node for given events that should be processed by a stage with given name.
`<T> Map<ClusterNode,Collection<T>>` | StreamerEventRouterAdapter.`route(StreamerContext ctx, String stageName, Collection<T> evts)` Selects a node for given events that should be processed by a stage with given name.
`<T> ClusterNode` | StreamerEventRouter.`route(StreamerContext ctx, String stageName, T evt)` Selects a node for given event that should be processed by a stage with given name.
`Map<String,Collection<?>>` | StreamerStage.`run(StreamerContext ctx, Collection<IN> evts)` Stage execution routine.

Method parameters in org.apache.ignite.streamer with type arguments of type StreamerContext
Modifier and Type | Method and Description
--- | ---
`void` | StreamerContext.`broadcast(IgniteInClosure<StreamerContext> clo)` Queries all streamer nodes deployed within grid.
`void` | StreamerContext.`broadcast(IgniteInClosure<StreamerContext> clo, Collection<ClusterNode> nodes)` Queries streamer nodes deployed within grid.
`<R> Collection<R>` | StreamerContext.`query(IgniteClosure<StreamerContext,R> clo)` Queries all streamer nodes deployed within grid.
`<R> Collection<R>` | StreamerContext.`query(IgniteClosure<StreamerContext,R> clo, Collection<ClusterNode> nodes)` Queries streamer nodes deployed within grid.
`<R1,R2> R2` | StreamerContext.`reduce(IgniteClosure<StreamerContext,R1> clo, IgniteReducer<R1,R2> rdc)` Queries all streamer nodes deployed within grid.
`<R1,R2> R2` | StreamerContext.`reduce(IgniteClosure<StreamerContext,R1> clo, IgniteReducer<R1,R2> rdc, Collection<ClusterNode> nodes)` Queries streamer nodes deployed within grid.

### Uses of StreamerContext in org.apache.ignite.streamer.router

Methods in org.apache.ignite.streamer.router with parameters of type StreamerContext
Modifier and Type | Method and Description
--- | ---
`<T> Map<ClusterNode,Collection<T>>` | StreamerLocalEventRouter.`route(StreamerContext ctx, String stageName, Collection<T> evts)` Selects a node for given events that should be processed by a stage with given name.
`ClusterNode` | StreamerRandomEventRouter.`route(StreamerContext ctx, String stageName, Object evt)` Selects a node for given event that should be processed by a stage with given name.
`ClusterNode` | StreamerRoundRobinEventRouter.`route(StreamerContext ctx, String stageName, Object evt)` Selects a node for given event that should be processed by a stage with given name.
`<T> ClusterNode` | StreamerCacheAffinityEventRouter.`route(StreamerContext ctx, String stageName, T evt)` Selects a node for given event that should be processed by a stage with given name.
`<T> ClusterNode` | StreamerLocalEventRouter.`route(StreamerContext ctx, String stageName, T evt)` Selects a node for given event that should be processed by a stage with given name.
`<T> ClusterNode` | StreamerAffinityEventRouter.`route(StreamerContext ctx, String stageName, T evt)` Selects a node for given event that should be processed by a stage with given name.

2015 Copyright © Apache Software Foundation

Follow @ApacheIgnite

Ignite Fabric | : ver. 1.0.0-RC3
Release Date | : March 24 2015