org.apache.ignite.streamer

Class StreamerEventRouterAdapter

java.lang.Object

org.apache.ignite.streamer.StreamerEventRouterAdapter

All Implemented Interfaces:

StreamerEventRouter

Direct Known Subclasses:

StreamerAffinityEventRouter, StreamerCacheAffinityEventRouter, StreamerRandomEventRouter, StreamerRoundRobinEventRouter

public abstract class StreamerEventRouterAdapter
extends Object
implements StreamerEventRouter

Streamer adapter for event routers.

Constructor Summary

Constructors

Constructor and Description
StreamerEventRouterAdapter()

Method Summary

Methods

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.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.ignite.streamer.StreamerEventRouter

route

Constructor Detail

StreamerEventRouterAdapter

public StreamerEventRouterAdapter()

Method Detail

route

public <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.

Specified by:

route in interface StreamerEventRouter

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.