This is an automated email from the ASF dual-hosted git repository. timoninmaxim pushed a change to branch IGNITE-17700__realtime_cdc in repository https://gitbox.apache.org/repos/asf/ignite.git
from 6eda7c91b41 IGNITE-19607 Fixed flaky IgniteClusterSnapshotStreamerTest test (#10755) add 9eaae91e0a5 IGNITE-19628 Add IndexQuery to performance statistics add 6d022194ed3 Revert "IGNITE-19628 Add IndexQuery to performance statistics" add 8950aefc115 IGNITE-19620 Provided ability to configure metric exporter filter from Spring XML (#10757) add 53dba922826 IGNITE-19590 SQL Calcite: Add sensitive information hiding when IGNITE_TO_STRING_INCLUDE_SENSITIVE property set to false - Fixes #10760. add 5c2b42dd4ec IGNITE-19628 Added IndexQuery to performance statistics (#10758) add 97176a35396 IGNITE-19650 Fixed broken serialization of communication messages due to incorrect GridCacheQueryRequest class marshalling. (#10768) add 0fb4ac567d0 IGNITE-19378 Documentation: Improve docs related to lazy loading - Fixes #10671. add 46d865d63dd IGNITE-15629 Management API introduced (#10675) add 77723f0d95c IGNITE-19588 SQL Calcite: Add long-running queries warnings - Fixes #10769. add 2fbd3a3329f IGNITE-19164 Improved message about requested partitions during snapshot restore (#10638) add f6e03372967 IGNITE-19164 Removed node consistent ID from snapshot restore message (#10771) add e7c9fe7eb1e IGNITE-19715 Thin client socket#open timeout changed to ClientConfiguration#timeout property. (#10770) add fc51f0e4327 IGNITE-19652 Adapt to DirectByteBuffer ctor changes in JDK 21 (#10764) add a225705fc5f IGNITE-16619 IndexQuery should support limit (#10767) No new revisions were added by this update. Summary of changes: docs/_docs/SQL/JDBC/jdbc-client-driver.adoc | 10 - docs/_docs/SQL/JDBC/jdbc-driver.adoc | 6 - docs/_docs/SQL/ODBC/connection-string-dsn.adoc | 6 - .../_docs/perf-and-troubleshooting/sql-tuning.adoc | 17 +- .../query/calcite/CalciteQueryProcessor.java | 66 +- .../internal/processors/query/calcite/Query.java | 32 +- .../processors/query/calcite/QueryRegistry.java | 11 +- .../query/calcite/QueryRegistryImpl.java | 29 +- .../processors/query/calcite}/QueryState.java | 2 +- .../processors/query/calcite/RootQuery.java | 67 +- .../query/calcite/exec/ExchangeService.java | 5 + .../query/calcite/exec/ExchangeServiceImpl.java | 16 +- .../query/calcite/exec/ExecutionServiceImpl.java | 35 +- .../query/calcite/exec/rel/RootNode.java | 62 +- .../calcite/prepare/AbstractMultiStepPlan.java | 5 +- .../{QueryPlan.java => AbstractQueryPlan.java} | 24 +- .../processors/query/calcite/prepare/DdlPlan.java | 6 +- .../query/calcite/prepare/ExplainPlan.java | 6 +- .../query/calcite/prepare/FragmentPlan.java | 6 +- .../query/calcite/prepare/MultiStepDmlPlan.java | 5 +- .../query/calcite/prepare/MultiStepQueryPlan.java | 5 +- .../query/calcite/prepare/PrepareServiceImpl.java | 11 +- .../query/calcite/prepare/QueryPlan.java | 5 + .../calcite/util/ConvertingClosableIterator.java | 10 +- .../processors/query/calcite/CancelTest.java | 6 +- .../exec/rel/TimeCalculationExecutionTest.java | 170 +++++ .../KillQueryCommandDdlIntegrationTest.java | 2 +- .../integration/RunningQueriesIntegrationTest.java | 25 +- .../integration/SqlDiagnosticIntegrationTest.java | 190 +++++- ...citeCommunicationMessageSerializationTest.java} | 28 +- .../query/calcite/planner/PlannerTest.java | 2 +- .../ignite/testsuites/ExecutionTestSuite.java | 2 + .../ignite/testsuites/IgniteCalciteTestSuite.java | 2 + .../thin/JdbcThinPartitionAwarenessSelfTest.java | 2 +- ...ThinPartitionAwarenessTransactionsSelfTest.java | 2 +- modules/control-utility/pom.xml | 7 + .../internal/commandline/AbstractCommand.java | 70 -- .../internal/commandline/ActivateCommand.java | 75 --- .../internal/commandline/ArgumentParser.java | 508 +++++++++++++++ .../internal/commandline/BaselineCommand.java | 316 --------- .../commandline/ClusterChangeTagCommand.java | 115 ---- .../commandline/ClusterStateChangeCommand.java | 130 ---- .../ignite/internal/commandline/Command.java | 281 -------- .../internal/commandline/CommandArgIterator.java | 216 ------- .../internal/commandline/CommandHandler.java | 400 +++++++++--- .../internal/commandline/CommandInvoker.java | 316 +++++++++ .../ignite/internal/commandline/CommandList.java | 167 ----- .../ignite/internal/commandline/CommandLogger.java | 99 --- .../internal/commandline/CommandsProvider.java | 5 +- .../internal/commandline/CommonArgParser.java | 402 ------------ .../commandline/ConnectionAndSslParameters.java | 186 +++--- .../internal/commandline/DeactivateCommand.java | 108 ---- .../commandline/DefragmentationCommand.java | 248 ------- .../ignite/internal/commandline/OutputFormat.java | 66 -- .../internal/commandline/PersistenceCommand.java | 288 --------- .../commandline/ShutdownPolicyCommand.java | 106 --- .../ignite/internal/commandline/StateCommand.java | 97 --- .../commandline/StringBuilderOutputStream.java | 69 -- .../ignite/internal/commandline/TaskExecutor.java | 198 ------ .../commandline/TracingConfigurationCommand.java | 334 ---------- .../ignite/internal/commandline/TxCommandArg.java | 78 --- .../ignite/internal/commandline/TxCommands.java | 558 ---------------- .../ignite/internal/commandline/WalCommands.java | 270 -------- .../ignite/internal/commandline/WarmUpCommand.java | 127 ---- .../internal/commandline/argument/CommandArg.java | 28 - .../commandline/argument/CommandArgUtils.java | 46 -- .../commandline/argument/parser/CLIArgument.java | 38 +- .../argument/parser/CLIArgumentParser.java | 121 ++-- .../commandline/baseline/BaselineArguments.java | 173 ----- .../commandline/baseline/BaselineSubcommands.java | 116 ---- .../internal/commandline/cache/CacheClear.java | 117 ---- .../internal/commandline/cache/CacheCommands.java | 148 ----- .../commandline/cache/CacheContention.java | 146 ----- .../internal/commandline/cache/CacheCreate.java | 124 ---- .../internal/commandline/cache/CacheDestroy.java | 162 ----- .../commandline/cache/CacheDistribution.java | 169 ----- .../cache/CacheIndexesForceRebuild.java | 263 -------- .../commandline/cache/CacheIndexesList.java | 264 -------- .../cache/CacheIndexesRebuildStatus.java | 172 ----- .../internal/commandline/cache/CacheMetrics.java | 133 ---- .../internal/commandline/cache/CacheScan.java | 128 ---- .../cache/CacheScheduleIndexesRebuild.java | 334 ---------- .../commandline/cache/CacheSubcommands.java | 201 ------ .../commandline/cache/CacheValidateIndexes.java | 337 ---------- .../commandline/cache/FindAndDeleteGarbage.java | 192 ------ .../internal/commandline/cache/IdleVerify.java | 411 ------------ .../commandline/cache/ResetLostPartitions.java | 79 --- .../cache/argument/DistributionCommandArg.java | 47 -- .../cache/argument/FindAndDeleteGarbageArg.java | 51 -- .../cache/argument/IdleVerifyCommandArg.java | 59 -- .../cache/argument/IndexRebuildCommandArg.java | 55 -- .../commandline/cache/argument/ListCommandArg.java | 56 -- .../cache/argument/ValidateIndexesCommandArg.java | 56 -- .../internal/commandline/cdc/CdcCommand.java | 69 -- .../internal/commandline/cdc/CdcSubcommands.java | 66 -- .../cdc/DeleteLostSegmentLinksCommand.java | 135 ---- .../internal/commandline/cdc/ResendCommand.java | 115 ---- .../consistency/ConsistencyCommand.java | 264 -------- .../consistency/ConsistencySubCommand.java | 77 --- .../defragmentation/DefragmentationArguments.java | 63 -- .../DefragmentationSubcommands.java | 68 -- .../commandline/diagnostic/DiagnosticCommand.java | 123 ---- .../diagnostic/DiagnosticSubCommand.java | 77 --- .../commandline/diagnostic/PageLocksCommand.java | 249 ------- .../encryption/CacheGroupEncryptionCommand.java | 264 -------- .../encryption/ChangeCacheGroupKeyCommand.java | 95 --- .../encryption/ChangeMasterKeyCommand.java | 88 --- .../commandline/encryption/EncryptionCommands.java | 70 -- .../encryption/EncryptionSubcommands.java | 99 --- .../encryption/GetMasterKeyNameCommand.java | 73 --- .../encryption/ReencryptionRateCommand.java | 137 ---- .../commandline/indexreader/IgniteIndexReader.java | 12 +- .../internal/commandline/meta/MetadataCommand.java | 152 ----- .../commandline/meta/MetadataSubCommandsList.java | 78 --- .../subcommands/MetadataAbstractSubCommand.java | 124 ---- .../meta/subcommands/MetadataHelpCommand.java | 49 -- .../meta/subcommands/MetadataListCommand.java | 55 -- .../meta/subcommands/MetadataRemoveCommand.java | 115 ---- .../meta/subcommands/MetadataUpdateCommand.java | 87 --- .../internal/commandline/metric/MetricCommand.java | 188 ------ .../commandline/metric/MetricCommandArg.java | 50 -- .../PerformanceStatisticsCommand.java | 107 --- .../PerformanceStatisticsSubCommand.java | 80 --- .../persistence/CleanAndBackupSubcommandArg.java | 45 -- .../persistence/PersistenceArguments.java | 100 --- .../persistence/PersistenceSubcommands.java | 73 --- .../commandline/property/PropertyCommand.java | 100 --- .../property/PropertySubCommandsList.java | 73 --- .../subcommands/PropertyAbstractSubCommand.java | 106 --- .../property/subcommands/PropertyGetCommand.java | 62 -- .../property/subcommands/PropertyHelpCommand.java | 49 -- .../property/subcommands/PropertyListCommand.java | 49 -- .../property/subcommands/PropertySetCommand.java | 71 -- .../internal/commandline/query/KillCommand.java | 287 -------- .../internal/commandline/query/KillSubcommand.java | 65 -- .../shutdown/ShutdownPolicyArgument.java | 72 --- .../snapshot/SnapshotCancelCommand.java | 84 --- .../snapshot/SnapshotCancelCommandOption.java | 71 -- .../commandline/snapshot/SnapshotCheckCommand.java | 101 --- .../snapshot/SnapshotCheckCommandOption.java | 73 --- .../commandline/snapshot/SnapshotCommand.java | 71 -- .../snapshot/SnapshotCreateCommand.java | 99 --- .../snapshot/SnapshotCreateCommandOption.java | 78 --- .../snapshot/SnapshotRestoreCommand.java | 209 ------ .../snapshot/SnapshotRestoreCommandOption.java | 84 --- .../commandline/snapshot/SnapshotSubcommand.java | 105 --- .../commandline/snapshot/SnapshotSubcommands.java | 79 --- .../commandline/systemview/SystemViewCommand.java | 278 -------- .../systemview/SystemViewCommandArg.java | 55 -- .../TracingConfigurationArguments.java | 180 ------ .../TracingConfigurationCommandArg.java | 79 --- .../TracingConfigurationSubcommand.java | 104 --- .../commandline/CommandHandlerParsingTest.java | 719 +++++++++++---------- .../GridCommandHandlerSslWithSecurityTest.java | 3 +- .../testsuites/IgniteControlUtilityTestSuite.java | 2 +- .../ignite/util/CacheMetricsCommandTest.java | 43 +- .../org/apache/ignite/util/CdcCommandTest.java | 62 +- .../apache/ignite/util/CdcResendCommandTest.java | 8 +- .../util/GridCommandHandlerAbstractTest.java | 9 +- .../util/GridCommandHandlerBrokenIndexTest.java | 3 +- ...CommandHandlerCheckIncrementalSnapshotTest.java | 10 +- .../util/GridCommandHandlerClusterByClassTest.java | 412 +++++++----- .../GridCommandHandlerConsistencyCountersTest.java | 22 +- ...sistencyRepairCorrectnessTransactionalTest.java | 21 +- .../util/GridCommandHandlerConsistencyTest.java | 22 +- .../GridCommandHandlerIndexForceRebuildTest.java | 2 +- .../util/GridCommandHandlerIndexListTest.java | 6 +- .../GridCommandHandlerIndexingCheckSizeTest.java | 31 +- ...idCommandHandlerIndexingClusterByClassTest.java | 2 +- .../util/GridCommandHandlerMetadataTest.java | 6 +- ...GridCommandHandlerScheduleIndexRebuildTest.java | 2 +- .../apache/ignite/util/GridCommandHandlerTest.java | 193 +++--- ...GridCommandHandlerTracingConfigurationTest.java | 2 +- .../ignite/util/KillCommandsControlShTest.java | 21 +- .../org/apache/ignite/util/MetricCommandTest.java | 82 +-- .../util/PerformanceStatisticsCommandTest.java | 47 +- .../apache/ignite/util/SystemViewCommandTest.java | 73 ++- .../org/apache/ignite/cache/query/IndexQuery.java | 26 + .../ignite/internal/TransactionsMXBeanImpl.java | 54 +- .../ignite/internal/binary/BinaryObjectImpl.java | 5 +- .../client/thin/ProtocolBitmaskFeature.java | 5 +- .../internal/client/thin/TcpClientCache.java | 7 + .../GridNioClientConnectionMultiplexer.java | 7 +- .../CheckIndexInlineSizesTask.java | 11 +- .../cache/distribution/CacheDistributionTask.java | 19 +- .../distribution/CacheDistributionTaskArg.java | 94 --- .../distribution/CacheDistributionTaskResult.java | 50 +- .../CacheResetLostPartitionsTask.java | 49 +- .../CacheResetLostPartitionsTaskArg.java | 72 --- .../CacheResetLostPartitionsTaskResult.java | 8 +- .../commandline/meta/tasks/MetadataInfoTask.java | 35 +- .../commandline/meta/tasks/MetadataRemoveTask.java | 15 +- .../commandline/meta/tasks/MetadataTypeArgs.java | 101 --- .../commandline/meta/tasks/MetadataUpdateTask.java | 14 +- .../commandline/property/PropertyArgs.java | 117 ---- .../property/tasks/PropertiesListTask.java | 11 +- .../commandline/property/tasks/PropertyTask.java | 50 +- .../internal/management/ActivateCommand.java | 55 ++ .../internal/management/ChangeTagCommand.java | 58 ++ .../ChangeTagCommandArg.java} | 49 +- .../internal/management/DeactivateCommand.java | 70 ++ .../DeactivateCommandArg.java} | 64 +- .../internal/management/IgniteCommandRegistry.java | 82 +++ .../internal/management/SetStateCommand.java | 59 ++ .../internal/management/SetStateCommandArg.java | 104 +++ .../internal/management/ShutdownPolicyCommand.java | 50 ++ .../ShutdownPolicyCommandArg.java} | 52 +- .../ignite/internal/management/StateCommand.java | 74 +++ .../internal/management/SystemViewCommand.java | 161 +++++ .../internal/management/SystemViewCommandArg.java | 117 ++++ .../WarmUpCommand.java} | 27 +- .../internal/management/WarmUpStopCommand.java} | 37 +- .../ignite/internal/management/api/Argument.java | 55 ++ .../internal/management/api/ArgumentGroup.java | 43 ++ .../api/BeforeNodeStartCommand.java} | 34 +- .../api/CliConfirmArgument.java} | 16 +- .../api/CliSubcommandsWithPrefix.java} | 19 +- .../ignite/internal/management/api/Command.java | 64 ++ .../management/api/CommandRegistryImpl.java | 88 +++ .../internal/management/api/CommandUtils.java | 558 ++++++++++++++++ .../internal/management/api/CommandsRegistry.java} | 41 +- .../internal/management/api/ComputeCommand.java | 55 ++ .../api/EnumDescription.java} | 19 +- .../api/HelpCommand.java} | 14 +- .../api/LocalCommand.java} | 29 +- .../ignite/internal/management/api/NoArg.java} | 32 +- .../api/Positional.java} | 26 +- .../api/PreparableCommand.java} | 35 +- .../baseline/AbstractBaselineCommand.java | 169 +++++ .../management/baseline/BaselineAddCommand.java} | 31 +- .../baseline/BaselineAddCommandArg.java} | 56 +- .../baseline/BaselineAutoAdjustCommand.java} | 31 +- .../baseline/BaselineAutoAdjustCommandArg.java | 90 +++ .../management/baseline/BaselineCommand.java | 111 ++++ .../baseline/BaselineCommandArg.java} | 23 +- .../baseline/BaselineRemoveCommand.java} | 31 +- .../baseline/BaselineRemoveCommandArg.java} | 24 +- .../management/baseline/BaselineSetCommand.java} | 31 +- .../baseline/BaselineSetCommandArg.java} | 24 +- .../baseline/BaselineVersionCommand.java} | 31 +- .../baseline/BaselineVersionCommandArg.java} | 62 +- .../cache/CacheCheckIndexInlineSizesCommand.java} | 108 ++-- .../management/cache/CacheClearCommand.java | 66 ++ .../cache/CacheClearCommandArg.java} | 40 +- .../internal/management/cache/CacheCommand.java | 57 ++ .../management/cache/CacheContentionCommand.java | 61 ++ .../cache/CacheContentionCommandArg.java} | 68 +- .../management/cache/CacheCreateCommand.java} | 37 +- .../management/cache/CacheCreateCommandArg.java | 90 +++ .../management/cache/CacheDestroyCommand.java | 91 +++ .../cache/CacheDestroyCommandArg.java} | 71 +- .../management/cache/CacheDistributionCommand.java | 62 ++ .../cache/CacheDistributionCommandArg.java | 115 ++++ .../management/cache/CacheFindGarbageCommand.java | 82 +++ .../cache/CacheFindGarbageCommandArg.java | 140 ++++ .../management/cache/CacheIdleVerifyCommand.java | 109 ++++ .../cache/CacheIdleVerifyCommandArg.java | 143 ++++ .../cache/CacheIdleVerifyDumpCommand.java | 47 ++ .../cache/CacheIdleVerifyDumpCommandArg.java} | 18 +- .../cache/CacheIndexesForceRebuildCommand.java | 110 ++++ .../cache/CacheIndexesForceRebuildCommandArg.java} | 66 +- .../management/cache/CacheIndexesListCommand.java | 75 +++ .../cache/CacheIndexesListCommandArg.java | 136 ++++ .../cache/CacheIndexesRebuildStatusCommand.java | 86 +++ .../CacheIndexesRebuildStatusCommandArg.java} | 39 +- .../management/cache/CacheListCommand.java} | 399 +++++------- .../management/cache/CacheListCommandArg.java | 143 ++++ .../management/cache/CacheMetricsCommand.java | 62 ++ .../management/cache/CacheMetricsCommandArg.java | 93 +++ .../cache/CacheResetLostPartitionsCommand.java | 51 ++ .../cache/CacheResetLostPartitionsCommandArg.java} | 42 +- .../management/cache/CacheScanCommand.java | 56 ++ .../cache/CacheScanCommandArg.java} | 76 +-- .../cache/CacheScheduleIndexesRebuildCommand.java | 135 ++++ .../CacheScheduleIndexesRebuildCommandArg.java | 161 +++++ .../cache/CacheValidateIndexesCommand.java | 131 ++++ .../cache/CacheValidateIndexesCommandArg.java | 198 ++++++ .../cdc/CdcCommand.java} | 28 +- .../cdc/CdcDeleteLostSegmentLinksCommand.java | 74 +++ .../cdc/CdcDeleteLostSegmentLinksCommandArg.java} | 39 +- .../internal/management/cdc/CdcResendCommand.java | 51 ++ .../cdc/CdcResendCommandArg.java} | 43 +- .../consistency/ConsistencyCommand.java} | 29 +- .../consistency/ConsistencyFinalizeCommand.java} | 35 +- .../consistency/ConsistencyRepairCommand.java | 120 ++++ .../consistency/ConsistencyRepairCommandArg.java | 115 ++++ .../consistency/ConsistencyStatusCommand.java | 69 ++ .../DefragmentationCancelCommand.java | 53 ++ .../defragmentation/DefragmentationCommand.java | 58 ++ .../DefragmentationScheduleCommand.java | 77 +++ .../DefragmentationScheduleCommandArg.java} | 64 +- .../DefragmentationStatusCommand.java | 52 ++ .../management/diagnostic/DiagnosticCommand.java | 52 ++ .../diagnostic/DiagnosticConnectivityCommand.java} | 120 ++-- .../DiagnosticConnectivityCommandArg.java} | 43 +- .../diagnostic/DiagnosticPagelocksCommand.java | 77 +++ .../diagnostic/DiagnosticPagelocksCommandArg.java | 133 ++++ .../encryption/CacheGroupEncryptionCommand.java | 70 ++ .../encryption/EncryptionCacheGroupArg.java} | 51 +- .../encryption/EncryptionCacheKeyIdsCommand.java | 66 ++ .../EncryptionChangeCacheKeyCommand.java | 51 ++ .../EncryptionChangeMasterKeyCommand.java | 51 ++ .../EncryptionChangeMasterKeyCommandArg.java} | 51 +- .../encryption/EncryptionCommand.java} | 34 +- .../EncryptionGetMasterKeyNameCommand.java} | 35 +- .../EncryptionReencryptionRateLimitCommand.java | 94 +++ ...EncryptionReencryptionRateLimitCommandArg.java} | 53 +- .../EncryptionReencryptionStatusCommand.java | 50 ++ .../EncryptionReencryptionStatusCommandArg.java} | 49 +- .../EncryptionResumeReencryptionCommand.java | 46 ++ .../EncryptionSuspendReencryptionCommand.java | 46 ++ .../management/kill/KillClientCommand.java | 52 ++ .../kill/KillClientCommandArg.java} | 73 +-- .../kill/KillCommand.java} | 35 +- .../management/kill/KillComputeCommand.java} | 32 +- .../kill/KillComputeCommandArg.java} | 53 +- .../management/kill/KillConsistencyCommand.java} | 38 +- .../management/kill/KillContinuousCommand.java} | 32 +- .../kill/KillContinuousCommandArg.java} | 80 +-- .../internal/management/kill/KillScanCommand.java} | 32 +- .../kill/KillScanCommandArg.java} | 99 ++- .../management/kill/KillServiceCommand.java} | 36 +- .../kill/KillServiceCommandArg.java} | 51 +- .../management/kill/KillSnapshotCommand.java} | 34 +- .../kill/KillSnapshotCommandArg.java} | 68 +- .../internal/management/kill/KillSqlCommand.java} | 32 +- .../kill/KillSqlCommandArg.java} | 86 ++- .../management/kill/KillTransactionCommand.java | 51 ++ .../kill/KillTransactionCommandArg.java} | 51 +- .../internal/management/meta/MetaCommand.java} | 53 +- .../management/meta/MetaDetailsCommand.java} | 63 +- .../meta/MetaDetailsCommandArg.java} | 77 +-- .../internal/management/meta/MetaListCommand.java | 65 ++ .../management/meta/MetaRemoveCommand.java | 84 +++ .../meta/MetaRemoveCommandArg.java} | 76 ++- .../management/meta/MetaUpdateCommand.java | 62 ++ .../meta/MetaUpdateCommandArg.java} | 70 +- .../internal/management/metric/MetricCommand.java | 82 +++ .../metric/MetricCommandArg.java} | 55 +- .../metric/MetricConfigureHistogramCommand.java | 50 ++ .../MetricConfigureHistogramCommandArg.java} | 57 +- .../metric/MetricConfigureHitrateCommand.java | 50 ++ .../metric/MetricConfigureHitrateCommandArg.java} | 57 +- .../PerformanceStatisticsCommand.java | 70 ++ .../PerformanceStatisticsRotateCommand.java | 41 ++ .../PerformanceStatisticsStartCommand.java | 41 ++ .../PerformanceStatisticsStatusCommand.java | 41 ++ .../PerformanceStatisticsStopCommand.java} | 34 +- .../persistence/PersistenceAbstractCommand.java | 122 ++++ .../persistence/PersistenceBackupAllCommand.java} | 30 +- .../PersistenceBackupCachesCommand.java} | 28 +- .../PersistenceBackupCachesTaskArg.java} | 53 +- .../persistence/PersistenceBackupCommand.java} | 29 +- .../PersistenceBackupCorruptedCommand.java} | 30 +- .../persistence/PersistenceCleanAllCommand.java} | 30 +- .../PersistenceCleanCachesCommand.java} | 28 +- .../PersistenceCleanCachesTaskArg.java} | 53 +- .../persistence/PersistenceCleanCommand.java} | 29 +- .../PersistenceCleanCorruptedCommand.java} | 30 +- .../management/persistence/PersistenceCommand.java | 108 ++++ .../persistence/PersistenceInfoCommand.java} | 30 +- .../management/property/PropertyCommand.java} | 41 +- .../management/property/PropertyGetCommand.java} | 35 +- .../property/PropertyGetCommandArg.java} | 49 +- .../management/property/PropertyListCommand.java | 48 ++ .../management/property/PropertySetCommand.java} | 33 +- .../property/PropertySetCommandArg.java} | 54 +- .../snapshot/AbstractSnapshotCommand.java} | 43 +- .../snapshot/SnapshotCancelCommand.java} | 32 +- .../snapshot/SnapshotCancelCommandArg.java} | 72 ++- .../management/snapshot/SnapshotCheckCommand.java | 52 ++ .../snapshot/SnapshotCheckCommandArg.java | 94 +++ .../snapshot/SnapshotCommand.java} | 31 +- .../snapshot/SnapshotCreateCommand.java} | 31 +- .../snapshot/SnapshotCreateCommandArg.java | 111 ++++ .../snapshot/SnapshotRestoreCommand.java | 58 ++ .../snapshot/SnapshotRestoreCommandArg.java | 211 ++++++ .../snapshot/SnapshotStatusCommand.java | 76 +-- .../AbstractTracingConfigurationCommand.java | 53 ++ .../tracing/TracingConfigurationCommand.java | 109 ++++ .../TracingConfigurationGetAllCommand.java} | 31 +- .../TracingConfigurationGetAllCommandArg.java} | 56 +- .../tracing/TracingConfigurationGetCommand.java} | 31 +- .../TracingConfigurationGetCommandArg.java} | 59 +- .../TracingConfigurationResetAllCommand.java | 39 ++ .../tracing/TracingConfigurationResetCommand.java} | 36 +- .../tracing/TracingConfigurationSetCommand.java} | 36 +- .../tracing/TracingConfigurationSetCommandArg.java | 82 +++ .../ignite/internal/management/tx/TxCommand.java | 105 +++ .../internal/management/tx/TxCommandArg.java | 222 +++++++ .../internal/management/tx/TxInfoCommand.java | 287 ++++++++ .../internal/management/tx/TxInfoCommandArg.java | 131 ++++ .../wal/WalCommand.java} | 30 +- .../internal/management/wal/WalDeleteCommand.java | 82 +++ .../wal/WalDeleteCommandArg.java} | 53 +- .../internal/management/wal/WalPrintCommand.java | 87 +++ .../internal/managers/IgniteMBeansManager.java | 8 +- .../processors/bulkload/BulkLoadProcessor.java | 4 +- .../internal/processors/cache/ClearCachesTask.java | 11 +- .../processors/cache/IgniteCacheProxyImpl.java | 3 + .../snapshot/SnapshotRestoreProcess.java | 27 +- .../query/GridCacheDistributedQueryFuture.java | 30 + .../query/GridCacheDistributedQueryManager.java | 23 +- .../cache/query/GridCacheQueryRequest.java | 6 +- .../verify/VerifyBackupPartitionsDumpTask.java | 18 +- .../cache/verify/VerifyBackupPartitionsTask.java | 364 ----------- .../cache/verify/VerifyBackupPartitionsTaskV2.java | 14 +- .../PerformanceStatisticsProcessor.java | 20 + .../platform/client/ClientBitmaskFeature.java | 5 +- .../platform/client/ClientMessageParser.java | 2 +- .../client/cache/ClientCacheIndexQueryRequest.java | 15 +- .../processors/query/GridQueryIndexing.java | 10 +- .../processors/query/GridQueryProcessor.java | 4 +- .../internal/processors/query/NoOpQueryEngine.java | 12 - .../internal/processors/query/QueryEngine.java | 8 - .../query/{ => running}/GridRunningQueryInfo.java | 26 +- .../query/running/HeavyQueriesTracker.java} | 108 +++- .../query/{ => running}/QueryHistory.java | 2 +- .../query/{ => running}/QueryHistoryKey.java | 2 +- .../{ => running}/QueryHistoryMetricsValue.java | 2 +- .../query/{ => running}/QueryHistoryTracker.java | 2 +- .../query/{ => running}/QueryRunningFuture.java | 2 +- .../query/{ => running}/RunningQueryManager.java | 46 +- .../processors/query/running}/SqlQueryMXBean.java | 2 +- .../query/running}/SqlQueryMXBeanImpl.java | 23 +- .../TrackableQuery.java} | 19 +- .../apache/ignite/internal/util/GridUnsafe.java | 10 +- .../apache/ignite/internal/util/IgniteUtils.java | 53 ++ .../visor/baseline/VisorBaselineOperation.java | 51 -- .../internal/visor/baseline/VisorBaselineTask.java | 47 +- .../visor/baseline/VisorBaselineTaskArg.java | 126 ---- .../internal/visor/cache/VisorCacheCreateTask.java | 18 +- .../internal/visor/cache/VisorCacheScanTask.java | 19 +- .../internal/visor/cache/VisorCacheStopTask.java | 18 +- .../visor/cache/VisorCacheStopTaskArg.java | 99 --- ...orFindAndDeleteGarbageInPersistenceClosure.java | 4 +- ...VisorFindAndDeleteGarbageInPersistenceTask.java | 23 +- ...orFindAndDeleteGarbageInPersistenceTaskArg.java | 101 --- .../visor/cache/index/IndexForceRebuildTask.java | 16 +- .../internal/visor/cache/index/IndexListTask.java | 19 +- .../visor/cache/index/IndexListTaskArg.java | 94 --- .../visor/cache/index/IndexRebuildStatusTask.java | 13 +- .../cache/index/ScheduleIndexRebuildTask.java | 19 +- .../cache/index/ScheduleIndexRebuildTaskArg.java | 84 --- .../visor/cache/metrics/VisorCacheMetricsTask.java | 15 +- .../cache/metrics/VisorCacheMetricsTaskArg.java | 84 --- .../visor/cdc/VisorCdcCacheDataResendTask.java | 13 +- .../visor/cdc/VisorCdcDeleteLostSegmentsTask.java | 12 +- .../client/VisorClientConnectionDropTask.java | 18 +- .../compute/VisorComputeCancelSessionTask.java | 13 +- .../consistency/VisorConsistencyCancelTask.java | 11 +- .../VisorConsistencyCountersFinalizationTask.java | 11 +- .../consistency/VisorConsistencyRepairTask.java | 21 +- .../consistency/VisorConsistencyRepairTaskArg.java | 97 --- .../consistency/VisorConsistencyStatusTask.java | 11 +- .../defragmentation/VisorDefragmentationTask.java | 43 +- .../internal/visor/diagnostic/Operation.java | 2 +- .../visor/diagnostic/VisorPageLocksTask.java | 40 +- .../availability/VisorConnectivityArgs.java | 68 -- .../availability/VisorConnectivityTask.java | 21 +- .../encryption/VisorCacheGroupEncryptionTask.java | 13 +- .../VisorCacheGroupEncryptionTaskArg.java | 68 -- .../encryption/VisorChangeCacheGroupKeyTask.java | 13 +- .../visor/encryption/VisorChangeMasterKeyTask.java | 13 +- .../encryption/VisorEncryptionKeyIdsTask.java | 7 +- .../encryption/VisorGetMasterKeyNameTask.java | 11 +- .../encryption/VisorReencryptionRateTask.java | 17 +- .../encryption/VisorReencryptionRateTaskArg.java | 74 --- .../encryption/VisorReencryptionResumeTask.java | 7 +- .../encryption/VisorReencryptionStatusTask.java | 7 +- .../encryption/VisorReencryptionSuspendTask.java | 7 +- .../internal/visor/metric/VisorMetricTask.java | 22 +- .../internal/visor/metric/VisorMetricTaskArg.java | 94 --- .../visor/misc/VisorClusterChangeTagTask.java | 16 +- .../ignite/internal/visor/misc/VisorWalTask.java | 34 +- .../internal/visor/misc/VisorWalTaskArg.java | 98 --- .../VisorPerformanceStatisticsTask.java | 49 +- .../VisorPerformanceStatisticsTaskArg.java | 64 -- .../visor/persistence/PersistenceTask.java | 75 +-- .../visor/persistence/PersistenceTaskArg.java | 82 --- .../query/VisorContinuousQueryCancelTask.java | 18 +- .../query/VisorQueryCancelOnInitiatorTask.java | 13 +- .../visor/query/VisorScanQueryCancelTask.java | 14 +- .../visor/service/VisorCancelServiceTask.java | 13 +- .../visor/shutdown/VisorShutdownPolicyTask.java | 17 +- .../visor/shutdown/VisorShutdownPolicyTaskArg.java | 76 --- .../visor/snapshot/VisorSnapshotCancelTask.java | 21 +- .../visor/snapshot/VisorSnapshotCancelTaskArg.java | 85 --- .../visor/snapshot/VisorSnapshotCheckTask.java | 13 +- .../visor/snapshot/VisorSnapshotCheckTaskArg.java | 92 --- .../visor/snapshot/VisorSnapshotCreateTask.java | 15 +- .../visor/snapshot/VisorSnapshotCreateTaskArg.java | 115 ---- .../visor/snapshot/VisorSnapshotRestoreTask.java | 53 +- .../snapshot/VisorSnapshotRestoreTaskAction.java | 46 -- .../snapshot/VisorSnapshotRestoreTaskArg.java | 120 ---- .../visor/snapshot/VisorSnapshotStatusTask.java | 13 +- .../visor/systemview/VisorSystemViewTask.java | 14 +- .../VisorTracingConfigurationOperation.java | 56 -- .../VisorTracingConfigurationTask.java | 58 +- .../VisorTracingConfigurationTaskArg.java | 103 --- .../internal/visor/tx/FetchNearXidVersionTask.java | 13 +- .../internal/visor/tx/KillTransactionTask.java | 71 ++ .../ignite/internal/visor/tx/VisorTxOperation.java | 45 -- .../ignite/internal/visor/tx/VisorTxTask.java | 128 ++-- .../ignite/internal/visor/tx/VisorTxTaskArg.java | 244 ------- .../internal/visor/verify/VisorContentionTask.java | 11 +- .../visor/verify/VisorContentionTaskArg.java | 84 --- .../visor/verify/VisorIdleVerifyDumpTask.java | 5 +- .../visor/verify/VisorIdleVerifyDumpTaskArg.java | 124 ---- .../internal/visor/verify/VisorIdleVerifyJob.java | 12 +- .../internal/visor/verify/VisorIdleVerifyTask.java | 111 ---- .../visor/verify/VisorIdleVerifyTaskArg.java | 220 ------- .../visor/verify/VisorIdleVerifyTaskResult.java | 76 --- .../visor/verify/VisorIdleVerifyTaskV2.java | 5 +- .../visor/verify/VisorValidateIndexesTask.java | 29 +- .../visor/verify/VisorValidateIndexesTaskArg.java | 158 ----- .../internal/visor/verify/VisorViewCacheTask.java | 22 +- .../visor/verify/VisorViewCacheTaskArg.java | 85 --- .../org/apache/ignite/lang/IgniteExperimental.java | 3 + .../ignite/spi/metric/MetricExporterSpi.java | 1 + .../ignite/spi/metric/RegexpMetricFilter.java} | 44 +- .../spi/systemview/view/SqlQueryHistoryView.java | 2 +- .../ignite/spi/systemview/view/SqlQueryView.java | 2 +- .../main/resources/META-INF/classnames.properties | 210 +++--- ...inaryConfigurationCustomSerializerSelfTest.java | 8 +- .../management/api/CommandUtilsSelfTest.java | 67 ++ ...tractCommunicationMessageSerializationTest.java | 601 +++++++++++++++++ ...iteIoCommunicationMessageSerializationTest.java | 91 +++ .../MaintenancePersistenceTaskTest.java | 23 +- .../snapshot/IgniteClusterSnapshotCheckTest.java | 18 +- .../IncrementalSnapshotRestoreTest.java | 12 +- .../cache/transactions/TxRollbackAsyncTest.java | 9 +- .../processors/query/DummyQueryIndexing.java | 7 +- .../junits/common/GridCommonAbstractTest.java | 6 +- .../ignite/testsuites/IgniteCacheTestSuite10.java | 2 + .../ignite/testsuites/IgniteUtilSelfTestSuite.java | 4 +- .../GridInternalTaskUnusedWalSegmentsTest.java | 12 +- ...mandHandlerClusterByClassTest_cache_help.output | 113 ++-- ...ridCommandHandlerClusterByClassTest_help.output | 159 +++-- ...dlerClusterByClassWithSSLTest_cache_help.output | 113 ++-- ...andHandlerClusterByClassWithSSLTest_help.output | 159 +++-- .../commandline/CommandsProviderExtImpl.java | 81 ++- .../commandline/ExtendedControlUtilityTest.java | 38 +- modules/indexing/pom.xml | 7 + .../query/h2/H2QueryFetchSizeInterceptor.java | 92 --- .../internal/processors/query/h2/H2QueryInfo.java | 22 +- .../processors/query/h2/H2ResultSetIterator.java | 13 +- .../processors/query/h2/IgniteH2Indexing.java | 43 +- .../processors/query/h2/RegisteredQueryCursor.java | 5 +- .../query/h2/twostep/GridMapQueryExecutor.java | 2 +- .../query/h2/twostep/GridReduceQueryExecutor.java | 5 +- .../query/h2/twostep/MapQueryResult.java | 10 +- .../query/h2/twostep/msg/GridH2QueryRequest.java | 3 +- .../ignite/cache/query/IndexQueryLimitTest.java | 233 +++++++ .../ignite/cache/query/IndexQueryTestSuite.java | 3 +- .../cache/query/ThinClientIndexQueryTest.java | 65 ++ .../metric/SqlStatisticsUserQueriesFastTest.java | 2 +- .../metric/SqlStatisticsUserQueriesLongTest.java | 2 +- .../internal/metric/UserQueriesTestBase.java | 4 +- .../cache/CacheSqlQueryValueCopySelfTest.java | 2 +- .../db/IgniteCacheGroupsWithRestartsTest.java | 11 +- .../db/LongDestroyDurableBackgroundTaskTest.java | 16 +- .../PerformanceStatisticsQueryTest.java | 19 + .../IgniteSqlSkipReducerOnUpdateDmlSelfTest.java | 1 + .../query/KillQueryErrorOnCancelTest.java | 1 + .../query/KillQueryOnClientDisconnectTest.java | 1 + .../internal/processors/query/KillQueryTest.java | 1 + .../processors/query/LongRunningQueryTest.java | 22 +- .../processors/query/RunningQueriesTest.java | 1 + .../processors/query/SqlQueryHistorySelfTest.java | 1 + .../processors/query/h2/GridIndexRebuildTest.java | 22 +- .../systemview/SystemViewSecurityTest.java | 2 +- .../H2CommunicationMessageSerializationTest.java} | 29 +- .../IgniteBinaryCacheQueryTestSuite3.java | 2 + .../test/config/metric/regexp-filter-config.xml | 64 ++ .../internal/metric/RegexpMetricFilterTest.java | 63 ++ .../ignite/testsuites/IgniteSpringTestSuite.java | 3 + 577 files changed, 16924 insertions(+), 24249 deletions(-) copy modules/{core/src/main/java/org/apache/ignite/internal/processors/query => calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite}/QueryState.java (94%) copy modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/{QueryPlan.java => AbstractQueryPlan.java} (74%) create mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/TimeCalculationExecutionTest.java copy modules/{core/src/main/java/org/apache/ignite/internal/processors/query/QueryState.java => calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/message/CalciteCommunicationMessageSerializationTest.java} (62%) delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/AbstractCommand.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/ActivateCommand.java create mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/ArgumentParser.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/BaselineCommand.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/ClusterChangeTagCommand.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/ClusterStateChangeCommand.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/Command.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/CommandArgIterator.java create mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/CommandInvoker.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/CommandList.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/CommonArgParser.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/DeactivateCommand.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/DefragmentationCommand.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/OutputFormat.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/PersistenceCommand.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/ShutdownPolicyCommand.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/StateCommand.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/StringBuilderOutputStream.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/TaskExecutor.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/TracingConfigurationCommand.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/TxCommandArg.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/TxCommands.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/WalCommands.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/WarmUpCommand.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/argument/CommandArg.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/argument/CommandArgUtils.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/baseline/BaselineArguments.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/baseline/BaselineSubcommands.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/cache/CacheClear.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/cache/CacheCommands.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/cache/CacheContention.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/cache/CacheCreate.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/cache/CacheDestroy.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/cache/CacheDistribution.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/cache/CacheIndexesForceRebuild.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/cache/CacheIndexesList.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/cache/CacheIndexesRebuildStatus.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/cache/CacheMetrics.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/cache/CacheScan.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/cache/CacheScheduleIndexesRebuild.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/cache/CacheSubcommands.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/cache/CacheValidateIndexes.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/cache/FindAndDeleteGarbage.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/cache/IdleVerify.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/cache/ResetLostPartitions.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/cache/argument/DistributionCommandArg.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/cache/argument/FindAndDeleteGarbageArg.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/cache/argument/IdleVerifyCommandArg.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/cache/argument/IndexRebuildCommandArg.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/cache/argument/ListCommandArg.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/cache/argument/ValidateIndexesCommandArg.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/cdc/CdcCommand.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/cdc/CdcSubcommands.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/cdc/DeleteLostSegmentLinksCommand.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/cdc/ResendCommand.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/consistency/ConsistencyCommand.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/consistency/ConsistencySubCommand.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/defragmentation/DefragmentationArguments.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/defragmentation/DefragmentationSubcommands.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/diagnostic/DiagnosticCommand.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/diagnostic/DiagnosticSubCommand.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/diagnostic/PageLocksCommand.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/encryption/CacheGroupEncryptionCommand.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/encryption/ChangeCacheGroupKeyCommand.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/encryption/ChangeMasterKeyCommand.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/encryption/EncryptionCommands.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/encryption/EncryptionSubcommands.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/encryption/GetMasterKeyNameCommand.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/encryption/ReencryptionRateCommand.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/meta/MetadataCommand.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/meta/MetadataSubCommandsList.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/meta/subcommands/MetadataAbstractSubCommand.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/meta/subcommands/MetadataHelpCommand.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/meta/subcommands/MetadataListCommand.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/meta/subcommands/MetadataRemoveCommand.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/meta/subcommands/MetadataUpdateCommand.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/metric/MetricCommand.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/metric/MetricCommandArg.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/performancestatistics/PerformanceStatisticsCommand.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/performancestatistics/PerformanceStatisticsSubCommand.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/persistence/CleanAndBackupSubcommandArg.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/persistence/PersistenceArguments.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/persistence/PersistenceSubcommands.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/property/PropertyCommand.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/property/PropertySubCommandsList.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/property/subcommands/PropertyAbstractSubCommand.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/property/subcommands/PropertyGetCommand.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/property/subcommands/PropertyHelpCommand.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/property/subcommands/PropertyListCommand.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/property/subcommands/PropertySetCommand.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/query/KillCommand.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/query/KillSubcommand.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/shutdown/ShutdownPolicyArgument.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/snapshot/SnapshotCancelCommand.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/snapshot/SnapshotCancelCommandOption.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/snapshot/SnapshotCheckCommand.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/snapshot/SnapshotCheckCommandOption.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/snapshot/SnapshotCommand.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/snapshot/SnapshotCreateCommand.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/snapshot/SnapshotCreateCommandOption.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/snapshot/SnapshotRestoreCommand.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/snapshot/SnapshotRestoreCommandOption.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/snapshot/SnapshotSubcommand.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/snapshot/SnapshotSubcommands.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/systemview/SystemViewCommand.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/systemview/SystemViewCommandArg.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/tracing/configuration/TracingConfigurationArguments.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/tracing/configuration/TracingConfigurationCommandArg.java delete mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/tracing/configuration/TracingConfigurationSubcommand.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/commandline/cache/distribution/CacheDistributionTaskArg.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/commandline/cache/reset_lost_partitions/CacheResetLostPartitionsTaskArg.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/commandline/meta/tasks/MetadataTypeArgs.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/commandline/property/PropertyArgs.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/ActivateCommand.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/ChangeTagCommand.java rename modules/core/src/main/java/org/apache/ignite/internal/{visor/systemview/VisorSystemViewTaskArg.java => management/ChangeTagCommandArg.java} (59%) create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/DeactivateCommand.java copy modules/core/src/main/java/org/apache/ignite/internal/{visor/cache/index/IndexRebuildStatusTaskArg.java => management/DeactivateCommandArg.java} (59%) create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/IgniteCommandRegistry.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/SetStateCommand.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/SetStateCommandArg.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/ShutdownPolicyCommand.java copy modules/core/src/main/java/org/apache/ignite/internal/{visor/cache/index/IndexRebuildStatusTaskArg.java => management/ShutdownPolicyCommandArg.java} (60%) create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/StateCommand.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/SystemViewCommand.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/SystemViewCommandArg.java copy modules/core/src/main/java/org/apache/ignite/internal/{processors/query/QueryState.java => management/WarmUpCommand.java} (68%) copy modules/{calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/DdlPlan.java => core/src/main/java/org/apache/ignite/internal/management/WarmUpStopCommand.java} (52%) create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/api/Argument.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/api/ArgumentGroup.java rename modules/core/src/main/java/org/apache/ignite/internal/{visor/persistence/PersistenceOperation.java => management/api/BeforeNodeStartCommand.java} (55%) copy modules/core/src/main/java/org/apache/ignite/internal/{processors/query/QueryRunningFuture.java => management/api/CliConfirmArgument.java} (63%) copy modules/core/src/main/java/org/apache/ignite/internal/{processors/query/QueryRunningFuture.java => management/api/CliSubcommandsWithPrefix.java} (55%) create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/api/Command.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/api/CommandRegistryImpl.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/api/CommandUtils.java copy modules/{control-utility/src/main/java/org/apache/ignite/internal/commandline/cache/argument/IndexForceRebuildCommandArg.java => core/src/main/java/org/apache/ignite/internal/management/api/CommandsRegistry.java} (54%) create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/api/ComputeCommand.java copy modules/core/src/main/java/org/apache/ignite/internal/{processors/query/QueryRunningFuture.java => management/api/EnumDescription.java} (60%) copy modules/core/src/main/java/org/apache/ignite/internal/{visor/diagnostic/Operation.java => management/api/HelpCommand.java} (72%) rename modules/core/src/main/java/org/apache/ignite/internal/{visor/tx/VisorTxProjection.java => management/api/LocalCommand.java} (57%) copy modules/{control-utility/src/main/java/org/apache/ignite/internal/commandline/cache/argument/IndexRebuildStatusArg.java => core/src/main/java/org/apache/ignite/internal/management/api/NoArg.java} (58%) copy modules/core/src/main/java/org/apache/ignite/internal/{processors/query/RunningQuery.java => management/api/Positional.java} (53%) rename modules/core/src/main/java/org/apache/ignite/internal/{visor/misc/VisorWalTaskOperation.java => management/api/PreparableCommand.java} (50%) create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/baseline/AbstractBaselineCommand.java copy modules/{calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/DdlPlan.java => core/src/main/java/org/apache/ignite/internal/management/baseline/BaselineAddCommand.java} (60%) copy modules/core/src/main/java/org/apache/ignite/internal/{processors/cache/ClearCachesTaskArg.java => management/baseline/BaselineAddCommandArg.java} (56%) copy modules/{calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/DdlPlan.java => core/src/main/java/org/apache/ignite/internal/management/baseline/BaselineAutoAdjustCommand.java} (60%) create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/baseline/BaselineAutoAdjustCommandArg.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/baseline/BaselineCommand.java copy modules/core/src/main/java/org/apache/ignite/internal/{processors/query/QueryState.java => management/baseline/BaselineCommandArg.java} (75%) copy modules/{calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/DdlPlan.java => core/src/main/java/org/apache/ignite/internal/management/baseline/BaselineRemoveCommand.java} (60%) copy modules/core/src/main/java/org/apache/ignite/internal/{processors/query/QueryState.java => management/baseline/BaselineRemoveCommandArg.java} (75%) copy modules/{calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/DdlPlan.java => core/src/main/java/org/apache/ignite/internal/management/baseline/BaselineSetCommand.java} (60%) copy modules/core/src/main/java/org/apache/ignite/internal/{processors/query/QueryState.java => management/baseline/BaselineSetCommandArg.java} (75%) copy modules/{calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/DdlPlan.java => core/src/main/java/org/apache/ignite/internal/management/baseline/BaselineVersionCommand.java} (60%) copy modules/core/src/main/java/org/apache/ignite/internal/{visor/cache/index/IndexRebuildStatusTaskArg.java => management/baseline/BaselineVersionCommandArg.java} (55%) rename modules/{control-utility/src/main/java/org/apache/ignite/internal/commandline/cache/CheckIndexInlineSizes.java => core/src/main/java/org/apache/ignite/internal/management/cache/CacheCheckIndexInlineSizesCommand.java} (53%) create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/cache/CacheClearCommand.java copy modules/core/src/main/java/org/apache/ignite/internal/{visor/cdc/VisorCdcCacheDataResendTaskArg.java => management/cache/CacheClearCommandArg.java} (63%) create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/cache/CacheCommand.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/cache/CacheContentionCommand.java copy modules/core/src/main/java/org/apache/ignite/internal/{visor/cache/index/IndexRebuildStatusTaskArg.java => management/cache/CacheContentionCommandArg.java} (59%) copy modules/{calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/DdlPlan.java => core/src/main/java/org/apache/ignite/internal/management/cache/CacheCreateCommand.java} (53%) create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/cache/CacheCreateCommandArg.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/cache/CacheDestroyCommand.java rename modules/core/src/main/java/org/apache/ignite/internal/{visor/diagnostic/VisorPageLocksTrackerArgs.java => management/cache/CacheDestroyCommandArg.java} (54%) create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/cache/CacheDistributionCommand.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/cache/CacheDistributionCommandArg.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/cache/CacheFindGarbageCommand.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/cache/CacheFindGarbageCommandArg.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/cache/CacheIdleVerifyCommand.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/cache/CacheIdleVerifyCommandArg.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/cache/CacheIdleVerifyDumpCommand.java copy modules/core/src/main/java/org/apache/ignite/internal/{processors/query/RunningQuery.java => management/cache/CacheIdleVerifyDumpCommandArg.java} (80%) create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/cache/CacheIndexesForceRebuildCommand.java copy modules/core/src/main/java/org/apache/ignite/internal/{visor/cache/index/IndexRebuildStatusTaskArg.java => management/cache/CacheIndexesForceRebuildCommandArg.java} (51%) create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/cache/CacheIndexesListCommand.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/cache/CacheIndexesListCommandArg.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/cache/CacheIndexesRebuildStatusCommand.java copy modules/core/src/main/java/org/apache/ignite/internal/{visor/cache/index/IndexRebuildStatusTaskArg.java => management/cache/CacheIndexesRebuildStatusCommandArg.java} (71%) rename modules/{control-utility/src/main/java/org/apache/ignite/internal/commandline/cache/CacheViewer.java => core/src/main/java/org/apache/ignite/internal/management/cache/CacheListCommand.java} (57%) create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/cache/CacheListCommandArg.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/cache/CacheMetricsCommand.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/cache/CacheMetricsCommandArg.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/cache/CacheResetLostPartitionsCommand.java copy modules/core/src/main/java/org/apache/ignite/internal/{visor/cdc/VisorCdcCacheDataResendTaskArg.java => management/cache/CacheResetLostPartitionsCommandArg.java} (61%) create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/cache/CacheScanCommand.java copy modules/core/src/main/java/org/apache/ignite/internal/{visor/cache/VisorCacheScanTaskArg.java => management/cache/CacheScanCommandArg.java} (64%) create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/cache/CacheScheduleIndexesRebuildCommand.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/cache/CacheScheduleIndexesRebuildCommandArg.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/cache/CacheValidateIndexesCommand.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/cache/CacheValidateIndexesCommandArg.java copy modules/core/src/main/java/org/apache/ignite/internal/{processors/query/QueryState.java => management/cdc/CdcCommand.java} (70%) create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/cdc/CdcDeleteLostSegmentLinksCommand.java copy modules/core/src/main/java/org/apache/ignite/internal/{visor/cache/index/IndexRebuildStatusTaskArg.java => management/cdc/CdcDeleteLostSegmentLinksCommandArg.java} (71%) create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/cdc/CdcResendCommand.java rename modules/core/src/main/java/org/apache/ignite/internal/{visor/cdc/VisorCdcCacheDataResendTaskArg.java => management/cdc/CdcResendCommandArg.java} (62%) copy modules/core/src/main/java/org/apache/ignite/internal/{processors/query/QueryState.java => management/consistency/ConsistencyCommand.java} (65%) copy modules/{calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/DdlPlan.java => core/src/main/java/org/apache/ignite/internal/management/consistency/ConsistencyFinalizeCommand.java} (55%) create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/consistency/ConsistencyRepairCommand.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/consistency/ConsistencyRepairCommandArg.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/consistency/ConsistencyStatusCommand.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/defragmentation/DefragmentationCancelCommand.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/defragmentation/DefragmentationCommand.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/defragmentation/DefragmentationScheduleCommand.java rename modules/core/src/main/java/org/apache/ignite/internal/{visor/defragmentation/VisorDefragmentationTaskArg.java => management/defragmentation/DefragmentationScheduleCommandArg.java} (54%) create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/defragmentation/DefragmentationStatusCommand.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/diagnostic/DiagnosticCommand.java rename modules/{control-utility/src/main/java/org/apache/ignite/internal/commandline/diagnostic/ConnectivityCommand.java => core/src/main/java/org/apache/ignite/internal/management/diagnostic/DiagnosticConnectivityCommand.java} (54%) rename modules/core/src/main/java/org/apache/ignite/internal/{visor/misc/VisorClusterChangeTagTaskArg.java => management/diagnostic/DiagnosticConnectivityCommandArg.java} (61%) create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/diagnostic/DiagnosticPagelocksCommand.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/diagnostic/DiagnosticPagelocksCommandArg.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/encryption/CacheGroupEncryptionCommand.java copy modules/core/src/main/java/org/apache/ignite/internal/{visor/cache/index/IndexRebuildStatusTaskArg.java => management/encryption/EncryptionCacheGroupArg.java} (60%) create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/encryption/EncryptionCacheKeyIdsCommand.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/encryption/EncryptionChangeCacheKeyCommand.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/encryption/EncryptionChangeMasterKeyCommand.java copy modules/core/src/main/java/org/apache/ignite/internal/{visor/cache/index/IndexRebuildStatusTaskArg.java => management/encryption/EncryptionChangeMasterKeyCommandArg.java} (60%) copy modules/core/src/main/java/org/apache/ignite/internal/{visor/persistence/PersistenceCleanAndBackupType.java => management/encryption/EncryptionCommand.java} (53%) copy modules/{calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/DdlPlan.java => core/src/main/java/org/apache/ignite/internal/management/encryption/EncryptionGetMasterKeyNameCommand.java} (53%) create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/encryption/EncryptionReencryptionRateLimitCommand.java copy modules/core/src/main/java/org/apache/ignite/internal/{visor/cache/index/IndexRebuildStatusTaskArg.java => management/encryption/EncryptionReencryptionRateLimitCommandArg.java} (58%) create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/encryption/EncryptionReencryptionStatusCommand.java copy modules/core/src/main/java/org/apache/ignite/internal/{visor/cache/index/IndexRebuildStatusTaskArg.java => management/encryption/EncryptionReencryptionStatusCommandArg.java} (60%) create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/encryption/EncryptionResumeReencryptionCommand.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/encryption/EncryptionSuspendReencryptionCommand.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/kill/KillClientCommand.java copy modules/core/src/main/java/org/apache/ignite/internal/{visor/query/VisorQueryCancelOnInitiatorTaskArg.java => management/kill/KillClientCommandArg.java} (58%) rename modules/core/src/main/java/org/apache/ignite/internal/{visor/persistence/PersistenceCleanAndBackupType.java => management/kill/KillCommand.java} (58%) copy modules/{calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/DdlPlan.java => core/src/main/java/org/apache/ignite/internal/management/kill/KillComputeCommand.java} (59%) copy modules/core/src/main/java/org/apache/ignite/internal/{visor/cache/index/IndexRebuildStatusTaskArg.java => management/kill/KillComputeCommandArg.java} (60%) copy modules/{calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/DdlPlan.java => core/src/main/java/org/apache/ignite/internal/management/kill/KillConsistencyCommand.java} (50%) copy modules/{calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/DdlPlan.java => core/src/main/java/org/apache/ignite/internal/management/kill/KillContinuousCommand.java} (59%) rename modules/core/src/main/java/org/apache/ignite/internal/{visor/query/VisorContinuousQueryCancelTaskArg.java => management/kill/KillContinuousCommandArg.java} (57%) copy modules/{calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/DdlPlan.java => core/src/main/java/org/apache/ignite/internal/management/kill/KillScanCommand.java} (60%) rename modules/core/src/main/java/org/apache/ignite/internal/{visor/query/VisorScanQueryCancelTaskArg.java => management/kill/KillScanCommandArg.java} (57%) rename modules/{control-utility/src/main/java/org/apache/ignite/internal/commandline/baseline/AutoAdjustCommandArg.java => core/src/main/java/org/apache/ignite/internal/management/kill/KillServiceCommand.java} (56%) copy modules/core/src/main/java/org/apache/ignite/internal/{visor/service/VisorCancelServiceTaskArg.java => management/kill/KillServiceCommandArg.java} (63%) copy modules/{calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/DdlPlan.java => core/src/main/java/org/apache/ignite/internal/management/kill/KillSnapshotCommand.java} (53%) rename modules/core/src/main/java/org/apache/ignite/internal/{visor/compute/VisorComputeCancelSessionTaskArg.java => management/kill/KillSnapshotCommandArg.java} (54%) copy modules/{calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/DdlPlan.java => core/src/main/java/org/apache/ignite/internal/management/kill/KillSqlCommand.java} (60%) rename modules/core/src/main/java/org/apache/ignite/internal/{visor/query/VisorQueryCancelOnInitiatorTaskArg.java => management/kill/KillSqlCommandArg.java} (55%) create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/kill/KillTransactionCommand.java copy modules/core/src/main/java/org/apache/ignite/internal/{visor/cache/index/IndexRebuildStatusTaskArg.java => management/kill/KillTransactionCommandArg.java} (61%) rename modules/{control-utility/src/main/java/org/apache/ignite/internal/commandline/cache/argument/IndexListCommandArg.java => core/src/main/java/org/apache/ignite/internal/management/meta/MetaCommand.java} (52%) rename modules/{control-utility/src/main/java/org/apache/ignite/internal/commandline/meta/subcommands/MetadataDetailsCommand.java => core/src/main/java/org/apache/ignite/internal/management/meta/MetaDetailsCommand.java} (53%) rename modules/core/src/main/java/org/apache/ignite/internal/{visor/cache/VisorCacheScanTaskArg.java => management/meta/MetaDetailsCommandArg.java} (54%) create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/meta/MetaListCommand.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/meta/MetaRemoveCommand.java rename modules/core/src/main/java/org/apache/ignite/internal/{visor/cache/index/IndexForceRebuildTaskArg.java => management/meta/MetaRemoveCommandArg.java} (50%) create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/meta/MetaUpdateCommand.java copy modules/core/src/main/java/org/apache/ignite/internal/{visor/persistence/PersistenceCleanAndBackupSettings.java => management/meta/MetaUpdateCommandArg.java} (50%) create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/metric/MetricCommand.java copy modules/core/src/main/java/org/apache/ignite/internal/{visor/persistence/PersistenceCleanAndBackupSettings.java => management/metric/MetricCommandArg.java} (59%) create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/metric/MetricConfigureHistogramCommand.java copy modules/core/src/main/java/org/apache/ignite/internal/{processors/cache/ClearCachesTaskArg.java => management/metric/MetricConfigureHistogramCommandArg.java} (56%) create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/metric/MetricConfigureHitrateCommand.java copy modules/core/src/main/java/org/apache/ignite/internal/{visor/cache/index/IndexRebuildStatusTaskArg.java => management/metric/MetricConfigureHitrateCommandArg.java} (55%) create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/performancestatistics/PerformanceStatisticsCommand.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/performancestatistics/PerformanceStatisticsRotateCommand.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/performancestatistics/PerformanceStatisticsStartCommand.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/performancestatistics/PerformanceStatisticsStatusCommand.java copy modules/{calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/DdlPlan.java => core/src/main/java/org/apache/ignite/internal/management/performancestatistics/PerformanceStatisticsStopCommand.java} (50%) create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/persistence/PersistenceAbstractCommand.java copy modules/core/src/main/java/org/apache/ignite/internal/{processors/query/QueryState.java => management/persistence/PersistenceBackupAllCommand.java} (61%) copy modules/core/src/main/java/org/apache/ignite/internal/{processors/query/QueryState.java => management/persistence/PersistenceBackupCachesCommand.java} (65%) copy modules/core/src/main/java/org/apache/ignite/internal/{processors/cache/ClearCachesTaskArg.java => management/persistence/PersistenceBackupCachesTaskArg.java} (59%) copy modules/core/src/main/java/org/apache/ignite/internal/{processors/query/QueryState.java => management/persistence/PersistenceBackupCommand.java} (66%) copy modules/core/src/main/java/org/apache/ignite/internal/{processors/query/QueryState.java => management/persistence/PersistenceBackupCorruptedCommand.java} (59%) copy modules/core/src/main/java/org/apache/ignite/internal/{processors/query/QueryState.java => management/persistence/PersistenceCleanAllCommand.java} (61%) copy modules/core/src/main/java/org/apache/ignite/internal/{processors/query/QueryState.java => management/persistence/PersistenceCleanCachesCommand.java} (65%) rename modules/core/src/main/java/org/apache/ignite/internal/{processors/cache/ClearCachesTaskArg.java => management/persistence/PersistenceCleanCachesTaskArg.java} (59%) copy modules/core/src/main/java/org/apache/ignite/internal/{processors/query/QueryState.java => management/persistence/PersistenceCleanCommand.java} (66%) copy modules/core/src/main/java/org/apache/ignite/internal/{processors/query/QueryState.java => management/persistence/PersistenceCleanCorruptedCommand.java} (59%) create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/persistence/PersistenceCommand.java copy modules/core/src/main/java/org/apache/ignite/internal/{processors/query/QueryState.java => management/persistence/PersistenceInfoCommand.java} (60%) rename modules/{control-utility/src/main/java/org/apache/ignite/internal/commandline/cache/argument/IndexRebuildStatusArg.java => core/src/main/java/org/apache/ignite/internal/management/property/PropertyCommand.java} (54%) copy modules/{calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/DdlPlan.java => core/src/main/java/org/apache/ignite/internal/management/property/PropertyGetCommand.java} (50%) copy modules/core/src/main/java/org/apache/ignite/internal/{visor/service/VisorCancelServiceTaskArg.java => management/property/PropertyGetCommandArg.java} (63%) create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/property/PropertyListCommand.java copy modules/{calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/DdlPlan.java => core/src/main/java/org/apache/ignite/internal/management/property/PropertySetCommand.java} (57%) copy modules/core/src/main/java/org/apache/ignite/internal/{visor/cache/index/IndexRebuildStatusTaskArg.java => management/property/PropertySetCommandArg.java} (58%) copy modules/{calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/DdlPlan.java => core/src/main/java/org/apache/ignite/internal/management/snapshot/AbstractSnapshotCommand.java} (53%) copy modules/{calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/DdlPlan.java => core/src/main/java/org/apache/ignite/internal/management/snapshot/SnapshotCancelCommand.java} (59%) rename modules/core/src/main/java/org/apache/ignite/internal/{visor/service/VisorCancelServiceTaskArg.java => management/snapshot/SnapshotCancelCommandArg.java} (56%) create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/snapshot/SnapshotCheckCommand.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/snapshot/SnapshotCheckCommandArg.java copy modules/core/src/main/java/org/apache/ignite/internal/{processors/query/QueryState.java => management/snapshot/SnapshotCommand.java} (63%) copy modules/{calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/DdlPlan.java => core/src/main/java/org/apache/ignite/internal/management/snapshot/SnapshotCreateCommand.java} (60%) create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/snapshot/SnapshotCreateCommandArg.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/snapshot/SnapshotRestoreCommand.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/snapshot/SnapshotRestoreCommandArg.java rename modules/{control-utility/src/main/java/org/apache/ignite/internal/commandline => core/src/main/java/org/apache/ignite/internal/management}/snapshot/SnapshotStatusCommand.java (83%) create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/tracing/AbstractTracingConfigurationCommand.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/tracing/TracingConfigurationCommand.java copy modules/core/src/main/java/org/apache/ignite/internal/{processors/query/QueryState.java => management/tracing/TracingConfigurationGetAllCommand.java} (61%) copy modules/core/src/main/java/org/apache/ignite/internal/{visor/cache/index/IndexRebuildStatusTaskArg.java => management/tracing/TracingConfigurationGetAllCommandArg.java} (58%) copy modules/core/src/main/java/org/apache/ignite/internal/{processors/query/QueryState.java => management/tracing/TracingConfigurationGetCommand.java} (59%) rename modules/core/src/main/java/org/apache/ignite/internal/{visor/persistence/PersistenceCleanAndBackupSettings.java => management/tracing/TracingConfigurationGetCommandArg.java} (56%) create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/tracing/TracingConfigurationResetAllCommand.java copy modules/{calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/FragmentPlan.java => core/src/main/java/org/apache/ignite/internal/management/tracing/TracingConfigurationResetCommand.java} (51%) copy modules/{calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/DdlPlan.java => core/src/main/java/org/apache/ignite/internal/management/tracing/TracingConfigurationSetCommand.java} (56%) create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/tracing/TracingConfigurationSetCommandArg.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/tx/TxCommand.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/tx/TxCommandArg.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/tx/TxInfoCommand.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/tx/TxInfoCommandArg.java copy modules/core/src/main/java/org/apache/ignite/internal/{processors/query/QueryState.java => management/wal/WalCommand.java} (68%) create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/wal/WalDeleteCommand.java rename modules/core/src/main/java/org/apache/ignite/internal/{visor/cache/index/IndexRebuildStatusTaskArg.java => management/wal/WalDeleteCommandArg.java} (60%) create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/management/wal/WalPrintCommand.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/processors/cache/verify/VerifyBackupPartitionsTask.java rename modules/core/src/main/java/org/apache/ignite/internal/processors/query/{ => running}/GridRunningQueryInfo.java (91%) rename modules/{indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/LongRunningQueryManager.java => core/src/main/java/org/apache/ignite/internal/processors/query/running/HeavyQueriesTracker.java} (68%) rename modules/core/src/main/java/org/apache/ignite/internal/processors/query/{ => running}/QueryHistory.java (98%) rename modules/core/src/main/java/org/apache/ignite/internal/processors/query/{ => running}/QueryHistoryKey.java (97%) rename modules/core/src/main/java/org/apache/ignite/internal/processors/query/{ => running}/QueryHistoryMetricsValue.java (97%) rename modules/core/src/main/java/org/apache/ignite/internal/processors/query/{ => running}/QueryHistoryTracker.java (98%) rename modules/core/src/main/java/org/apache/ignite/internal/processors/query/{ => running}/QueryRunningFuture.java (94%) rename modules/core/src/main/java/org/apache/ignite/internal/processors/query/{ => running}/RunningQueryManager.java (96%) rename modules/{indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/mxbean => core/src/main/java/org/apache/ignite/internal/processors/query/running}/SqlQueryMXBean.java (98%) rename modules/{indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/mxbean => core/src/main/java/org/apache/ignite/internal/processors/query/running}/SqlQueryMXBeanImpl.java (69%) rename modules/core/src/main/java/org/apache/ignite/internal/processors/query/{RunningQuery.java => running/TrackableQuery.java} (69%) delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/visor/baseline/VisorBaselineOperation.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/visor/baseline/VisorBaselineTaskArg.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheStopTaskArg.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorFindAndDeleteGarbageInPersistenceTaskArg.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/visor/cache/index/IndexListTaskArg.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/visor/cache/index/ScheduleIndexRebuildTaskArg.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/visor/cache/metrics/VisorCacheMetricsTaskArg.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/visor/consistency/VisorConsistencyRepairTaskArg.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/visor/diagnostic/availability/VisorConnectivityArgs.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/visor/encryption/VisorCacheGroupEncryptionTaskArg.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/visor/encryption/VisorReencryptionRateTaskArg.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/visor/metric/VisorMetricTaskArg.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/visor/misc/VisorWalTaskArg.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/visor/performancestatistics/VisorPerformanceStatisticsTaskArg.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/visor/persistence/PersistenceTaskArg.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/visor/shutdown/VisorShutdownPolicyTaskArg.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/visor/snapshot/VisorSnapshotCancelTaskArg.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/visor/snapshot/VisorSnapshotCheckTaskArg.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/visor/snapshot/VisorSnapshotCreateTaskArg.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/visor/snapshot/VisorSnapshotRestoreTaskAction.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/visor/snapshot/VisorSnapshotRestoreTaskArg.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/visor/tracing/configuration/VisorTracingConfigurationOperation.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/visor/tracing/configuration/VisorTracingConfigurationTaskArg.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/visor/tx/KillTransactionTask.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/visor/tx/VisorTxOperation.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/visor/tx/VisorTxTaskArg.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/visor/verify/VisorContentionTaskArg.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/visor/verify/VisorIdleVerifyDumpTaskArg.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/visor/verify/VisorIdleVerifyTask.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/visor/verify/VisorIdleVerifyTaskArg.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/visor/verify/VisorIdleVerifyTaskResult.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/visor/verify/VisorValidateIndexesTaskArg.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/visor/verify/VisorViewCacheTaskArg.java rename modules/{control-utility/src/main/java/org/apache/ignite/internal/commandline/cache/argument/IndexForceRebuildCommandArg.java => core/src/main/java/org/apache/ignite/spi/metric/RegexpMetricFilter.java} (51%) create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/management/api/CommandUtilsSelfTest.java create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/managers/communication/AbstractCommunicationMessageSerializationTest.java create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/managers/communication/IgniteIoCommunicationMessageSerializationTest.java delete mode 100644 modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/H2QueryFetchSizeInterceptor.java create mode 100644 modules/indexing/src/test/java/org/apache/ignite/cache/query/IndexQueryLimitTest.java rename modules/{core/src/main/java/org/apache/ignite/internal/processors/query/QueryState.java => indexing/src/test/java/org/apache/ignite/spi/communication/tcp/H2CommunicationMessageSerializationTest.java} (59%) create mode 100644 modules/spring/src/test/config/metric/regexp-filter-config.xml create mode 100644 modules/spring/src/test/java/org/apache/ignite/internal/metric/RegexpMetricFilterTest.java