| Package | Description |
|---|---|
| org.apache.ignite |
Contains entry-point Ignite & HPC APIs.
|
| org.apache.ignite.cluster |
Contains cluster-related classes.
|
| org.apache.ignite.internal |
Contains main implementation.
|
| org.apache.ignite.internal.cluster | |
| org.apache.ignite.internal.processors.cache |
This package contain cache-related processors & persistence implementation.
|
| org.apache.ignite.internal.processors.cache.query | |
| org.apache.ignite.internal.processors.platform.client.cluster | |
| org.apache.ignite.internal.processors.platform.compute | |
| org.apache.ignite.internal.processors.service |
| 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 the cluster group to which this
IgniteServices instance belongs. |
ClusterGroup |
IgniteEvents.clusterGroup()
Gets cluster group to which this
IgniteEvents instance belongs. |
ClusterGroup |
IgniteCompute.clusterGroup()
Gets cluster group to which this
IgniteCompute instance belongs. |
ClusterGroup |
IgniteMessaging.clusterGroup()
Gets the cluster group to which this
GridMessaging instance belongs. |
ClusterGroup |
IgniteCluster.forLocal()
Gets a cluster group consisting from the local node.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteCompute |
Ignite.compute(ClusterGroup grp)
Gets
compute facade over the specified cluster group. |
IgniteEvents |
Ignite.events(ClusterGroup grp)
Gets
events facade over nodes within the cluster group. |
ExecutorService |
Ignite.executorService(ClusterGroup grp)
Creates a new
ExecutorService which will execute all submitted
Callable and Runnable jobs on nodes in the specified cluster group. |
IgniteMessaging |
Ignite.message(ClusterGroup grp)
Gets
messaging facade over nodes within the cluster group. |
CacheMetrics |
IgniteCache.metrics(ClusterGroup grp)
Gets cluster group snapshot metrics for caches in cluster group.
|
IgniteServices |
Ignite.services(ClusterGroup grp)
Gets
services facade over nodes within the cluster group. |
| Modifier and Type | Method and Description |
|---|---|
ClusterGroup |
ClusterGroup.forAttribute(String name,
@Nullable Object val)
Creates a new cluster group for nodes containing given name and value
specified in user attributes.
|
ClusterGroup |
ClusterGroup.forCacheNodes(String cacheName)
Creates a cluster group for all nodes that have cache with specified name, either in client or server modes.
|
ClusterGroup |
ClusterGroup.forClientNodes(String cacheName)
Creates a cluster group for all client nodes that access cache with the specified name.
|
ClusterGroup |
ClusterGroup.forClients()
Creates a cluster group of nodes started in client mode.
|
ClusterGroup |
ClusterGroup.forDaemons()
Gets a cluster group consisting from the daemon nodes.
|
ClusterGroup |
ClusterGroup.forDataNodes(String cacheName)
Creates a cluster group for all data nodes that have the cache with the specified name running.
|
ClusterGroup |
ClusterGroup.forHost(ClusterNode node)
Gets cluster group consisting from the nodes in this cluster group residing on the
same host as the given node.
|
ClusterGroup |
ClusterGroup.forHost(String host,
String... hosts)
Gets cluster group consisting from the nodes running on the hosts specified.
|
ClusterGroup |
ClusterGroup.forNode(ClusterNode node,
ClusterNode... nodes)
Creates a cluster group for the given node.
|
ClusterGroup |
ClusterGroup.forNodeId(UUID id,
UUID... ids)
Creates a cluster group for a node with the specified ID.
|
ClusterGroup |
ClusterGroup.forNodeIds(Collection<UUID> ids)
Creates a cluster group over nodes with specified node IDs.
|
ClusterGroup |
ClusterGroup.forNodes(Collection<? extends ClusterNode> nodes)
Creates a cluster group over a given set of nodes.
|
ClusterGroup |
ClusterGroup.forOldest()
Creates a cluster group with one oldest node from the current cluster group.
|
ClusterGroup |
ClusterGroup.forOthers(ClusterGroup prj)
Creates a cluster group for nodes not included into the given cluster group.
|
ClusterGroup |
ClusterGroup.forOthers(ClusterNode node,
ClusterNode... nodes)
Creates a cluster group for nodes other than the given nodes.
|
ClusterGroup |
ClusterGroup.forPredicate(IgnitePredicate<ClusterNode> p)
Creates a new cluster group which includes all nodes that pass the given predicate filter.
|
ClusterGroup |
ClusterGroup.forRandom()
Creates a cluster group with one random node from the current cluster group.
|
ClusterGroup |
ClusterGroup.forRemotes()
Gets cluster group consisting from the nodes in this cluster group excluding the local node.
|
ClusterGroup |
ClusterGroup.forServers()
Creates a cluster group of nodes started in server mode.
|
ClusterGroup |
ClusterGroup.forYoungest()
Creates a cluster group with one youngest node in the current cluster group.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterGroup |
ClusterGroup.forOthers(ClusterGroup prj)
Creates a cluster group for nodes not included into the given cluster group.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterGroup |
IgniteServicesImpl.clusterGroup()
Gets the cluster group to which this
IgniteServices instance belongs. |
ClusterGroup |
IgniteComputeImpl.clusterGroup()
Gets cluster group to which this
IgniteCompute instance belongs. |
ClusterGroup |
IgniteMessagingImpl.clusterGroup()
Gets the cluster group to which this
GridMessaging instance belongs. |
ClusterGroup |
IgniteEventsImpl.clusterGroup()
Gets cluster group to which this
IgniteEvents instance belongs. |
| Modifier and Type | Method and Description |
|---|---|
IgniteCompute |
IgniteKernal.compute(ClusterGroup grp)
Gets
compute facade over the specified cluster group. |
IgniteEvents |
IgniteKernal.events(ClusterGroup grp)
Gets
events facade over nodes within the cluster group. |
ExecutorService |
IgniteKernal.executorService(ClusterGroup grp)
Creates a new
ExecutorService which will execute all submitted
Callable and Runnable jobs on nodes in the specified cluster group. |
IgniteMessaging |
IgniteKernal.message(ClusterGroup prj)
Gets
messaging facade over nodes within the cluster group. |
IgniteServices |
IgniteKernal.services(ClusterGroup grp)
Gets
services facade over nodes within the cluster group. |
| Constructor and Description |
|---|
ClusterMetricsMXBeanImpl(ClusterGroup cluster,
GridKernalContext ctx) |
ClusterMetricsSnapshot(ClusterGroup p)
Create metrics for given cluster group.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
ClusterGroupEx
Internal projection interface.
|
interface |
IgniteClusterEx |
| Modifier and Type | Class and Description |
|---|---|
class |
ClusterGroupAdapter |
class |
IgniteClusterAsyncImpl |
class |
IgniteClusterImpl |
| Modifier and Type | Method and Description |
|---|---|
ClusterGroup |
IgniteClusterAsyncImpl.forAttribute(String name,
@Nullable Object val)
Creates a new cluster group for nodes containing given name and value
specified in user attributes.
|
ClusterGroup |
ClusterGroupAdapter.forAttribute(String name,
@Nullable Object val)
Creates a new cluster group for nodes containing given name and value
specified in user attributes.
|
ClusterGroup |
IgniteClusterAsyncImpl.forCacheNodes(String cacheName)
Creates a cluster group for all nodes that have cache with specified name, either in client or server modes.
|
ClusterGroup |
ClusterGroupAdapter.forCacheNodes(String cacheName)
Creates a cluster group for all nodes that have cache with specified name, either in client or server modes.
|
ClusterGroup |
ClusterGroupAdapter.forCacheNodes(String cacheName,
boolean affNodes,
boolean nearNodes,
boolean clientNodes) |
ClusterGroup |
ClusterGroupEx.forCacheNodes(String cacheName,
boolean affNodes,
boolean nearNodes,
boolean clientNodes) |
ClusterGroup |
IgniteClusterAsyncImpl.forClientNodes(String cacheName)
Creates a cluster group for all client nodes that access cache with the specified name.
|
ClusterGroup |
ClusterGroupAdapter.forClientNodes(String cacheName)
Creates a cluster group for all client nodes that access cache with the specified name.
|
ClusterGroup |
IgniteClusterAsyncImpl.forClients()
Creates a cluster group of nodes started in client mode.
|
ClusterGroup |
ClusterGroupAdapter.forClients()
Creates a cluster group of nodes started in client mode.
|
ClusterGroup |
IgniteClusterAsyncImpl.forDaemons()
Gets a cluster group consisting from the daemon nodes.
|
ClusterGroup |
ClusterGroupAdapter.forDaemons()
Gets a cluster group consisting from the daemon nodes.
|
ClusterGroup |
IgniteClusterAsyncImpl.forDataNodes(String cacheName)
Creates a cluster group for all data nodes that have the cache with the specified name running.
|
ClusterGroup |
ClusterGroupAdapter.forDataNodes(String cacheName)
Creates a cluster group for all data nodes that have the cache with the specified name running.
|
ClusterGroup |
IgniteClusterAsyncImpl.forHost(ClusterNode node)
Gets cluster group consisting from the nodes in this cluster group residing on the
same host as the given node.
|
ClusterGroup |
ClusterGroupAdapter.forHost(ClusterNode node)
Gets cluster group consisting from the nodes in this cluster group residing on the
same host as the given node.
|
ClusterGroup |
IgniteClusterAsyncImpl.forHost(String host,
String... hosts)
Gets cluster group consisting from the nodes running on the hosts specified.
|
ClusterGroup |
ClusterGroupAdapter.forHost(String host,
String... hosts)
Gets cluster group consisting from the nodes running on the hosts specified.
|
ClusterGroup |
IgniteClusterAsyncImpl.forLocal()
Gets a cluster group consisting from the local node.
|
ClusterGroup |
IgniteClusterImpl.forLocal()
Gets a cluster group consisting from the local node.
|
ClusterGroup |
IgniteClusterAsyncImpl.forNode(ClusterNode node,
ClusterNode... nodes)
Creates a cluster group for the given node.
|
ClusterGroup |
ClusterGroupAdapter.forNode(ClusterNode node,
ClusterNode... nodes)
Creates a cluster group for the given node.
|
ClusterGroup |
IgniteClusterAsyncImpl.forNodeId(UUID id,
UUID... ids)
Creates a cluster group for a node with the specified ID.
|
ClusterGroup |
ClusterGroupAdapter.forNodeId(UUID id,
UUID... ids)
Creates a cluster group for a node with the specified ID.
|
ClusterGroup |
IgniteClusterAsyncImpl.forNodeIds(Collection<UUID> ids)
Creates a cluster group over nodes with specified node IDs.
|
ClusterGroup |
ClusterGroupAdapter.forNodeIds(Collection<UUID> ids)
Creates a cluster group over nodes with specified node IDs.
|
ClusterGroup |
IgniteClusterAsyncImpl.forNodes(Collection<? extends ClusterNode> nodes)
Creates a cluster group over a given set of nodes.
|
ClusterGroup |
ClusterGroupAdapter.forNodes(Collection<? extends ClusterNode> nodes)
Creates a cluster group over a given set of nodes.
|
ClusterGroup |
IgniteClusterAsyncImpl.forOldest()
Creates a cluster group with one oldest node from the current cluster group.
|
ClusterGroup |
ClusterGroupAdapter.forOldest()
Creates a cluster group with one oldest node from the current cluster group.
|
ClusterGroup |
IgniteClusterAsyncImpl.forOthers(ClusterGroup prj)
Creates a cluster group for nodes not included into the given cluster group.
|
ClusterGroup |
ClusterGroupAdapter.forOthers(ClusterGroup grp)
Creates a cluster group for nodes not included into the given cluster group.
|
ClusterGroup |
IgniteClusterAsyncImpl.forOthers(ClusterNode node,
ClusterNode... nodes)
Creates a cluster group for nodes other than the given nodes.
|
ClusterGroup |
ClusterGroupAdapter.forOthers(ClusterNode node,
ClusterNode... nodes)
Creates a cluster group for nodes other than the given nodes.
|
ClusterGroup |
IgniteClusterAsyncImpl.forPredicate(IgnitePredicate<ClusterNode> p)
Creates a new cluster group which includes all nodes that pass the given predicate filter.
|
ClusterGroup |
ClusterGroupAdapter.forPredicate(IgnitePredicate<ClusterNode> p)
Creates a new cluster group which includes all nodes that pass the given predicate filter.
|
ClusterGroup |
IgniteClusterAsyncImpl.forRandom()
Creates a cluster group with one random node from the current cluster group.
|
ClusterGroup |
ClusterGroupAdapter.forRandom()
Creates a cluster group with one random node from the current cluster group.
|
ClusterGroup |
IgniteClusterAsyncImpl.forRemotes()
Gets cluster group consisting from the nodes in this cluster group excluding the local node.
|
ClusterGroup |
ClusterGroupAdapter.forRemotes()
Gets cluster group consisting from the nodes in this cluster group excluding the local node.
|
ClusterGroup |
IgniteClusterAsyncImpl.forServers()
Creates a cluster group of nodes started in server mode.
|
ClusterGroup |
ClusterGroupAdapter.forServers()
Creates a cluster group of nodes started in server mode.
|
ClusterGroup |
IgniteClusterAsyncImpl.forYoungest()
Creates a cluster group with one youngest node in the current cluster group.
|
ClusterGroup |
ClusterGroupAdapter.forYoungest()
Creates a cluster group with one youngest node in the current cluster group.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterGroup |
IgniteClusterAsyncImpl.forOthers(ClusterGroup prj)
Creates a cluster group for nodes not included into the given cluster group.
|
ClusterGroup |
ClusterGroupAdapter.forOthers(ClusterGroup grp)
Creates a cluster group for nodes not included into the given cluster group.
|
| Modifier and Type | Method and Description |
|---|---|
CacheMetrics |
GridCacheAdapter.clusterMetrics(ClusterGroup grp)
Gets cluster group metrics (statistics) for this cache.
|
CacheMetrics |
IgniteInternalCache.clusterMetrics(ClusterGroup grp)
Gets cluster group metrics (statistics) for this cache.
|
CacheMetrics |
GridCacheProxyImpl.clusterMetrics(ClusterGroup grp)
Gets cluster group metrics (statistics) for this cache.
|
CacheMetrics |
IgniteCacheProxyImpl.metrics(ClusterGroup grp)
Gets cluster group snapshot metrics for caches in cluster group.
|
CacheMetrics |
GatewayProtectedCacheProxy.metrics(ClusterGroup grp)
Gets cluster group snapshot metrics for caches in cluster group.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterGroup |
GridCacheQueryAdapter.projection() |
| Modifier and Type | Method and Description |
|---|---|
CacheQuery<T> |
GridCacheQueryAdapter.projection(ClusterGroup prj)
Sets optional grid projection to execute this query on.
|
CacheQuery<T> |
CacheQuery.projection(ClusterGroup prj)
Sets optional grid projection to execute this query on.
|
| Constructor and Description |
|---|
GridCacheQueryAdapter(GridCacheContext<?,?> cctx,
GridCacheQueryType type,
IgniteLogger log,
int pageSize,
long timeout,
boolean incBackups,
boolean dedup,
ClusterGroup prj,
IgniteBiPredicate<Object,Object> filter,
@Nullable Integer part,
@Nullable String clsName,
String clause,
int limit,
boolean incMeta,
boolean keepBinary,
UUID subjId,
int taskHash,
MvccSnapshot mvccSnapshot,
Boolean dataPageScanEnabled) |
| Modifier and Type | Method and Description |
|---|---|
ClusterGroup |
ClientClusterGroupProjection.apply(ClusterGroup clusterGrp)
Applies projection.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterGroup |
ClientClusterGroupProjection.apply(ClusterGroup clusterGrp)
Applies projection.
|
| Constructor and Description |
|---|
PlatformCompute(PlatformContext platformCtx,
ClusterGroup grp,
String platformAttr)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<?> |
IgniteServiceProcessor.deployAll(ClusterGroup prj,
Collection<ServiceConfiguration> cfgs) |
abstract IgniteInternalFuture<?> |
ServiceProcessorAdapter.deployAll(ClusterGroup prj,
Collection<ServiceConfiguration> cfgs) |
IgniteInternalFuture<?> |
GridServiceProcessor.deployAll(ClusterGroup prj,
Collection<ServiceConfiguration> cfgs)
Deprecated.
|
IgniteInternalFuture<?> |
IgniteServiceProcessor.deployClusterSingleton(ClusterGroup prj,
String name,
Service srvc) |
abstract IgniteInternalFuture<?> |
ServiceProcessorAdapter.deployClusterSingleton(ClusterGroup prj,
String name,
Service srvc) |
IgniteInternalFuture<?> |
GridServiceProcessor.deployClusterSingleton(ClusterGroup prj,
String name,
Service srvc)
Deprecated.
|
IgniteInternalFuture<?> |
IgniteServiceProcessor.deployMultiple(ClusterGroup prj,
String name,
Service srvc,
int totalCnt,
int maxPerNodeCnt) |
abstract IgniteInternalFuture<?> |
ServiceProcessorAdapter.deployMultiple(ClusterGroup prj,
String name,
Service srvc,
int totalCnt,
int maxPerNodeCnt) |
IgniteInternalFuture<?> |
GridServiceProcessor.deployMultiple(ClusterGroup prj,
String name,
Service srvc,
int totalCnt,
int maxPerNodeCnt)
Deprecated.
|
IgniteInternalFuture<?> |
IgniteServiceProcessor.deployNodeSingleton(ClusterGroup prj,
String name,
Service srvc) |
abstract IgniteInternalFuture<?> |
ServiceProcessorAdapter.deployNodeSingleton(ClusterGroup prj,
String name,
Service srvc) |
IgniteInternalFuture<?> |
GridServiceProcessor.deployNodeSingleton(ClusterGroup prj,
String name,
Service srvc)
Deprecated.
|
<T> T |
IgniteServiceProcessor.serviceProxy(ClusterGroup prj,
String name,
Class<? super T> srvcCls,
boolean sticky,
long timeout) |
abstract <T> T |
ServiceProcessorAdapter.serviceProxy(ClusterGroup prj,
String name,
Class<? super T> srvcCls,
boolean sticky,
long timeout) |
<T> T |
GridServiceProcessor.serviceProxy(ClusterGroup prj,
String name,
Class<? super T> srvcCls,
boolean sticky,
long timeout)
Deprecated.
|
| Constructor and Description |
|---|
GridServiceProxy(ClusterGroup prj,
String name,
Class<? super T> svc,
boolean sticky,
long timeout,
GridKernalContext ctx) |
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.11.1 Release Date : December 20 2021