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.