public class StreamerAffinityEventRouter extends StreamerEventRouterAdapter
StreamerAffinityEventRouter.AffinityEvent.affinityKey()
method. If event does not implement
StreamerAffinityEventRouter.AffinityEvent
interface, then event itself will be used to determine affinity.Modifier and Type | Class and Description |
---|---|
static interface |
StreamerAffinityEventRouter.AffinityEvent
All events that implement this interface will be routed based on key affinity.
|
Modifier and Type | Field and Description |
---|---|
static int |
REPLICA_CNT |
Constructor and Description |
---|
StreamerAffinityEventRouter() |
Modifier and Type | Method and Description |
---|---|
<T> ClusterNode |
route(StreamerContext ctx,
String stageName,
T evt)
Selects a node for given event that should be processed by a stage with given name.
|
route
public static final int REPLICA_CNT
public <T> ClusterNode route(StreamerContext ctx, String stageName, T evt)
ctx
- Streamer context.stageName
- Stage name.evt
- Event to route.null
then the whole pipeline execution
will be terminated. All running and ongoing stages for pipeline execution will be
cancelled.
Follow @ApacheIgnite
Apache Ignite Fabric : ver. 1.0.0-RC1 Release Date : February 16 2015