| 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 |
GridifyTaskAdapter<R>
Convenience adapter for tasks that work with
Gridify annotation
for grid-enabling methods. |
class |
GridifyTaskSplitAdapter<R>
Convenience adapter for tasks that work with
Gridify annotation
for grid-enabling methods. |
| Modifier and Type | Class and Description |
|---|---|
class |
GridifyDefaultRangeTask
Default gridify task which simply executes a method on remote node.
|
class |
GridifyDefaultTask
Default gridify task which simply executes a method on remote node.
|
| Modifier and Type | Class and Description |
|---|---|
class |
IgfsTask<T,R>
IGFS task which can be executed on the grid using one of
IgniteFs.execute() methods. |
class |
IgfsTaskNoReduceAdapter<T,R>
Convenient
IgfsTask adapter with empty reduce step. |
| 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> |
IgniteComputeImpl.executeAsync0(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.
|
void |
IgniteComputeImpl.localDeployTask(Class<? extends ComputeTask> taskCls,
ClassLoader clsLdr)
Explicitly deploys a task with given class loader on the local node.
|
| Modifier and Type | Method and Description |
|---|---|
static <R> R |
TaskExecutor.executeTask(GridClient client,
Class<? extends ComputeTask<?,R>> taskCls,
Object taskArgs,
GridClientConfiguration clientCfg) |
| 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 |
JdbcConnectionValidationTask
Deprecated.
Using Ignite client node based JDBC driver is preferable.
See documentation of
IgniteJdbcDriver for details. |
| 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 |
GridCacheQueryJdbcMetadataTask
Task that gets metadata for JDBC adapter.
|
class |
GridCacheQueryJdbcTask
Task for JDBC adapter.
|
class |
GridCacheQueryJdbcValidationTask
Task to validate connection.
|
| Modifier and Type | Class and Description |
|---|---|
class |
CollectConflictPartitionKeysTask |
class |
RetrieveConflictPartitionValuesTask |
class |
VerifyBackupPartitionsDumpTask
Task for collection checksums primary and backup partitions of specified caches.
|
class |
VerifyBackupPartitionsTask
Deprecated.
Legacy version of
VerifyBackupPartitionsTaskV2. |
class |
VerifyBackupPartitionsTaskV2
Task for comparing update counters and checksums between primary and backup partitions of specified caches.
|
| 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 |
PlatformBalancingSingleClosureAffinityTask
Interop single-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,
boolean sys) |
<T,R> ComputeTaskInternalFuture<R> |
GridTaskProcessor.execute(ComputeTask<T,R> task,
T arg,
boolean sys,
@Nullable String execName) |
<T,R> ComputeTaskInternalFuture<R> |
GridTaskProcessor.execute(ComputeTask<T,R> task,
T arg,
String execName) |
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,
@Nullable String execName) |
| 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 |
VisorCoordinatorNodeTask<A,R>
Base class for Visor tasks intended to execute job on coordinator node.
|
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 |
VisorBaselineTask
Task that will collect information about baseline topology and can change its state.
|
class |
VisorBaselineViewTask
Task that will collect information about baseline topology.
|
| Modifier and Type | Class and Description |
|---|---|
class |
VisorBinaryMetadataCollectorTask
Task that collects binary metadata.
|
| Modifier and Type | Class and Description |
|---|---|
class |
VisorCacheAffinityNodeTask
Task that will find affinity node for key.
|
class |
VisorCacheClearTask
Task that clears specified caches on specified node.
|
class |
VisorCacheConfigurationCollectorTask
Task that collect cache metrics from all nodes.
|
class |
VisorCacheLoadTask
Task to loads caches.
|
class |
VisorCacheLostPartitionsTask
Collect list of lost partitions.
|
class |
VisorCacheMetadataTask
Task to get cache SQL metadata.
|
class |
VisorCacheMetricsCollectorTask
Task that collect cache metrics from all nodes.
|
class |
VisorCacheModifyTask
Task that modify value in specified cache.
|
class |
VisorCacheNamesCollectorTask
Task that collect cache names and deployment IDs.
|
class |
VisorCacheNodesTask
Task that returns collection of cache data nodes IDs.
|
class |
VisorCachePartitionsTask
Task that collect keys distribution in partitions.
|
class |
VisorCacheRebalanceTask
Pre-loads caches.
|
class |
VisorCacheResetLostPartitionsTask
Reset lost partitions for caches.
|
class |
VisorCacheResetMetricsTask
Reset compute grid metrics.
|
class |
VisorCacheStartTask
Task that start cache or near cache with specified configuration.
|
class |
VisorCacheStopTask
Task that stop specified caches on specified node.
|
class |
VisorCacheToggleStatisticsTask
Switch statisticsEnabled flag for specified caches to specified state.
|
class |
VisorFindAndDeleteGarbageInPersistenceTask
Compute task which are part of 'find and delete garbage' functionality.
|
| Modifier and Type | Class and Description |
|---|---|
class |
VisorComputeCancelSessionsTask
Cancels given tasks sessions.
|
class |
VisorComputeResetMetricsTask
Reset compute grid metrics task.
|
class |
VisorComputeToggleMonitoringTask
Task to run gc on nodes.
|
class |
VisorGatewayTask
Task to run Visor tasks through http REST.
|
| Modifier and Type | Class and Description |
|---|---|
class |
VisorThreadDumpTask
Creates thread dump.
|
| Modifier and Type | Class and Description |
|---|---|
class |
VisorPageLocksTask |
| Modifier and Type | Class and Description |
|---|---|
class |
VisorFileBlockTask
Task to read file block.
|
class |
VisorLatestTextFilesTask
Get list files matching filter.
|
| Modifier and Type | Class and Description |
|---|---|
class |
VisorIgfsFormatTask
Format IGFS instance.
|
class |
VisorIgfsProfilerClearTask
Remove all IGFS profiler logs.
|
class |
VisorIgfsProfilerTask
Task that parse hadoop profiler logs.
|
class |
VisorIgfsResetMetricsTask
Resets IGFS metrics.
|
class |
VisorIgfsSamplingStateTask
Task to set IGFS instance sampling state.
|
| Modifier and Type | Class and Description |
|---|---|
class |
VisorLogSearchTask
Search text matching in logs
|
| Modifier and Type | Class and Description |
|---|---|
class |
VisorAckTask
Ack task to run on node.
|
class |
VisorChangeGridActiveStateTask
Task for changing grid active state.
|
class |
VisorLatestVersionTask
Task for collecting latest version.
|
class |
VisorNopTask
Nop task with random timeout.
|
class |
VisorResolveHostNameTask
Task that resolve host name for specified IP address from node.
|
class |
VisorWalTask
Performs WAL cleanup clusterwide.
|
| Modifier and Type | Class and Description |
|---|---|
class |
VisorCacheRebalanceCollectorTask
Collects topology rebalance metrics.
|
class |
VisorNodeConfigurationCollectorTask
Grid configuration data collect task.
|
class |
VisorNodeDataCollectorTask
Collects current Grid state mostly topology and metrics.
|
class |
VisorNodeEventsCollectorTask
Task that runs on specified node and returns events data.
|
class |
VisorNodeGcTask
Task to run gc on nodes.
|
class |
VisorNodePingTask
Ping other node.
|
class |
VisorNodeRestartTask
Restarts nodes.
|
class |
VisorNodeStopTask
Stops nodes.
|
class |
VisorNodeSuppressedErrorsTask
Task to collect last errors on nodes.
|
| Modifier and Type | Class and Description |
|---|---|
class |
VisorQueryCancelTask
Task to cancel queries.
|
class |
VisorQueryCleanupTask
Task for cleanup not needed SCAN or SQL queries result futures from node local.
|
class |
VisorQueryDetailMetricsCollectorTask
Task to collect cache query metrics.
|
class |
VisorQueryFetchFirstPageTask
Task for check a query execution and receiving first page of query result.
|
class |
VisorQueryNextPageTask
Task for collecting next page previously executed SQL or SCAN query.
|
class |
VisorQueryPingTask
Task for inform a node about awaiting of query result from Web console.
|
class |
VisorQueryResetDetailMetricsTask
Reset query detail metrics.
|
class |
VisorQueryResetMetricsTask
Reset compute grid query metrics.
|
class |
VisorQueryTask
Task for execute SQL fields query and get first page of results.
|
class |
VisorRunningQueriesCollectorTask
Task to collect currently running queries.
|
class |
VisorScanQueryTask
Task for execute SCAN query and get first page of results.
|
| Modifier and Type | Class and Description |
|---|---|
class |
VisorCancelServiceTask
Task for cancel services with specified name.
|
class |
VisorServiceTask
Task for collect topology service configuration.
|
| Modifier and Type | Class and Description |
|---|---|
class |
FetchNearXidVersionTask
Retrieves unique transaction identifier (nearXid) from UUID/GridCacheVersion of xid/nearXid.
|
class |
VisorTxTask |
| Modifier and Type | Class and Description |
|---|---|
class |
VisorContentionTask |
class |
VisorIdleAnalyzeTask
Task to find diverged keys of conflict partition.
|
class |
VisorIdleVerifyDumpTask
Task to verify checksums of backup partitions and return all collected information.
|
class |
VisorIdleVerifyTask
Deprecated.
|
class |
VisorIdleVerifyTaskV2
Task to verify checksums of backup partitions.
|
class |
VisorViewCacheTask |
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.8.0 Release Date : February 27 2020