Package | Description |
---|---|
org.apache.ignite |
Contains entry-point Ignite & HPC APIs.
|
org.apache.ignite.streamer |
Contains main Streaming APIs.
|
org.apache.ignite.streamer.router |
Contains streamer event router implementations.
|
Modifier and Type | Method and Description |
---|---|
StreamerContext |
IgniteStreamer.context()
Gets streamer context.
|
Modifier and Type | Method and Description |
---|---|
<T> Map<ClusterNode,Collection<T>> |
StreamerEventRouter.route(StreamerContext ctx,
String stageName,
Collection<T> evts)
Selects a node for given events that should be processed by a stage with given name.
|
<T> Map<ClusterNode,Collection<T>> |
StreamerEventRouterAdapter.route(StreamerContext ctx,
String stageName,
Collection<T> evts)
Selects a node for given events that should be processed by a stage with given name.
|
<T> ClusterNode |
StreamerEventRouter.route(StreamerContext ctx,
String stageName,
T evt)
Selects a node for given event that should be processed by a stage with given name.
|
Map<String,Collection<?>> |
StreamerStage.run(StreamerContext ctx,
Collection<IN> evts)
Stage execution routine.
|
Modifier and Type | Method and Description |
---|---|
void |
StreamerContext.broadcast(IgniteInClosure<StreamerContext> clo)
Queries all streamer nodes deployed within grid.
|
void |
StreamerContext.broadcast(IgniteInClosure<StreamerContext> clo,
Collection<ClusterNode> nodes)
Queries streamer nodes deployed within grid.
|
<R> Collection<R> |
StreamerContext.query(IgniteClosure<StreamerContext,R> clo)
Queries all streamer nodes deployed within grid.
|
<R> Collection<R> |
StreamerContext.query(IgniteClosure<StreamerContext,R> clo,
Collection<ClusterNode> nodes)
Queries streamer nodes deployed within grid.
|
<R1,R2> R2 |
StreamerContext.reduce(IgniteClosure<StreamerContext,R1> clo,
IgniteReducer<R1,R2> rdc)
Queries all streamer nodes deployed within grid.
|
<R1,R2> R2 |
StreamerContext.reduce(IgniteClosure<StreamerContext,R1> clo,
IgniteReducer<R1,R2> rdc,
Collection<ClusterNode> nodes)
Queries streamer nodes deployed within grid.
|
Modifier and Type | Method and Description |
---|---|
<T> Map<ClusterNode,Collection<T>> |
StreamerLocalEventRouter.route(StreamerContext ctx,
String stageName,
Collection<T> evts)
Selects a node for given events that should be processed by a stage with given name.
|
ClusterNode |
StreamerRandomEventRouter.route(StreamerContext ctx,
String stageName,
Object evt)
Selects a node for given event that should be processed by a stage with given name.
|
ClusterNode |
StreamerRoundRobinEventRouter.route(StreamerContext ctx,
String stageName,
Object evt)
Selects a node for given event that should be processed by a stage with given name.
|
<T> ClusterNode |
StreamerCacheAffinityEventRouter.route(StreamerContext ctx,
String stageName,
T evt)
Selects a node for given event that should be processed by a stage with given name.
|
<T> ClusterNode |
StreamerLocalEventRouter.route(StreamerContext ctx,
String stageName,
T evt)
Selects a node for given event that should be processed by a stage with given name.
|
<T> ClusterNode |
StreamerAffinityEventRouter.route(StreamerContext ctx,
String stageName,
T evt)
Selects a node for given event that should be processed by a stage with given name.
|
Follow @ApacheIgnite
Apache Ignite Fabric : ver. 1.0.0-RC3 Release Date : March 24 2015