Package | Description |
---|---|
org.apache.ignite |
Contains entry-point Ignite & HPC APIs.
|
org.apache.ignite.cluster | |
org.apache.ignite.streamer |
Contains main Streaming APIs.
|
Modifier and Type | Interface and Description |
---|---|
interface |
IgniteCluster
Represents whole cluster (all available nodes) and also provides a handle on
IgniteCluster.nodeLocalMap() which
provides map-like functionality linked to current grid node. |
Modifier and Type | Method and Description |
---|---|
ClusterGroup |
IgniteServices.clusterGroup()
Gets grid projection to which this
GridServices instance belongs. |
ClusterGroup |
IgniteEvents.clusterGroup()
Gets grid projection to which this
GridMessaging instance belongs. |
ClusterGroup |
IgniteMessaging.clusterGroup()
Gets grid projection to which this
GridMessaging instance belongs. |
ClusterGroup |
IgniteCompute.clusterGroup()
Gets grid projection to which this
GridCompute instance belongs. |
ClusterGroup |
IgniteCluster.forLocal()
Gets monadic projection consisting from the local node.
|
Modifier and Type | Method and Description |
---|---|
IgniteCompute |
IgniteSpringBean.compute(ClusterGroup grp) |
IgniteCompute |
Ignite.compute(ClusterGroup grp) |
IgniteEvents |
IgniteSpringBean.events(ClusterGroup grp) |
IgniteEvents |
Ignite.events(ClusterGroup grp) |
ExecutorService |
IgniteSpringBean.executorService(ClusterGroup grp) |
ExecutorService |
Ignite.executorService(ClusterGroup grp) |
IgniteMessaging |
IgniteSpringBean.message(ClusterGroup prj) |
IgniteMessaging |
Ignite.message(ClusterGroup grp) |
IgniteServices |
IgniteSpringBean.services(ClusterGroup grp) |
IgniteServices |
Ignite.services(ClusterGroup grp) |
Modifier and Type | Method and Description |
---|---|
ClusterGroup |
ClusterGroup.forAttribute(String name,
String val)
Creates projection for nodes containing given name and value
specified in user attributes.
|
ClusterGroup |
ClusterGroup.forCacheNodes(String cacheName)
Creates projection for all nodes that have cache with specified name running.
|
ClusterGroup |
ClusterGroup.forClientNodes(String cacheName)
Creates projection for all nodes that have cache with specified name running and cache distribution mode is
CacheDistributionMode.CLIENT_ONLY or CacheDistributionMode.NEAR_ONLY . |
ClusterGroup |
ClusterGroup.forDaemons()
Gets projection consisting from the daemon nodes in this projection.
|
ClusterGroup |
ClusterGroup.forDataNodes(String cacheName)
Creates projection for all nodes that have cache with specified name running and cache distribution mode is
CacheDistributionMode.PARTITIONED_ONLY or CacheDistributionMode.NEAR_PARTITIONED . |
ClusterGroup |
ClusterGroup.forHost(ClusterNode node)
Gets grid projection consisting from the nodes in this projection residing on the
same host as given node.
|
ClusterGroup |
ClusterGroup.forNode(ClusterNode node,
ClusterNode... nodes)
Creates a grid projection for the given node.
|
ClusterGroup |
ClusterGroup.forNodeId(UUID id,
UUID... ids)
Creates a grid projection for a node with specified ID.
|
ClusterGroup |
ClusterGroup.forNodeIds(Collection<UUID> ids)
Creates a grid projection over nodes with specified node IDs.
|
ClusterGroup |
ClusterGroup.forNodes(Collection<? extends ClusterNode> nodes)
Creates a grid projection over a given set of nodes.
|
ClusterGroup |
ClusterGroup.forOldest()
Creates grid projection with one oldest node in the current projection.
|
ClusterGroup |
ClusterGroup.forOthers(ClusterGroup prj)
Creates a grid projection for nodes not included into given projection.
|
ClusterGroup |
ClusterGroup.forOthers(ClusterNode node,
ClusterNode... nodes)
Creates a grid projection for nodes other than given nodes.
|
ClusterGroup |
ClusterGroup.forPredicate(IgnitePredicate<ClusterNode> p)
Creates a grid projection which includes all nodes that pass the given predicate filter.
|
ClusterGroup |
ClusterGroup.forRandom()
Creates grid projection with one random node from current projection.
|
ClusterGroup |
ClusterGroup.forRemotes()
Gets grid projection consisting from the nodes in this projection excluding the local node.
|
ClusterGroup |
ClusterGroup.forStreamer(String streamerName,
String... streamerNames)
Creates projection for all nodes that have streamer with specified name running.
|
ClusterGroup |
ClusterGroup.forYoungest()
Creates grid projection with one youngest node in the current projection.
|
Modifier and Type | Method and Description |
---|---|
ClusterGroup |
ClusterGroup.forOthers(ClusterGroup prj)
Creates a grid projection for nodes not included into given projection.
|
Modifier and Type | Method and Description |
---|---|
ClusterGroup |
StreamerContext.projection()
Gets instance of dynamic grid projection including all nodes on which this streamer is running.
|
Follow @ApacheIgnite
Apache Ignite Fabric : ver. 1.0.0-RC3 Release Date : March 24 2015