org.gridgain.grid.streamer.router

Class GridStreamerCacheAffinityEventRouter

java.lang.Object

org.gridgain.grid.streamer.GridStreamerEventRouterAdapter

org.gridgain.grid.streamer.router.GridStreamerCacheAffinityEventRouter

All Implemented Interfaces:

GridStreamerEventRouter

public class GridStreamerCacheAffinityEventRouter
extends GridStreamerEventRouterAdapter

Router used to colocate streamer events with data stored in a partitioned cache.

Affinity Key

Affinity key for collocation of event together on the same node is specified via GridStreamerCacheAffinityEventRouter.CacheAffinityEvent.affinityKey() method. If event does not implement GridStreamerCacheAffinityEventRouter.CacheAffinityEvent interface, then event will be routed always to local node.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	GridStreamerCacheAffinityEventRouter.CacheAffinityEvent All events that implement this interface will be routed based on key affinity.

Constructor Summary

Constructors

Constructor and Description
GridStreamerCacheAffinityEventRouter()

Method Summary

Methods

Modifier and Type	Method and Description
<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 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

GridStreamerCacheAffinityEventRouter

public GridStreamerCacheAffinityEventRouter()

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.

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.