Uses of Interface
org.apache.ignite.cluster.ClusterGroup

Packages that use ClusterGroup

Package	Description
org.apache.ignite	Contains entry-point Ignite & HPC APIs.
org.apache.ignite.cluster
org.apache.ignite.internal	Contains main implementation.
org.apache.ignite.internal.cluster
org.apache.ignite.internal.processors.cache
org.apache.ignite.internal.processors.cache.query
org.apache.ignite.internal.processors.cache.query.continuous
org.apache.ignite.internal.processors.service
org.apache.ignite.internal.processors.streamer	TODO.
org.apache.ignite.internal.util.lang
org.apache.ignite.streamer	Contains main Streaming APIs.

Uses of ClusterGroup in org.apache.ignite

Subinterfaces of ClusterGroup in org.apache.ignite

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.

Methods in org.apache.ignite that return ClusterGroup

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.

Methods in org.apache.ignite with parameters of type ClusterGroup

Modifier and Type	Method and Description
IgniteCompute	Ignite.compute(ClusterGroup grp)
IgniteEvents	Ignite.events(ClusterGroup grp)
ExecutorService	Ignite.executorService(ClusterGroup grp)
IgniteMessaging	Ignite.message(ClusterGroup grp)
IgniteServices	Ignite.services(ClusterGroup grp)

Uses of ClusterGroup in org.apache.ignite.cluster

Methods in org.apache.ignite.cluster that return ClusterGroup

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.

Methods in org.apache.ignite.cluster with parameters of type ClusterGroup

Modifier and Type	Method and Description
ClusterGroup	ClusterGroup.forOthers(ClusterGroup prj) Creates a grid projection for nodes not included into given projection.

Uses of ClusterGroup in org.apache.ignite.internal

Methods in org.apache.ignite.internal that return ClusterGroup

Modifier and Type	Method and Description
ClusterGroup	IgniteMessagingImpl.clusterGroup() Gets grid projection to which this GridMessaging instance belongs.
ClusterGroup	IgniteServicesImpl.clusterGroup() Gets grid projection to which this GridServices instance belongs.
ClusterGroup	IgniteEventsImpl.clusterGroup() Gets grid projection to which this GridMessaging instance belongs.
ClusterGroup	IgniteComputeImpl.clusterGroup() Gets grid projection to which this GridCompute instance belongs.

Methods in org.apache.ignite.internal with parameters of type ClusterGroup

Modifier and Type	Method and Description
IgniteCompute	IgniteKernal.compute(ClusterGroup grp)
IgniteEvents	IgniteKernal.events(ClusterGroup grp)
ExecutorService	IgniteKernal.executorService(ClusterGroup grp)
IgniteMessaging	IgniteKernal.message(ClusterGroup prj)
IgniteServices	IgniteKernal.services(ClusterGroup grp)

Constructors in org.apache.ignite.internal with parameters of type ClusterGroup

Constructor and Description
ClusterMetricsSnapshot(ClusterGroup p) Create metrics for given cluster group.

Uses of ClusterGroup in org.apache.ignite.internal.cluster

Subinterfaces of ClusterGroup in org.apache.ignite.internal.cluster

Modifier and Type	Interface and Description
interface	ClusterGroupEx Internal projection interface.
interface	IgniteClusterEx

Classes in org.apache.ignite.internal.cluster that implement ClusterGroup

Modifier and Type	Class and Description
class	ClusterGroupAdapter
class	IgniteClusterAsyncImpl
class	IgniteClusterImpl

Methods in org.apache.ignite.internal.cluster that return ClusterGroup

Modifier and Type	Method and Description
ClusterGroup	IgniteClusterAsyncImpl.forAttribute(String name, String val) Creates projection for nodes containing given name and value specified in user attributes.
ClusterGroup	ClusterGroupAdapter.forAttribute(String name, String val) Creates projection for nodes containing given name and value specified in user attributes.
ClusterGroup	IgniteClusterAsyncImpl.forCacheNodes(String cacheName) Creates projection for all nodes that have cache with specified name running.
ClusterGroup	ClusterGroupAdapter.forCacheNodes(String cacheName) Creates projection for all nodes that have cache with specified name running.
ClusterGroup	ClusterGroupEx.forCacheNodes(String cacheName, Set<CacheDistributionMode> distributionModes)
ClusterGroup	ClusterGroupAdapter.forCacheNodes(String cacheName, Set<CacheDistributionMode> distributionModes)
ClusterGroup	IgniteClusterAsyncImpl.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	ClusterGroupAdapter.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	IgniteClusterAsyncImpl.forDaemons() Gets projection consisting from the daemon nodes in this projection.
ClusterGroup	ClusterGroupAdapter.forDaemons() Gets projection consisting from the daemon nodes in this projection.
ClusterGroup	IgniteClusterAsyncImpl.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	ClusterGroupAdapter.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	IgniteClusterAsyncImpl.forHost(ClusterNode node) Gets grid projection consisting from the nodes in this projection residing on the same host as given node.
ClusterGroup	ClusterGroupAdapter.forHost(ClusterNode node) Gets grid projection consisting from the nodes in this projection residing on the same host as given node.
ClusterGroup	IgniteClusterImpl.forLocal() Gets monadic projection consisting from the local node.
ClusterGroup	IgniteClusterAsyncImpl.forLocal() Gets monadic projection consisting from the local node.
ClusterGroup	IgniteClusterAsyncImpl.forNode(ClusterNode node, ClusterNode... nodes) Creates a grid projection for the given node.
ClusterGroup	ClusterGroupAdapter.forNode(ClusterNode node, ClusterNode... nodes) Creates a grid projection for the given node.
ClusterGroup	IgniteClusterAsyncImpl.forNodeId(UUID id, UUID... ids) Creates a grid projection for a node with specified ID.
ClusterGroup	ClusterGroupAdapter.forNodeId(UUID id, UUID... ids) Creates a grid projection for a node with specified ID.
ClusterGroup	IgniteClusterAsyncImpl.forNodeIds(Collection<UUID> ids) Creates a grid projection over nodes with specified node IDs.
ClusterGroup	ClusterGroupAdapter.forNodeIds(Collection<UUID> ids) Creates a grid projection over nodes with specified node IDs.
ClusterGroup	IgniteClusterAsyncImpl.forNodes(Collection<? extends ClusterNode> nodes) Creates a grid projection over a given set of nodes.
ClusterGroup	ClusterGroupAdapter.forNodes(Collection<? extends ClusterNode> nodes) Creates a grid projection over a given set of nodes.
ClusterGroup	IgniteClusterAsyncImpl.forOldest() Creates grid projection with one oldest node in the current projection.
ClusterGroup	ClusterGroupAdapter.forOldest() Creates grid projection with one oldest node in the current projection.
ClusterGroup	IgniteClusterAsyncImpl.forOthers(ClusterGroup prj) Creates a grid projection for nodes not included into given projection.
ClusterGroup	ClusterGroupAdapter.forOthers(ClusterGroup grp) Creates a grid projection for nodes not included into given projection.
ClusterGroup	IgniteClusterAsyncImpl.forOthers(ClusterNode node, ClusterNode... nodes) Creates a grid projection for nodes other than given nodes.
ClusterGroup	ClusterGroupAdapter.forOthers(ClusterNode node, ClusterNode... nodes) Creates a grid projection for nodes other than given nodes.
ClusterGroup	IgniteClusterAsyncImpl.forPredicate(IgnitePredicate<ClusterNode> p) Creates a grid projection which includes all nodes that pass the given predicate filter.
ClusterGroup	ClusterGroupAdapter.forPredicate(IgnitePredicate<ClusterNode> p) Creates a grid projection which includes all nodes that pass the given predicate filter.
ClusterGroup	IgniteClusterAsyncImpl.forRandom() Creates grid projection with one random node from current projection.
ClusterGroup	ClusterGroupAdapter.forRandom() Creates grid projection with one random node from current projection.
ClusterGroup	IgniteClusterAsyncImpl.forRemotes() Gets grid projection consisting from the nodes in this projection excluding the local node.
ClusterGroup	ClusterGroupAdapter.forRemotes() Gets grid projection consisting from the nodes in this projection excluding the local node.
ClusterGroup	IgniteClusterAsyncImpl.forStreamer(String streamerName, String... streamerNames) Creates projection for all nodes that have streamer with specified name running.
ClusterGroup	ClusterGroupAdapter.forStreamer(String streamerName, String... streamerNames) Creates projection for all nodes that have streamer with specified name running.
ClusterGroup	IgniteClusterAsyncImpl.forYoungest() Creates grid projection with one youngest node in the current projection.
ClusterGroup	ClusterGroupAdapter.forYoungest() Creates grid projection with one youngest node in the current projection.

Methods in org.apache.ignite.internal.cluster with parameters of type ClusterGroup

Modifier and Type	Method and Description
ClusterGroup	IgniteClusterAsyncImpl.forOthers(ClusterGroup prj) Creates a grid projection for nodes not included into given projection.
ClusterGroup	ClusterGroupAdapter.forOthers(ClusterGroup grp) Creates a grid projection for nodes not included into given projection.

Uses of ClusterGroup in org.apache.ignite.internal.processors.cache

Methods in org.apache.ignite.internal.processors.cache that return ClusterGroup

Modifier and Type	Method and Description
ClusterGroup	CacheProjection.gridProjection() Gets grid projection for this cache.
ClusterGroup	GridCacheProjectionImpl.gridProjection() Gets grid projection for this cache.
ClusterGroup	GridCacheProxyImpl.gridProjection() Gets grid projection for this cache.
ClusterGroup	GridCacheAdapter.gridProjection() Gets grid projection for this cache.

Uses of ClusterGroup in org.apache.ignite.internal.processors.cache.query

Methods in org.apache.ignite.internal.processors.cache.query that return ClusterGroup

Modifier and Type	Method and Description
ClusterGroup	GridCacheQueryAdapter.projection()

Methods in org.apache.ignite.internal.processors.cache.query with parameters of type ClusterGroup

Modifier and Type	Method and Description
CacheQuery<T>	CacheQuery.projection(ClusterGroup prj) Sets optional grid projection to execute this query on.
CacheQuery<T>	GridCacheQueryAdapter.projection(ClusterGroup prj) Sets optional grid projection to execute this query on.

Constructors in org.apache.ignite.internal.processors.cache.query with parameters of type ClusterGroup

Constructor and Description
GridCacheQueryAdapter(GridCacheContext<?,?> cctx, GridCacheQueryType type, IgniteLogger log, int pageSize, long timeout, boolean keepAll, boolean incBackups, boolean dedup, ClusterGroup prj, IgniteBiPredicate<Object,Object> filter, String clsName, String clause, boolean incMeta, boolean keepPortable, UUID subjId, int taskHash)

Uses of ClusterGroup in org.apache.ignite.internal.processors.cache.query.continuous

Methods in org.apache.ignite.internal.processors.cache.query.continuous with parameters of type ClusterGroup

Modifier and Type	Method and Description
UUID	CacheContinuousQueryManager.executeQuery(javax.cache.event.CacheEntryUpdatedListener locLsnr, javax.cache.event.CacheEntryEventFilter rmtFilter, int bufSize, long timeInterval, boolean autoUnsubscribe, ClusterGroup grp)

Uses of ClusterGroup in org.apache.ignite.internal.processors.service

Methods in org.apache.ignite.internal.processors.service with parameters of type ClusterGroup

Modifier and Type	Method and Description
IgniteInternalFuture<?>	GridServiceProcessor.deployClusterSingleton(ClusterGroup prj, String name, Service svc)
IgniteInternalFuture<?>	GridServiceProcessor.deployMultiple(ClusterGroup prj, String name, Service svc, int totalCnt, int maxPerNodeCnt)
IgniteInternalFuture<?>	GridServiceProcessor.deployNodeSingleton(ClusterGroup prj, String name, Service svc)
<T> T	GridServiceProcessor.serviceProxy(ClusterGroup prj, String name, Class<? super T> svcItf, boolean sticky)

Uses of ClusterGroup in org.apache.ignite.internal.processors.streamer

Methods in org.apache.ignite.internal.processors.streamer that return ClusterGroup

Modifier and Type	Method and Description
ClusterGroup	GridStreamerContextImpl.projection() Gets instance of dynamic grid projection including all nodes on which this streamer is running.
ClusterGroup	GridStreamerContextDelegate.projection() Gets instance of dynamic grid projection including all nodes on which this streamer is running.

Uses of ClusterGroup in org.apache.ignite.internal.util.lang

Methods in org.apache.ignite.internal.util.lang that return types with arguments of type ClusterGroup

Modifier and Type	Method and Description
static IgniteClosure<ClusterGroup,IgnitePredicate<ClusterNode>>	GridFunc.predicate() Gets closure that transform a grid projection into its predicate.

Uses of ClusterGroup in org.apache.ignite.streamer

Methods in org.apache.ignite.streamer that return ClusterGroup

Modifier and Type	Method and Description
ClusterGroup	StreamerContext.projection() Gets instance of dynamic grid projection including all nodes on which this streamer is running.