org.gridgain.grid.streamer.router

Class GridStreamerLocalEventRouter

java.lang.Object

org.gridgain.grid.streamer.router.GridStreamerLocalEventRouter

All Implemented Interfaces:

GridStreamerEventRouter

public class GridStreamerLocalEventRouter
extends Object
implements GridStreamerEventRouter

Local router. Always routes event to local node.

Constructor Summary

Constructors

Constructor and Description
GridStreamerLocalEventRouter()

Method Summary

Methods

Modifier and Type	Method and Description
<T> Map<GridNode,Collection<T>>	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	route(GridStreamerContext ctx, String stageName, T evt) Selects a node for given event that should be processed by a stage with given name.

Methods inherited from class java.lang.Object

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

Constructor Detail

GridStreamerLocalEventRouter

public GridStreamerLocalEventRouter()

Method Detail

route

public <T> GridNode route(GridStreamerContext ctx,
                 String stageName,
                 T evt)

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

Specified by:

route in interface GridStreamerEventRouter

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.

route

public <T> Map<GridNode,Collection<T>> route(GridStreamerContext ctx,
                                    String stageName,
                                    Collection<T> evts)

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

Specified by:

route in interface GridStreamerEventRouter

Parameters:

ctx - Streamer context.

stageName - Stage name to route events.

evts - Events.

Returns:

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