org.gridgain.grid.streamer.router

Class GridStreamerRandomEventRouter

java.lang.Object

org.gridgain.grid.streamer.GridStreamerEventRouterAdapter

org.gridgain.grid.streamer.router.GridStreamerRandomEventRouter

All Implemented Interfaces:

GridStreamerEventRouter

public class GridStreamerRandomEventRouter
extends GridStreamerEventRouterAdapter

Random router. Routes event to random node.

Constructor Summary

Constructors

Constructor and Description
GridStreamerRandomEventRouter() Empty constructor for spring.
GridStreamerRandomEventRouter(Collection<GridPredicate<GridNode>> predicates) Constructs random event router with optional set of filters to apply to streamer projection.
GridStreamerRandomEventRouter(GridPredicate<GridNode>... predicates) Constructs random event router with optional set of filters to apply to streamer projection.

Method Summary

Methods

Modifier and Type	Method and Description
GridNode	route(GridStreamerContext ctx, String stageName, Object evt) Selects a node for given event that should be processed by a stage with given name.

Methods inherited from class org.gridgain.grid.streamer.GridStreamerEventRouterAdapter

route

Methods inherited from class java.lang.Object

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

Constructor Detail

GridStreamerRandomEventRouter

public GridStreamerRandomEventRouter()

Empty constructor for spring.

GridStreamerRandomEventRouter

public GridStreamerRandomEventRouter(@Nullable
                             GridPredicate<GridNode>... predicates)

Constructs random event router with optional set of filters to apply to streamer projection.

Parameters:

predicates - Node predicates.

GridStreamerRandomEventRouter

public GridStreamerRandomEventRouter(Collection<GridPredicate<GridNode>> predicates)

Constructs random event router with optional set of filters to apply to streamer projection.

Parameters:

predicates - Node predicates.

Method Detail

route

public GridNode route(GridStreamerContext ctx,
             String stageName,
             Object evt)

Selects a node for given event that should be processed by a stage with given name.

Parameters:

ctx - Streamer context.

stageName - Stage name.

evt - Event to route.

Returns:

Node to route to. If this method returns null then the whole pipeline execution will be terminated. All running and ongoing stages for pipeline execution will be cancelled.