org.gridgain.grid.streamer

Class GridStreamerEventRouterAdapter

java.lang.Object

org.gridgain.grid.streamer.GridStreamerEventRouterAdapter

All Implemented Interfaces:

GridStreamerEventRouter

Direct Known Subclasses:

GridStreamerAffinityEventRouter, GridStreamerCacheAffinityEventRouter, GridStreamerRandomEventRouter, GridStreamerRoundRobinEventRouter

public abstract class GridStreamerEventRouterAdapter
extends Object
implements GridStreamerEventRouter

Streamer adapter for event routers.

Constructor Summary

Constructors

Constructor and Description
GridStreamerEventRouterAdapter()

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.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.gridgain.grid.streamer.GridStreamerEventRouter

route

Constructor Detail

GridStreamerEventRouterAdapter

public GridStreamerEventRouterAdapter()

Method Detail

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.