public class StreamerRandomEventRouter extends StreamerEventRouterAdapter
Constructor and Description |
---|
StreamerRandomEventRouter()
Empty constructor for spring.
|
StreamerRandomEventRouter(Collection<IgnitePredicate<ClusterNode>> predicates)
Constructs random event router with optional set of filters to apply to streamer projection.
|
StreamerRandomEventRouter(IgnitePredicate<ClusterNode>... predicates)
Constructs random event router with optional set of filters to apply to streamer projection.
|
Modifier and Type | Method and Description |
---|---|
ClusterNode |
route(StreamerContext ctx,
String stageName,
Object evt)
Selects a node for given event that should be processed by a stage with given name.
|
route
public StreamerRandomEventRouter()
public StreamerRandomEventRouter(@Nullable IgnitePredicate<ClusterNode>... predicates)
predicates
- Node predicates.public StreamerRandomEventRouter(Collection<IgnitePredicate<ClusterNode>> predicates)
predicates
- Node predicates.public ClusterNode route(StreamerContext ctx, String stageName, Object 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