| Modifier and Type | Method and Description |
|---|---|
Map<String,Class<? extends ComputeTask<?,?>>> |
IgniteCompute.localTasks()
Gets map of all locally deployed tasks keyed by their task name .
|
| Modifier and Type | Method and Description |
|---|---|
<T,R> R |
IgniteCompute.execute(ComputeTask<T,R> task,
T arg)
Executes given task within the cluster group.
|
<T,R> ComputeTaskFuture<R> |
IgniteCompute.executeAsync(ComputeTask<T,R> task,
T arg)
Executes given task asynchronously within the cluster group.
|
| Modifier and Type | Method and Description |
|---|---|
<T,R> R |
IgniteCompute.execute(Class<? extends ComputeTask<T,R>> taskCls,
T arg)
Executes given task on within the cluster group.
|
<T,R> ComputeTaskFuture<R> |
IgniteCompute.executeAsync(Class<? extends ComputeTask<T,R>> taskCls,
T arg)
Executes given task asynchronously on within the cluster group.
|
void |
IgniteCompute.localDeployTask(Class<? extends ComputeTask> taskCls,
ClassLoader clsLdr)
Explicitly deploys a task with given class loader on the local node.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ComputeTaskAdapter<T,R>
Convenience adapter for
ComputeTask interface. |
class |
ComputeTaskSplitAdapter<T,R>
This class defines simplified adapter for
ComputeTask. |
| Modifier and Type | Class and Description |
|---|---|
class |
CheckCpHistTask
Task that checks whether last checkpoint is applicable for providing history for all groups and partitions that are
passed as parameters.
|
| Modifier and Type | Method and Description |
|---|---|
Map<String,Class<? extends ComputeTask<?,?>>> |
IgniteComputeImpl.localTasks()
Gets map of all locally deployed tasks keyed by their task name .
|
| Modifier and Type | Method and Description |
|---|---|
<T,R> R |
IgniteComputeImpl.execute(ComputeTask<T,R> task,
T arg)
Executes given task within the cluster group.
|
<T,R> ComputeTaskFuture<R> |
IgniteComputeImpl.executeAsync(ComputeTask<T,R> task,
T arg)
Executes given task asynchronously within the cluster group.
|
<T,R> ComputeTaskInternalFuture<R> |
IgniteComputeHandler.executeAsync(ComputeTask<T,R> task,
T arg)
Execute implementation.
|
| Modifier and Type | Method and Description |
|---|---|
<T,R> R |
IgniteComputeImpl.execute(Class<? extends ComputeTask<T,R>> taskCls,
T arg)
Executes given task on within the cluster group.
|
<T,R> ComputeTaskFuture<R> |
IgniteComputeImpl.executeAsync(Class<? extends ComputeTask<T,R>> taskCls,
T arg)
Executes given task asynchronously on within the cluster group.
|
<T,R> IgniteInternalFuture<R> |
IgniteComputeHandler.executeAsync(Class<? extends ComputeTask<T,R>> taskCls,
T arg)
Execute implementation.
|
void |
IgniteComputeImpl.localDeployTask(Class<? extends ComputeTask> taskCls,
ClassLoader clsLdr)
Explicitly deploys a task with given class loader on the local node.
|
| Modifier and Type | Class and Description |
|---|---|
class |
CheckIndexInlineSizesTask
Task for check secondary indexes inline size on the different nodes.
|
| Modifier and Type | Class and Description |
|---|---|
class |
CacheDistributionTask
Collect information on the distribution of partitions.
|
| Modifier and Type | Class and Description |
|---|---|
class |
CacheResetLostPartitionsTask
Reset status of lost partitions.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ClusterChangeTagTask |
class |
ShutdownPolicyTask
Shutdown policy task.
|
class |
SystemViewTask
Reperesents visor task for obtaining system view content.
|
| Modifier and Type | Method and Description |
|---|---|
Class<? extends ComputeTask<VisorTaskArgument<A>,R>> |
ComputeCommand.taskClass() |
| Modifier and Type | Method and Description |
|---|---|
static <A,R> R |
CommandUtils.execute(@Nullable GridClient cli,
@Nullable Ignite ignite,
Class<? extends ComputeTask<VisorTaskArgument<A>,R>> taskCls,
A arg,
Collection<GridClientNode> nodes) |
| Modifier and Type | Class and Description |
|---|---|
class |
BaselineTask
Task that will collect information about baseline topology and can change its state.
|
| Modifier and Type | Class and Description |
|---|---|
class |
CacheConfigurationCollectorTask
Task that collect cache metrics from all nodes.
|
class |
CacheCreateTask
Task to create caches from Spring XML configuration.
|
class |
CacheMetricsTask
Task for a cache metrics command.
|
class |
CacheScanTask
Task that scan cache entries.
|
class |
CacheStopTask
Task that stop specified caches on specified node.
|
class |
ContentionTask |
class |
FindAndDeleteGarbageInPersistenceTask
Compute task which are part of 'find and delete garbage' functionality.
|
class |
IdleVerifyDumpTask
Task to verify checksums of backup partitions and return all collected information.
|
class |
IdleVerifyTaskV2
Task to verify checksums of backup partitions.
|
class |
IndexForceRebuildTask
Task that triggers indexes force rebuild for specified caches or cache groups.
|
class |
IndexListTask
Task that collects indexes information.
|
class |
IndexRebuildStatusTask
Task that collects caches that have index rebuild in progress.
|
class |
ScheduleIndexRebuildTask
Task that schedules indexes rebuild for specified caches via the maintenance mode.
|
class |
ValidateIndexesTask |
class |
VerifyBackupPartitionsDumpTask
Task for collection checksums primary and backup partitions of specified caches.
|
class |
VerifyBackupPartitionsTaskV2
Task for comparing update counters and checksums between primary and backup partitions of specified caches.
|
class |
ViewCacheTask |
| Modifier and Type | Class and Description |
|---|---|
class |
CdcCacheDataResendTask
Task to forcefully resend all cache data to CDC.
|
class |
CdcDeleteLostSegmentsTask
Task to delete lost segment CDC links.
|
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractConsistencyTask<A,J>
Base class for Consistency tasks.
|
class |
ConsistencyCountersFinalizationTask |
class |
ConsistencyRepairTask |
class |
ConsistencyStatusTask |
| Modifier and Type | Class and Description |
|---|---|
class |
DefragmentationTask |
| Modifier and Type | Class and Description |
|---|---|
class |
ConnectivityTask
Visor task that checks connectivity status between nodes.
|
class |
PageLocksTask |
| Modifier and Type | Class and Description |
|---|---|
class |
CacheGroupEncryptionTask<T>
Visor encrypted cache group multinode task.
|
class |
ChangeCacheGroupKeyTask
The task for changing the encryption key of the cache group.
|
class |
ChangeMasterKeyTask
The task for changing the master key.
|
class |
EncryptionKeyIdsTask
Get current encryption key IDs of the cache group.
|
class |
GetMasterKeyNameTask
The task for getting the master key name.
|
class |
ReencryptionRateTask
View/change cache group re-encryption rate limit .
|
class |
ReencryptionResumeTask
Resume re-encryption of the cache group.
|
class |
ReencryptionStatusTask
Get re-encryption status of the cache group.
|
class |
ReencryptionSuspendTask
Suspend re-encryption of the cache group.
|
| Modifier and Type | Class and Description |
|---|---|
class |
CancelServiceTask
Task for cancel services with specified name.
|
class |
ClientConnectionDropTask
Task to cancel client connection(s).
|
class |
ComputeCancelSessionTask
Cancels given tasks sessions on all cluster nodes.
|
class |
ConsistencyCancelTask
Cancels given consistency repairs on all cluster nodes.
|
class |
ContinuousQueryCancelTask
Task to cancel continuous query.
|
class |
KillTransactionTask |
class |
QueryCancelOnInitiatorTask
Task to cancel queries on initiator node.
|
class |
ScanQueryCancelTask
Task to cancel scan queries.
|
class |
SnapshotCancelTask |
| Modifier and Type | Class and Description |
|---|---|
class |
MetadataInfoTask
Task for MetadataListCommand and MetadataDetailsCommand commands.
|
class |
MetadataRemoveTask
Task for remove specified binary type.
|
class |
MetadataUpdateTask
Task for update specified binary type.
|
| Modifier and Type | Class and Description |
|---|---|
class |
MetricTask
Reperesents visor task for obtaining metric values.
|
| Modifier and Type | Class and Description |
|---|---|
class |
PerformanceStatisticsTask
Represents visor task to manage performance statistics.
|
| Modifier and Type | Class and Description |
|---|---|
class |
PersistenceTask |
| Modifier and Type | Class and Description |
|---|---|
class |
PropertiesListTask
Task for property operations.
|
class |
PropertyTask
Task for property operations.
|
| Modifier and Type | Class and Description |
|---|---|
class |
SnapshotCheckTask |
class |
SnapshotCreateTask |
class |
SnapshotOneNodeTask<A,R>
Base class for single node visor snapshot task.
|
class |
SnapshotRestoreTask
Visor snapshot restore task.
|
class |
SnapshotStatusTask
Task to get the status of the current snapshot operation in the cluster.
|
| Modifier and Type | Class and Description |
|---|---|
class |
TracingConfigurationTask
Task that will collect and update tracing configuration.
|
| Modifier and Type | Class and Description |
|---|---|
class |
FetchNearXidVersionTask
Retrieves unique transaction identifier (nearXid) from UUID/GridCacheVersion of xid/nearXid.
|
class |
TxTask |
| Modifier and Type | Class and Description |
|---|---|
class |
WalTask
Performs WAL cleanup clusterwide.
|
| Modifier and Type | Method and Description |
|---|---|
Map<String,Class<? extends ComputeTask<?,?>>> |
GridDeploymentManager.findAllTasks(IgnitePredicate<? super Class<? extends ComputeTask<?,?>>>... p) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridDeployment.internalTask(@Nullable ComputeTask task,
Class<?> taskCls)
Checks whether task class is annotated with
GridInternal. |
boolean |
GridDeployment.visorManagementTask(@Nullable ComputeTask task,
@NotNull Class<?> taskCls)
Checks whether task class is annotated with
GridVisorManagementTask. |
| Modifier and Type | Class and Description |
|---|---|
class |
ClearCachesTask
Clears specified caches.
|
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractSnapshotVerificationTask
The task for checking the consistency of snapshots in the cluster.
|
class |
IncrementalSnapshotVerificationTask |
class |
SnapshotHandlerRestoreTask
Snapshot restore operation handling task.
|
class |
SnapshotMetadataVerificationTask
Snapshot task to verify snapshot metadata on the baseline nodes for given snapshot name.
|
class |
SnapshotPartitionsVerifyTask
Task for checking snapshot partitions consistency the same way as
VerifyBackupPartitionsTaskV2 does. |
| Modifier and Type | Class and Description |
|---|---|
class |
CollectConflictPartitionKeysTask |
class |
RetrieveConflictPartitionValuesTask |
| Modifier and Type | Class and Description |
|---|---|
class |
GridPeerDeployAwareTaskAdapter<T,R>
Peer deployment aware task adapter.
|
| Modifier and Type | Class and Description |
|---|---|
class |
PlatformAbstractTask
Base class for all interop tasks.
|
class |
PlatformBalancingMultiClosureTask
Interop multi-closure task with node balancing.
|
class |
PlatformBalancingSingleClosureTask
Interop single-closure task with node balancing.
|
class |
PlatformBroadcastingMultiClosureTask
Interop multi-closure task with broadcast semantics.
|
class |
PlatformBroadcastingSingleClosureTask
Interop single-closure task with broadcast semantics.
|
class |
PlatformFullTask
Interop task which requires full execution cycle.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridResourceProcessor.inject(GridDeployment dep,
ComputeTask<?,?> task,
GridTaskSessionImpl ses,
ComputeLoadBalancer balancer,
ComputeTaskContinuousMapper mapper)
Injects held resources into given grid task.
|
| Modifier and Type | Method and Description |
|---|---|
ComputeTask<T,R> |
GridTaskWorker.getTask() |
| Modifier and Type | Method and Description |
|---|---|
<T,R> ComputeTaskInternalFuture<R> |
GridTaskProcessor.execute(ComputeTask<T,R> task,
T arg) |
<T,R> ComputeTaskInternalFuture<R> |
GridTaskProcessor.execute(ComputeTask<T,R> task,
T arg,
TaskExecutionOptions opts) |
void |
GridTaskWorker.setTask(ComputeTask<T,R> task) |
| Modifier and Type | Method and Description |
|---|---|
<T,R> ComputeTaskInternalFuture<R> |
GridTaskProcessor.execute(Class<? extends ComputeTask<T,R>> taskCls,
T arg) |
<T,R> ComputeTaskInternalFuture<R> |
GridTaskProcessor.execute(Class<? extends ComputeTask<T,R>> taskCls,
T arg,
TaskExecutionOptions opts) |
| Modifier and Type | Method and Description |
|---|---|
static String |
IgniteUtils.getTaskName(Class<? extends ComputeTask<?,?>> taskCls)
Gets task name for the given task class.
|
| Modifier and Type | Class and Description |
|---|---|
class |
IgniteRemoteMapTask<T,R>
Util task that will execute ComputeTask on a given node.
|
| Constructor and Description |
|---|
IgniteRemoteMapTask(ClusterNode node,
ComputeTask<T,R> remoteTask) |
| Modifier and Type | Class and Description |
|---|---|
class |
VisorMultiNodeTask<A,R,J>
Base class for Visor tasks intended to query data from a multiple node.
|
class |
VisorOneNodeTask<A,R>
Base class for Visor tasks intended to query data from a single node.
|
| Modifier and Type | Class and Description |
|---|---|
class |
VisorBaselineViewTask
Task that will collect information about baseline topology.
|
| Modifier and Type | Class and Description |
|---|---|
class |
VisorComputeCancelSessionsTask
Cancels given task session.
|
| Modifier and Type | Class and Description |
|---|---|
class |
VisorIdAndTagViewTask |
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.16.0 Release Date : December 15 2023