public interface StreamerContext
Modifier and Type | Method and Description |
---|---|
void |
broadcast(IgniteInClosure<StreamerContext> clo)
Queries all streamer nodes deployed within grid.
|
void |
broadcast(IgniteInClosure<StreamerContext> clo,
Collection<ClusterNode> nodes)
Queries streamer nodes deployed within grid.
|
<K,V> ConcurrentMap<K,V> |
localSpace()
Gets streamer local space.
|
String |
nextStageName()
For context passed to
StreamerStage.run(StreamerContext, Collection) this method will
return next stage name in execution pipeline. |
ClusterGroup |
projection()
Gets instance of dynamic grid projection including all nodes on which this streamer is running.
|
<R> Collection<R> |
query(IgniteClosure<StreamerContext,R> clo)
Queries all streamer nodes deployed within grid.
|
<R> Collection<R> |
query(IgniteClosure<StreamerContext,R> clo,
Collection<ClusterNode> nodes)
Queries streamer nodes deployed within grid.
|
<R1,R2> R2 |
reduce(IgniteClosure<StreamerContext,R1> clo,
IgniteReducer<R1,R2> rdc)
Queries all streamer nodes deployed within grid.
|
<R1,R2> R2 |
reduce(IgniteClosure<StreamerContext,R1> clo,
IgniteReducer<R1,R2> rdc,
Collection<ClusterNode> nodes)
Queries streamer nodes deployed within grid.
|
<E> StreamerWindow<E> |
window()
Gets default event window, i.e. window that is on the first place in streamer configuration.
|
<E> StreamerWindow<E> |
window(String winName)
Gets streamer event window by window name, if no window with such
name was configured
IllegalArgumentException will be thrown. |
ClusterGroup projection()
<K,V> ConcurrentMap<K,V> localSpace()
<E> StreamerWindow<E> window()
<E> StreamerWindow<E> window(String winName)
IllegalArgumentException
will be thrown.winName
- Window name.String nextStageName()
StreamerStage.run(StreamerContext, Collection)
this method will
return next stage name in execution pipeline. For context obtained from streamer object, this method will
return first stage name.<R> Collection<R> query(IgniteClosure<StreamerContext,R> clo) throws IgniteException
clo
- Function to be executed on individual nodes.IgniteException
- If query execution failed.<R> Collection<R> query(IgniteClosure<StreamerContext,R> clo, Collection<ClusterNode> nodes) throws IgniteException
clo
- Function to be executed on individual nodes.nodes
- Optional list of nodes to execute query on, if empty, then all nodes on
which this streamer is running will be queried.IgniteException
- If query execution failed.void broadcast(IgniteInClosure<StreamerContext> clo) throws IgniteException
clo
- Function to be executed on individual nodes.IgniteException
- If closure execution failed.void broadcast(IgniteInClosure<StreamerContext> clo, Collection<ClusterNode> nodes) throws IgniteException
clo
- Function to be executed on individual nodes.nodes
- Optional list of nodes to execute query on, if empty, then all nodes on
which this streamer is running will be queried.IgniteException
- If closure execution failed.<R1,R2> R2 reduce(IgniteClosure<StreamerContext,R1> clo, IgniteReducer<R1,R2> rdc) throws IgniteException
clo
- Function to be executed on individual nodes.rdc
- Reducer to reduce results received from remote nodes.IgniteException
- If query execution failed.<R1,R2> R2 reduce(IgniteClosure<StreamerContext,R1> clo, IgniteReducer<R1,R2> rdc, Collection<ClusterNode> nodes) throws IgniteException
clo
- Function to be executed on individual nodes.rdc
- Reducer to reduce results received from remote nodes.nodes
- Optional list of nodes to execute query on, if empty, then all nodes on
which this streamer is running will be queried.IgniteException
- If query execution failed.
Follow @ApacheIgnite
Apache Ignite Fabric : ver. 1.0.0-RC3 Release Date : March 24 2015