Package org.apache.ignite.internal.management.api

Interface ComputeCommand<A extends IgniteDataTransferObject,R>

All Superinterfaces:

Command<A,R>

All Known Implementing Classes:

AbstractBaselineCommand, AbstractSnapshotCommand, AbstractTracingConfigurationCommand, BaselineAddCommand, BaselineAutoAdjustCommand, BaselineCommand, BaselineRemoveCommand, BaselineSetCommand, BaselineVersionCommand, CacheCheckIndexInlineSizesCommand, CacheClearCommand, CacheContentionCommand, CacheCreateCommand, CacheDestroyCommand, CacheDistributionCommand, CacheFindGarbageCommand, CacheIdleVerifyCommand, CacheIdleVerifyDumpCommand, CacheIndexesForceRebuildCommand, CacheIndexesListCommand, CacheIndexesRebuildStatusCommand, CacheMetricsCommand, CacheResetLostPartitionsCommand, CacheScanCommand, CacheScheduleIndexesRebuildCommand, CacheValidateIndexesCommand, CdcDeleteLostSegmentLinksCommand, CdcResendCommand, ChangeTagCommand, ConsistencyFinalizeCommand, ConsistencyStatusCommand, DefragmentationCancelCommand, DefragmentationScheduleCommand, DefragmentationStatusCommand, DiagnosticConnectivityCommand, DiagnosticPagelocksCommand, EncryptionCacheKeyIdsCommand, EncryptionChangeCacheKeyCommand, EncryptionChangeMasterKeyCommand, EncryptionGetMasterKeyNameCommand, EncryptionReencryptionRateLimitCommand, EncryptionReencryptionStatusCommand, EncryptionResumeReencryptionCommand, EncryptionSuspendReencryptionCommand, KillClientCommand, KillComputeCommand, KillConsistencyCommand, KillContinuousCommand, KillScanCommand, KillServiceCommand, KillSnapshotCommand, KillSqlCommand, KillTransactionCommand, MetaDetailsCommand, MetaListCommand, MetaRemoveCommand, MetaUpdateCommand, MetricCommand, MetricConfigureHistogramCommand, MetricConfigureHitrateCommand, PerformanceStatisticsRotateCommand, PerformanceStatisticsStartCommand, PerformanceStatisticsStatusCommand, PerformanceStatisticsStopCommand, PersistenceAbstractCommand, PersistenceBackupAllCommand, PersistenceBackupCachesCommand, PersistenceBackupCorruptedCommand, PersistenceCleanAllCommand, PersistenceCleanCachesCommand, PersistenceCleanCorruptedCommand, PersistenceCommand, PersistenceInfoCommand, PropertyGetCommand, PropertyListCommand, PropertySetCommand, ShutdownPolicyCommand, SnapshotCancelCommand, SnapshotCheckCommand, SnapshotCreateCommand, SnapshotRestoreCommand, SnapshotStatusCommand, SystemViewCommand, TracingConfigurationCommand, TracingConfigurationGetAllCommand, TracingConfigurationGetCommand, TracingConfigurationResetAllCommand, TracingConfigurationResetCommand, TracingConfigurationSetCommand, TxCommand, WalDeleteCommand, WalPrintCommand

public interface ComputeCommand<A extends IgniteDataTransferObject,R>
extends Command<A,R>

Command that executed with some compute task.

Field Summary

Fields inherited from interface org.apache.ignite.internal.management.api.Command

CMD_NAME_POSTFIX

Method Summary

Modifier and Type	Method	Description
default R	handleException(Exception e, Consumer<String> printer)
default @Nullable Collection<GridClientNode>	nodes(Collection<GridClientNode> nodes, A arg)
default void	printResult(A arg, R res, Consumer<String> printer)	Prints command result to the user.
Class<? extends VisorMultiNodeTask<A,R,?>>	taskClass()

Methods inherited from interface org.apache.ignite.internal.management.api.Command

argClass, confirmationPrompt, deprecationMessage, description

Method Detail

taskClass

Class<? extends VisorMultiNodeTask<A,R,?>> taskClass()

Returns:

Task class.

printResult

default void printResult(A arg,
                         R res,
                         Consumer<String> printer)

Prints command result to the user.

Parameters:

arg - Argument.

res - Result.

printer - Implementation specific printer.

nodes

@Nullable
default @Nullable Collection<GridClientNode> nodes(Collection<GridClientNode> nodes,
                                                   A arg)

Parameters:

nodes - Live nodes.

arg - Argument.

Returns:

nodes to execute command on, null means default node must be used.

handleException

default R handleException(Exception e,
                          Consumer<String> printer)
                   throws Exception

Parameters:

e - Task execution exception to handle.

printer - Implementation specific printer.

Returns:

Result if the exception is suppressed.

Throws:

Exception