public interface StreamerStage<IN>
StreamerEventRouter
which will determine
on which node the stage should be executed.
Generally, event stage execution graph if fully controlled by return values of
this method, while node execution graph is controlled by
StreamerEventRouter.route(StreamerContext, String, Object)
method.
Modifier and Type | Method and Description |
---|---|
String |
name()
Gets streamer stage name.
|
Map<String,Collection<?>> |
run(StreamerContext ctx,
Collection<IN> evts)
Stage execution routine.
|
String name()
@Nullable Map<String,Collection<?>> run(StreamerContext ctx, Collection<IN> evts) throws IgniteException
StreamerEventRouter
which will determine on which node the stage should be executed.
Generally, event stage execution graph if fully controlled by return values of
this method, while node execution graph is controlled by
StreamerEventRouter.route(StreamerContext, String, Object)
method.
ctx
- Streamer context.evts
- Input events.IgniteException
- If failed.
Follow @ApacheIgnite
Apache Ignite Fabric : ver. 1.0.0-RC3 Release Date : March 24 2015