public abstract class StreamerEventRouterAdapter extends Object implements StreamerEventRouter
Constructor and Description |
---|
StreamerEventRouterAdapter() |
Modifier and Type | Method and Description |
---|---|
<T> Map<ClusterNode,Collection<T>> |
route(StreamerContext ctx,
String stageName,
Collection<T> evts)
Selects a node for given events that should be processed by a stage with given name.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
route
public <T> Map<ClusterNode,Collection<T>> route(StreamerContext ctx, String stageName, Collection<T> evts)
route
in interface StreamerEventRouter
ctx
- Streamer context.stageName
- Stage name to route events.evts
- Events.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