ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gvvinbl...@apache.org
Subject [ignite] 01/02: Merge branch 'master' into ignite-12248
Date Mon, 13 Jul 2020 11:20:01 GMT
This is an automated email from the ASF dual-hosted git repository.

gvvinblade pushed a commit to branch ignite-12248
in repository https://gitbox.apache.org/repos/asf/ignite.git

commit ca4cdf5d2914e0087e47bcba26792e15ec42b02a
Merge: 951f134 3bd9870
Author: Igor Seliverstov <gvvinblade@gmail.com>
AuthorDate: Mon Jul 13 14:00:12 2020 +0300

    Merge branch 'master' into ignite-12248
    
    # Conflicts:
    #	modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/query/PlatformContinuousQueryImpl.java
    #	pom.xml

 .github/PULL_REQUEST_TEMPLATE.md                   |    4 +-
 .gitignore                                         |   30 +-
 DEVNOTES.txt                                       |   12 +-
 LICENSE                                            |    6 +
 README.md                                          |    6 +-
 assembly/dependencies-apache-ignite-slim.xml       |  222 ++
 assembly/dependencies-apache-ignite.xml            |    2 +
 assembly/libs/README.txt                           |    5 -
 assembly/release-apache-ignite-base.xml            |   16 +-
 assembly/release-apache-ignite-slim.xml            |   50 +
 checkstyle/checkstyle.xml                          |    9 +
 examples/README-slim.txt                           |   32 +
 examples/pom-standalone-lgpl.xml                   |   18 +
 examples/pom-standalone.xml                        |   18 +
 .../examples/datagrid/SpatialQueryExample.java     |   14 +-
 .../ComputeClientBinaryTaskExecutionExample.java   |    2 +-
 .../binary/computegrid/ComputeClientTask.java      |    2 +-
 .../examples/client/ClientPutGetExample.java       |    4 +-
 .../examples/datagrid/DataRegionsExample.java      |    2 +-
 .../dataset/AlgorithmSpecificDatasetExample.java   |    2 +-
 .../inference/h2o/H2OMojoModelParserExample.java   |    2 +-
 ...eeClassificationTrainerSQLInferenceExample.java |   36 +-
 ...onTreeClassificationTrainerSQLTableExample.java |  109 +-
 .../org/apache/ignite/examples/model/Address.java  |    2 +-
 .../OpenCensusMetricsExporterExample.java          |    4 +-
 .../spark/JavaIgniteDataFrameWriteExample.java     |    3 +-
 .../ignite/examples/spark/SharedRDDExample.java    |    5 +-
 .../ignite/examples/CacheExamplesSelfTest.java     |    2 +-
 idea/ignite_codeStyle.xml                          |    2 +
 .../apache/ignite/gridify/BasicAopSelfTest.java    |    5 +-
 modules/aws/pom.xml                                |   12 +
 .../ignite/spi/checkpoint/s3/S3CheckpointSpi.java  |   20 +-
 .../tcp/ipfinder/elb/TcpDiscoveryAlbIpFinder.java  |    8 +-
 .../tcp/ipfinder/elb/TcpDiscoveryElbIpFinder.java  |    9 +-
 .../spi/checkpoint/s3/S3CheckpointSpiSelfTest.java |    6 +-
 .../tcp/ipfinder/s3/client/DummyObjectListing.java |    4 +-
 .../ipfinder/s3/client/DummyObjectListingTest.java |    4 +-
 .../tcp/ipfinder/s3/client/DummyS3Client.java      |   22 +-
 .../tcp/ipfinder/s3/client/DummyS3ClientTest.java  |    6 +-
 .../internal/benchmarks/jmh/algo/BenchmarkCRC.java |    5 +-
 .../benchmarks/jmh/cache/JmhCacheBenchmark.java    |    3 +-
 .../GridDhtPartitionsStateValidatorBenchmark.java  |   11 +-
 .../benchmarks/jmh/misc/JmhIncrementBenchmark.java |    3 +-
 .../jmh/runner/JmhIdeBenchmarkRunner.java          |    3 +-
 .../jmh/sequence/JmhSequenceBenchmark.java         |    2 +-
 .../jmh/streamer/JmhStreamerAddDataBenchmark.java  |    6 +-
 .../benchmarks/jol/GridMetricsJolBenchmark.java    |    2 +-
 .../ignite/internal/benchmarks/model/IntValue.java |    9 +-
 .../stream/camel/IgniteCamelStreamerTest.java      |   14 +-
 .../store/cassandra/serializer/KryoSerializer.java |    8 +-
 .../apache/ignite/tests/KryoSerializerTest.java    |    2 -
 .../cache/store/cassandra/CassandraCacheStore.java |    8 +-
 .../store/cassandra/common/CassandraHelper.java    |    6 +-
 .../cassandra/common/PropertyMappingHelper.java    |    4 +-
 .../persistence/KeyValuePersistenceSettings.java   |    2 +-
 .../persistence/PersistenceController.java         |    7 +-
 .../cassandra/persistence/PersistenceSettings.java |   10 +-
 .../store/cassandra/persistence/PojoField.java     |    7 +-
 .../cassandra/persistence/PojoFieldAccessor.java   |    3 +-
 .../store/cassandra/session/CassandraSession.java  |    3 +-
 .../session/GenericBatchExecutionAssistant.java    |    2 +-
 .../session/LoadCacheCustomQueryWorker.java        |    2 +-
 .../session/WrappedPreparedStatement.java          |    5 +-
 .../session/transaction/WriteMutation.java         |    2 -
 .../tests/CassandraDirectPersistenceTest.java      |   15 +-
 .../ignite/tests/CassandraSessionImplTest.java     |   28 +-
 .../ignite/tests/DatasourceSerializationTest.java  |   17 +-
 .../ignite/tests/IgnitePersistentStoreTest.java    |   18 +-
 .../tests/LoadTestsCassandraArtifactsCreator.java  |    5 +-
 .../apache/ignite/tests/pojos/SimplePerson.java    |    3 +-
 .../apache/ignite/tests/pojos/SimplePersonId.java  |    3 +-
 .../apache/ignite/tests/utils/CassandraHelper.java |   11 +-
 .../apache/ignite/tests/utils/TestTransaction.java |    3 +-
 .../org/apache/ignite/tests/utils/TestsHelper.java |   24 +-
 .../client/ClientDefaultCacheSelfTest.java         |    4 +-
 .../jdbc2/JdbcAbstractDmlStatementSelfTest.java    |    3 +-
 .../internal/jdbc2/JdbcBulkLoadSelfTest.java       |   17 +-
 .../internal/jdbc2/JdbcEmptyCacheSelfTest.java     |   17 +-
 .../internal/jdbc2/JdbcMetadataSelfTest.java       |    3 +-
 .../rest/AbstractRestProcessorSelfTest.java        |    8 +
 .../rest/ChangeStateCommandHandlerTest.java        |    5 +-
 .../rest/JettyRestProcessorAbstractSelfTest.java   |  175 +-
 .../rest/JettyRestProcessorCommonSelfTest.java     |    4 +-
 .../rest/JettyRestProcessorGetAllAsArrayTest.java  |    2 +-
 .../tcp/redis/RedisProtocolStringSelfTest.java     |   75 +
 .../apache/ignite/jdbc/JdbcMetadataSelfTest.java   |    8 +-
 .../apache/ignite/jdbc/JdbcResultSetSelfTest.java  |   25 +-
 .../ignite/jdbc/JdbcVersionMismatchSelfTest.java   |    7 +-
 ...eJdbcThinDriverPartitionAwarenessTestSuite.java |    2 +-
 .../ignite/jdbc/thin/JdbcThinBulkLoadSelfTest.java |    8 +-
 .../JdbcThinComplexDmlDdlCustomSchemaSelfTest.java |    3 +-
 .../ignite/jdbc/thin/JdbcThinMetadataSelfTest.java |  117 +-
 .../thin/JdbcThinPreparedStatementLeakTest.java    |    7 +-
 .../jdbc/thin/JdbcThinWalModeChangeSelfTest.java   |    9 +-
 .../ipfinder/cloud/TcpDiscoveryCloudIpFinder.java  |    8 +-
 .../cloud/TcpDiscoveryCloudIpFinderSelfTest.java   |    3 +-
 .../SystemViewRowAttributeWalkerGenerator.java     |    8 +-
 .../persistence/FoldersReuseCompatibilityTest.java |    3 +-
 ...IgnitePersistenceCompatibilityAbstractTest.java |    3 +-
 .../MoveBinaryMetadataCompatibility.java           |  111 +
 .../junits/IgniteCompatibilityNodeRunner.java      |    2 +-
 .../testframework/util/MavenUtils.java             |    5 +-
 .../IgniteCompatibilityBasicTestSuite.java         |    4 +-
 .../compress/CompressionProcessorImpl.java         |    2 +-
 .../processors/compress/FileSystemUtilsTest.java   |    4 +-
 .../licenses/apache-2.0.txt                        |    0
 modules/control-utility/pom.xml                    |  117 +
 .../internal/commandline/ActivateCommand.java      |    0
 .../internal/commandline/BaselineCommand.java      |  281 +++
 .../commandline/ClusterChangeTagCommand.java       |  115 +
 .../commandline/ClusterStateChangeCommand.java     |    0
 .../ignite/internal/commandline/Command.java       |    0
 .../internal/commandline/CommandArgIterator.java   |  191 ++
 .../internal/commandline/CommandHandler.java       |    0
 .../ignite/internal/commandline/CommandList.java   |  129 ++
 .../ignite/internal/commandline/CommandLogger.java |    0
 .../internal/commandline/CommonArgParser.java      |  350 +++
 .../commandline/ConnectionAndSslParameters.java    |    0
 .../internal/commandline/DeactivateCommand.java    |    0
 .../ignite/internal/commandline/GridConsole.java   |    0
 .../internal/commandline/GridConsoleAdapter.java   |    0
 .../ignite/internal/commandline/NoopConsole.java   |    0
 .../ignite/internal/commandline/OutputFormat.java  |    0
 .../ignite/internal/commandline/StateCommand.java  |   97 +
 .../ignite/internal/commandline/TaskExecutor.java  |    0
 .../ignite/internal/commandline/TxCommandArg.java  |    0
 .../ignite/internal/commandline/TxCommands.java    |  558 +++++
 .../ignite/internal/commandline/WalCommands.java   |    0
 .../internal/commandline/argument/CommandArg.java  |    0
 .../commandline/argument/CommandArgUtils.java      |    0
 .../commandline/baseline/AutoAdjustCommandArg.java |    0
 .../commandline/baseline/BaselineArguments.java    |    0
 .../commandline/baseline/BaselineSubcommands.java  |    0
 .../commandline/cache/CacheCommandList.java        |    0
 .../internal/commandline/cache/CacheCommands.java  |    0
 .../commandline/cache/CacheContention.java         |    0
 .../commandline/cache/CacheDistribution.java       |    0
 .../commandline/cache/CacheSubcommands.java        |    0
 .../commandline/cache/CacheValidateIndexes.java    |  344 +++
 .../internal/commandline/cache/CacheViewer.java    |    0
 .../commandline/cache/CheckIndexInlineSizes.java   |    0
 .../commandline/cache/FindAndDeleteGarbage.java    |    0
 .../internal/commandline/cache/IdleVerify.java     |  371 ++++
 .../commandline/cache/ResetLostPartitions.java     |    0
 .../cache/argument/DistributionCommandArg.java     |    0
 .../cache/argument/FindAndDeleteGarbageArg.java    |    0
 .../cache/argument/IdleVerifyCommandArg.java       |    0
 .../commandline/cache/argument/ListCommandArg.java |    0
 .../cache/argument/ValidateIndexesCommandArg.java  |    0
 .../commandline/diagnostic/DiagnosticCommand.java  |    0
 .../diagnostic/DiagnosticSubCommand.java           |    0
 .../commandline/diagnostic/PageLocksCommand.java   |    0
 .../commandline/encryption/EncryptionCommand.java  |    0
 .../encryption/EncryptionSubcommand.java           |    0
 .../internal/commandline/meta/MetadataCommand.java |  164 ++
 .../commandline/meta/MetadataSubCommandsList.java  |   78 +
 .../subcommands/MetadataAbstractSubCommand.java    |  123 ++
 .../meta/subcommands/MetadataDetailsCommand.java   |   91 +
 .../meta/subcommands/MetadataHelpCommand.java      |   54 +
 .../meta/subcommands/MetadataListCommand.java      |   56 +
 .../meta/subcommands/MetadataRemoveCommand.java    |  117 +
 .../meta/subcommands/MetadataUpdateCommand.java    |   88 +
 .../internal/commandline/query/KillCommand.java    |  226 ++
 .../internal/commandline/query/KillSubcommand.java |   57 +
 .../commandline/snapshot/SnapshotCommand.java      |  113 +
 .../commandline/snapshot/SnapshotSubcommand.java   |   59 +
 .../main/resources/META-INF/classnames.properties  |   27 +
 .../commandline/CommandHandlerParsingTest.java     |  650 ++++++
 .../GridCommandHandlerSslWithSecurityTest.java     |  147 ++
 .../testsuites/IgniteControlUtilityTestSuite.java  |   66 +
 .../ZookeeperIgniteControlUtilityTestSuite.java    |   43 +
 .../util/GridCommandHandlerAbstractTest.java       |  437 ++++
 .../util/GridCommandHandlerBrokenIndexTest.java    |    0
 ...idCommandHandlerCheckIndexesInlineSizeTest.java |    0
 ...idCommandHandlerClusterByClassAbstractTest.java |    0
 .../util/GridCommandHandlerClusterByClassTest.java | 1741 +++++++++++++++
 ...ridCommandHandlerClusterByClassWithSSLTest.java |    0
 ...CommandHandlerClusterPerMethodAbstractTest.java |    0
 .../GridCommandHandlerIndexingCheckSizeTest.java   |    0
 ...idCommandHandlerIndexingClusterByClassTest.java |  197 ++
 ...ndHandlerIndexingClusterByClassWithSSLTest.java |    0
 .../util/GridCommandHandlerIndexingTest.java       |  347 +++
 .../util/GridCommandHandlerIndexingUtils.java      |    0
 .../GridCommandHandlerIndexingWithSSLTest.java     |    0
 .../util/GridCommandHandlerMetadataTest.java       |  384 ++++
 .../ignite/util/GridCommandHandlerSslTest.java     |    0
 .../apache/ignite/util/GridCommandHandlerTest.java | 2265 ++++++++++++++++++++
 .../ignite/util/GridCommandHandlerTestUtils.java   |    0
 .../ignite/util/GridCommandHandlerWithSSLTest.java |    0
 .../ignite/util/KillCommandsCommandShTest.java     |  198 ++
 .../main/java/org/apache/ignite/IgniteCluster.java |   42 +-
 .../java/org/apache/ignite/IgniteFileSystem.java   |    2 +-
 .../java/org/apache/ignite/IgniteServices.java     |    2 +-
 .../java/org/apache/ignite/IgniteSnapshot.java     |    9 +
 .../org/apache/ignite/IgniteSystemProperties.java  |    8 +
 .../ignite/binary/BinaryTypeConfiguration.java     |    5 +-
 .../java/org/apache/ignite/cache/CacheMetrics.java |   12 +
 .../java/org/apache/ignite/cache/QueryEntity.java  |    2 +-
 .../ignite/cache/query/BulkLoadContextCursor.java  |    7 +-
 .../org/apache/ignite/client/ClientServices.java   |   56 +
 .../org/apache/ignite/client/IgniteClient.java     |   20 +
 .../org/apache/ignite/cluster/ClusterState.java    |   47 +-
 .../configuration/DataStorageConfiguration.java    |    6 +
 .../configuration/FileSystemConfiguration.java     |    3 +-
 .../ignite/configuration/HadoopConfiguration.java  |    2 +-
 .../ignite/configuration/IgniteConfiguration.java  |    2 +-
 .../configuration/PlatformCacheConfiguration.java  |    3 +-
 .../ignite/events/ClusterTagUpdatedEvent.java      |   82 +
 .../java/org/apache/ignite/events/EventType.java   |   18 +-
 .../igfs/IgfsParentNotDirectoryException.java      |    2 +-
 .../local/LocalIgfsSecondaryFileSystem.java        |   37 +-
 .../ignite/internal/GridEventConsumeHandler.java   |   12 +-
 .../apache/ignite/internal/GridKernalContext.java  |    2 +-
 .../ignite/internal/GridKernalContextImpl.java     |    2 +-
 .../java/org/apache/ignite/internal/GridTopic.java |    5 +-
 .../org/apache/ignite/internal/IgniteFeatures.java |   12 +-
 .../org/apache/ignite/internal/IgniteKernal.java   |   69 +-
 .../ignite/internal/MarshallerContextImpl.java     |   32 +-
 .../internal/MarshallerMappingFileStore.java       |   65 +-
 .../ignite/internal/SecurityAwareBiPredicate.java  |    8 +-
 .../ignite/internal/TransactionsMXBeanImpl.java    |   10 +
 .../internal/binary/BinaryClassDescriptor.java     |    4 +-
 .../ignite/internal/binary/BinaryContext.java      |   11 +-
 .../ignite/internal/binary/BinaryEnumCache.java    |    3 +-
 .../ignite/internal/binary/BinaryFieldImpl.java    |    4 +-
 .../internal/binary/BinaryFieldMetadata.java       |    5 +-
 .../internal/binary/BinaryMethodWriteReplacer.java |    5 +-
 .../ignite/internal/binary/BinaryRawWriterEx.java  |    2 +-
 .../internal/binary/BinaryReaderHandles.java       |    3 +-
 .../ignite/internal/binary/BinarySchema.java       |    3 +-
 .../internal/binary/BinarySchemaRegistry.java      |    3 +-
 .../binary/BinarySerializedFieldComparator.java    |    3 +-
 .../internal/binary/BinaryThreadLocalContext.java  |    2 +-
 .../ignite/internal/binary/BinaryTreeMap.java      |    9 +-
 .../binary/BinaryTreeMapWriteReplacer.java         |    3 +-
 .../ignite/internal/binary/BinaryTreeSet.java      |    7 +-
 .../binary/BinaryTreeSetWriteReplacer.java         |    3 +-
 .../ignite/internal/binary/BinaryTypeImpl.java     |    6 +-
 .../ignite/internal/binary/BinaryTypeProxy.java    |    3 +-
 .../apache/ignite/internal/binary/BinaryUtils.java |    7 +-
 .../ignite/internal/binary/BinaryWriterExImpl.java |    2 +-
 .../internal/binary/GridBinaryMarshaller.java      |    2 +-
 .../internal/binary/builder/BinaryBuilderEnum.java |    4 +-
 .../binary/builder/BinaryBuilderReader.java        |   21 +-
 .../binary/builder/BinaryEnumArrayLazyValue.java   |    4 +-
 .../binary/builder/BinaryLazyArrayList.java        |    2 +-
 .../binary/builder/BinaryLazyLinkedList.java       |    2 +-
 .../internal/binary/builder/BinaryLazyMap.java     |    2 +-
 .../internal/binary/builder/BinaryLazySet.java     |    2 +-
 .../binary/builder/BinaryObjectArrayLazyValue.java |    4 +-
 .../binary/builder/BinaryPlainBinaryObject.java    |    2 +-
 .../internal/client/GridClientClusterState.java    |   18 +-
 .../client/impl/GridClientClusterStateImpl.java    |   24 +
 .../GridClientZipOptimizedMarshaller.java          |    2 +-
 .../client/router/impl/GridRouterClientImpl.java   |    2 +-
 .../client/thin/ClientClusterGroupImpl.java        |   14 +-
 .../internal/client/thin/ClientClusterImpl.java    |   12 +
 .../internal/client/thin/ClientComputeImpl.java    |   57 +-
 .../internal/client/thin/ClientOperation.java      |    4 +-
 .../internal/client/thin/ClientServicesImpl.java   |  180 ++
 .../ignite/internal/client/thin/ClientUtils.java   |   11 +-
 .../client/thin/ProtocolBitmaskFeature.java        |    5 +-
 .../internal/client/thin/ProtocolContext.java      |   12 +
 .../internal/client/thin/ReliableChannel.java      |   12 +
 .../client/thin/TcpClientTransactions.java         |   64 +-
 .../internal/client/thin/TcpIgniteClient.java      |  137 +-
 .../internal/cluster/ClusterGroupAdapter.java      |  220 +-
 .../internal/cluster/ClusterNodeLocalMapImpl.java  |    2 +-
 .../internal/cluster/IgniteClusterAsyncImpl.java   |   15 +
 .../ignite/internal/cluster/IgniteClusterImpl.java |   68 +
 .../internal/commandline/BaselineCommand.java      |  281 ---
 .../internal/commandline/CommandArgIterator.java   |  158 --
 .../ignite/internal/commandline/CommandList.java   |  122 --
 .../internal/commandline/CommonArgParser.java      |  350 ---
 .../ignite/internal/commandline/StateCommand.java  |   88 -
 .../ignite/internal/commandline/TxCommands.java    |  558 -----
 .../commandline/cache/CacheValidateIndexes.java    |  344 ---
 .../internal/commandline/cache/IdleVerify.java     |  394 ----
 .../CheckIndexInlineSizesTask.java                 |    5 +-
 .../commandline/meta/subcommands/VoidDto.java      |   42 +
 .../commandline/meta/tasks/MetadataInfoTask.java   |   88 +
 .../commandline/meta/tasks/MetadataListResult.java |   74 +
 .../commandline/meta/tasks/MetadataMarshalled.java |   86 +
 .../commandline/meta/tasks/MetadataRemoveTask.java |  148 ++
 .../commandline/meta/tasks/MetadataTypeArgs.java   |   96 +
 .../commandline/meta/tasks/MetadataUpdateTask.java |   97 +
 .../internal/commandline/query/KillCommand.java    |  214 --
 .../internal/commandline/query/KillSubcommand.java |   52 -
 .../commandline/snapshot/SnapshotCommand.java      |  100 -
 .../commandline/snapshot/SnapshotSubcommand.java   |   56 -
 .../org/apache/ignite/internal/jdbc/JdbcUtils.java |    2 +-
 .../internal/jdbc/thin/JdbcThinConnection.java     |    8 +-
 .../internal/managers/IgniteMBeansManager.java     |    4 +-
 .../managers/communication/GridIoManager.java      |  241 ++-
 .../managers/communication/GridIoMessage.java      |   15 +-
 .../communication/GridIoMessageFactory.java        |    2 +
 .../communication/GridIoSecurityAwareMessage.java  |    8 +-
 .../managers/deployment/GridDeployment.java        |    2 +-
 .../deployment/GridDeploymentCommunication.java    |    9 +-
 .../managers/discovery/ClusterMetricsImpl.java     |    2 +-
 .../managers/discovery/GridDiscoveryManager.java   |    5 +-
 .../systemview/walker/ComputeJobViewWalker.java    |    2 +-
 .../walker/PartitionStateViewWalker.java           |   75 +
 .../pagemem/impl/PageMemoryNoStoreImpl.java        |    4 +-
 .../pagemem/wal/record/CheckpointRecord.java       |    3 +-
 .../pagemem/wal/record/MasterKeyChangeRecord.java  |    2 +-
 .../affinity/GridAffinityAssignmentCache.java      |    7 +
 .../processors/bulkload/BulkLoadCsvFormat.java     |    3 +-
 .../processors/bulkload/BulkLoadCsvParser.java     |   13 +-
 .../processors/bulkload/BulkLoadParser.java        |    3 +-
 .../bulkload/pipeline/CharsetDecoderBlock.java     |    5 +-
 .../bulkload/pipeline/CsvLineProcessorBlock.java   |    3 +-
 .../bulkload/pipeline/LineSplitterBlock.java       |    3 +-
 .../cache/CacheAffinitySharedManager.java          |    6 +
 .../cache/CacheClusterMetricsMXBeanImpl.java       |    5 +
 .../cache/CacheDefaultBinaryAffinityKeyMapper.java |    5 +-
 .../processors/cache/CacheGroupMetricsImpl.java    |   10 +-
 .../cache/CacheLocalMetricsMXBeanImpl.java         |    5 +
 .../processors/cache/CacheMetricsImpl.java         |   62 +-
 .../processors/cache/CacheMetricsSnapshot.java     |    5 +
 .../processors/cache/CacheMetricsSnapshotV2.java   |   12 +
 .../cache/CachePartialUpdateCheckedException.java  |    7 +
 .../processors/cache/ClusterCachesInfo.java        |   77 +-
 .../processors/cache/DynamicCacheDescriptor.java   |   31 +-
 .../internal/processors/cache/ExchangeActions.java |    6 +-
 .../cache/GatewayProtectedCacheProxy.java          |    8 +-
 .../processors/cache/GridCacheAdapter.java         |    6 +
 .../processors/cache/GridCacheContext.java         |   37 +-
 .../processors/cache/GridCacheContextInfo.java     |   31 +-
 .../processors/cache/GridCacheEntryInfo.java       |    3 +-
 .../cache/GridCacheLockTimeoutException.java       |    2 +-
 .../cache/GridCachePartitionExchangeManager.java   |  368 ++--
 .../processors/cache/GridCachePreloader.java       |    5 +-
 .../cache/GridCachePreloaderAdapter.java           |    5 +-
 .../processors/cache/GridCacheProcessor.java       |  222 +-
 .../internal/processors/cache/GridCacheUtils.java  |   38 +
 .../processors/cache/IgniteCacheProxyImpl.java     |   55 +-
 .../cache/LongOperationsDumpSettingsClosure.java   |    8 +-
 .../processors/cache/StateChangeRequest.java       |    4 +-
 .../cache/ValidationOnNodeJoinUtils.java           |   31 +-
 .../processors/cache/WalStateAbstractMessage.java  |    3 +-
 .../processors/cache/WalStateAckMessage.java       |    5 +-
 .../cache/WalStateDistributedProcess.java          |    9 +-
 .../internal/processors/cache/WalStateManager.java |    2 +-
 .../cache/binary/BinaryMetadataFileStore.java      |  283 ++-
 .../cache/binary/BinaryMetadataHolder.java         |   32 +-
 .../cache/binary/BinaryMetadataTransport.java      |  446 ++--
 .../binary/CacheObjectBinaryProcessorImpl.java     |  117 +-
 .../processors/cache/binary/IgniteBinaryImpl.java  |    7 +-
 .../binary/MetadataRemoveAcceptedMessage.java      |   96 +
 .../binary/MetadataRemoveProposedMessage.java      |  143 ++
 .../distributed/GridDistributedCacheEntry.java     |    4 +
 .../GridDistributedTxFinishRequest.java            |    2 +-
 .../GridDistributedTxRemoteAdapter.java            |    2 +-
 .../dht/GridDhtAssignmentFetchFuture.java          |    2 +-
 .../cache/distributed/dht/GridDhtCacheAdapter.java |    4 +-
 .../dht/GridDhtTopologyFutureAdapter.java          |    8 +-
 .../dht/preloader/GridDhtPartitionDemander.java    |   57 +-
 .../dht/preloader/GridDhtPartitionSupplier.java    |   91 +-
 .../preloader/GridDhtPartitionsExchangeFuture.java |  393 +++-
 .../dht/preloader/GridDhtPreloader.java            |   36 +-
 .../IgniteDhtPartitionHistorySuppliersMap.java     |   15 +-
 .../IgniteHistoricalIteratorException.java         |   48 +
 .../preloader/RebalanceReassignExchangeTask.java   |   15 +-
 .../dht/preloader/SupplyPartitionInfo.java         |   99 +
 .../dht/topology/GridClientPartitionTopology.java  |    2 +-
 .../dht/topology/GridDhtPartitionTopology.java     |    2 +-
 .../dht/topology/GridDhtPartitionTopologyImpl.java |   71 +-
 .../distributed/near/IgniteTxMappingsImpl.java     |    2 +-
 .../cache/local/GridLocalLockFuture.java           |    4 +-
 .../processors/cache/mvcc/MvccProcessorImpl.java   |   14 +-
 .../processors/cache/mvcc/MvccVersionImpl.java     |    3 +-
 .../cache/persistence/DataStorageMetricsImpl.java  |    2 +-
 .../cache/persistence/DataStructure.java           |    4 +-
 .../GridCacheDatabaseSharedManager.java            |  227 +-
 .../cache/persistence/GridCacheOffheapManager.java |  157 +-
 .../IgniteCacheDatabaseSharedManager.java          |   15 +-
 .../persistence/checkpoint/CheckpointEntry.java    |   15 +-
 .../persistence/checkpoint/CheckpointHistory.java  |  305 ++-
 .../persistence/checkpoint/CheckpointProgress.java |    3 +-
 .../checkpoint/CheckpointProgressImpl.java         |    9 +-
 .../checkpoint/PartitionDestroyQueue.java          |    5 +-
 .../persistence/checkpoint/ReservationReason.java  |   50 +
 .../pagelocktracker/stack/LockStack.java           |    2 +-
 .../evict/Random2LruPageEvictionTracker.java       |    2 +-
 .../cache/persistence/file/EncryptedFileIO.java    |    4 +-
 .../persistence/file/EncryptedFileIOFactory.java   |    2 +-
 .../filename/PdsConsistentIdProcessor.java         |    3 +
 .../cache/persistence/pagemem/PageMemoryImpl.java  |   12 +-
 .../partstorage/PartitionMetaStorage.java          |    2 +-
 .../snapshot/IgniteSnapshotManager.java            |  170 +-
 .../persistence/snapshot/SnapshotFutureTask.java   |    8 +-
 .../persistence/snapshot/SnapshotMXBeanImpl.java   |    5 +
 .../persistence/tree/reuse/ReuseListImpl.java      |    2 +-
 .../cache/persistence/tree/util/PageHandler.java   |    2 +-
 .../persistence/wal/FileWriteAheadLogManager.java  |    4 +-
 .../wal/aware/SegmentCompressStorage.java          |    4 +-
 .../wal/io/LockedSegmentFileInputFactory.java      |    2 +-
 .../wal/reader/StandaloneGridKernalContext.java    |    4 +-
 .../query/GridCacheDistributedQueryManager.java    |    7 +-
 .../cache/query/GridCacheQueryManager.java         |   14 +-
 .../cache/query/GridCacheQueryMetricsAdapter.java  |    2 +-
 .../query/GridCacheQuerySqlMetadataJobV2.java      |   13 +-
 .../cache/query/GridCacheQuerySqlMetadataV2.java   |    5 +-
 .../cache/query/IgniteQueryErrorCode.java          |    3 +
 .../cache/query/QueryEntityTypeDescriptor.java     |   14 +-
 .../CacheContinuousQueryEventBuffer.java           |  169 +-
 .../continuous/CacheContinuousQueryHandler.java    |   18 +-
 .../continuous/CacheContinuousQueryListener.java   |   12 +-
 .../continuous/CacheContinuousQueryManager.java    |   28 +-
 .../CacheContinuousQueryPartitionRecovery.java     |   16 +-
 .../query/continuous/SecurityAwareFilter.java      |   22 +-
 .../SecurityAwareTransformerFactory.java           |   22 +-
 .../cache/store/CacheOsStoreManager.java           |    2 +-
 .../cache/transactions/IgniteTxManager.java        |  290 ++-
 .../TxCollisionsDumpSettingsClosure.java           |   54 +
 .../cache/verify/IdleVerifyResultV2.java           |    4 +-
 .../verify/VerifyBackupPartitionsDumpTask.java     |   26 +-
 .../cache/verify/VerifyBackupPartitionsTaskV2.java |    2 +-
 .../cacheobject/IgniteCacheObjectProcessor.java    |   10 +
 .../cluster/ChangeGlobalStateFinishMessage.java    |    4 +-
 .../cluster/ChangeGlobalStateMessage.java          |    2 +-
 .../ClientGetClusterStateComputeRequest.java       |   42 +
 .../ClientSetClusterStateComputeRequest.java       |   84 +
 .../processors/cluster/ClusterIdAndTag.java        |   80 +
 .../processors/cluster/ClusterProcessor.java       |  264 ++-
 .../processors/cluster/ClusterTagGenerator.java    |  862 ++++++++
 .../cluster/DiscoveryDataClusterState.java         |    2 +-
 .../cluster/GridClusterStateProcessor.java         |  221 +-
 .../cluster/IgniteClusterMXBeanImpl.java           |   62 +
 .../datastreamer/DataStreamProcessor.java          |    7 +-
 .../datastructures/DataStructureInfoKey.java       |    3 +-
 .../datastructures/DataStructuresCacheKey.java     |    3 +-
 .../datastructures/GridCacheAtomicLongImpl.java    |    2 +-
 .../GridCacheAtomicSequenceImpl.java               |   11 +-
 .../GridCacheCountDownLatchImpl.java               |    2 +-
 .../datastructures/GridCacheLockImpl.java          |    5 +-
 .../datastructures/GridCacheSemaphoreImpl.java     |    2 +-
 .../processors/hadoop/HadoopClassLoader.java       |   21 +-
 .../processors/hadoop/HadoopNoopHelper.java        |    3 +-
 .../hadoop/shuffle/HadoopDirectShuffleMessage.java |    9 +-
 .../hadoop/shuffle/HadoopShuffleAck.java           |   11 +-
 .../hadoop/shuffle/HadoopShuffleFinishRequest.java |    9 +-
 .../shuffle/HadoopShuffleFinishResponse.java       |    9 +-
 .../processors/igfs/IgfsAbstractOutputStream.java  |    7 +-
 .../processors/igfs/IgfsClientSession.java         |    2 +-
 .../internal/processors/igfs/IgfsCreateResult.java |    3 +-
 .../internal/processors/igfs/IgfsDataManager.java  |    4 +-
 .../internal/processors/igfs/IgfsDeleteWorker.java |   15 +-
 .../processors/igfs/IgfsDirectoryInfo.java         |   15 +-
 .../internal/processors/igfs/IgfsEntryInfo.java    |   13 +-
 .../internal/processors/igfs/IgfsFileImpl.java     |   13 +-
 .../internal/processors/igfs/IgfsFileInfo.java     |   13 +-
 .../processors/igfs/IgfsFileWorkerBatch.java       |    9 +-
 .../processors/igfs/IgfsInputStreamImpl.java       |   21 +-
 .../internal/processors/igfs/IgfsIpcHandler.java   |   15 +-
 ...sLazySecondaryFileSystemPositionedReadable.java |    3 +-
 .../internal/processors/igfs/IgfsListingEntry.java |    9 +-
 .../processors/igfs/IgfsOutputStreamImpl.java      |    7 +-
 .../processors/igfs/IgfsOutputStreamProxyImpl.java |    7 +-
 .../internal/processors/igfs/IgfsPathIds.java      |    5 +-
 .../processors/igfs/IgfsPathsCreateResult.java     |    3 +-
 .../internal/processors/igfs/IgfsProcessor.java    |    2 +-
 .../igfs/IgfsSecondaryFileSystemCreateContext.java |    5 +-
 .../igfs/IgfsSecondaryFileSystemImpl.java          |    7 +-
 .../ignite/internal/processors/igfs/IgfsUtils.java |   29 +-
 .../igfs/client/IgfsClientAffinityCallable.java    |    3 +-
 .../igfs/client/IgfsClientListFilesCallable.java   |    3 +-
 .../igfs/client/IgfsClientListPathsCallable.java   |    3 +-
 .../igfs/client/IgfsClientMkdirsCallable.java      |    3 +-
 .../igfs/client/IgfsClientUpdateCallable.java      |    3 +-
 .../meta/IgfsClientMetaIdsForPathCallable.java     |    3 +-
 .../processors/igfs/data/IgfsDataPutProcessor.java |   15 +-
 .../meta/IgfsMetaDirectoryCreateProcessor.java     |   19 +-
 .../meta/IgfsMetaDirectoryListingAddProcessor.java |   17 +-
 .../IgfsMetaDirectoryListingRemoveProcessor.java   |   19 +-
 .../IgfsMetaDirectoryListingRenameProcessor.java   |   19 +-
 .../IgfsMetaDirectoryListingReplaceProcessor.java  |   19 +-
 .../igfs/meta/IgfsMetaFileCreateProcessor.java     |   17 +-
 .../igfs/meta/IgfsMetaFileLockProcessor.java       |   15 +-
 .../meta/IgfsMetaFileRangeDeleteProcessor.java     |   15 +-
 .../meta/IgfsMetaFileRangeUpdateProcessor.java     |   15 +-
 .../meta/IgfsMetaFileReserveSpaceProcessor.java    |   15 +-
 .../igfs/meta/IgfsMetaFileUnlockProcessor.java     |   15 +-
 .../meta/IgfsMetaUpdatePropertiesProcessor.java    |   17 +-
 .../igfs/meta/IgfsMetaUpdateTimesProcessor.java    |   15 +-
 .../local/LocalFileSystemPositionedReadable.java   |    3 +-
 .../igfs/secondary/local/LocalFileSystemUtils.java |   13 +-
 .../internal/processors/job/GridJobProcessor.java  |    2 +-
 .../metastorage/DistributedMetaStorage.java        |    5 +
 .../processors/metric/GridMetricManager.java       |    2 +-
 .../metric/PushMetricsExporterAdapter.java         |    2 +-
 .../ClientListenerAbstractConnectionContext.java   |   11 +-
 .../odbc/ClientListenerBufferedParser.java         |    7 +-
 .../processors/odbc/ClientListenerProcessor.java   |  138 +-
 .../odbc/jdbc/JdbcConnectionContext.java           |    2 +-
 .../odbc/odbc/OdbcConnectionContext.java           |    2 +-
 .../processors/odbc/odbc/OdbcRequestHandler.java   |    4 +-
 .../odbc/odbc/OdbcRequestHandlerWorker.java        |    3 +-
 .../processors/odbc/odbc/OdbcTableMeta.java        |    3 +-
 .../odbc/odbc/escape/OdbcEscapeUtils.java          |    5 +-
 .../platform/PlatformConfigurationEx.java          |    5 +-
 .../processors/platform/PlatformContext.java       |    3 +-
 .../processors/platform/PlatformContextImpl.java   |   15 +-
 .../platform/PlatformDefaultJavaObjectFactory.java |    3 +-
 .../platform/PlatformJavaObjectFactoryEx.java      |    3 +-
 .../platform/PlatformJavaObjectFactoryProxy.java   |   13 +-
 .../internal/processors/platform/PlatformLock.java |  107 +
 .../platform/PlatformNativeException.java          |    3 +-
 .../processors/platform/PlatformProcessorImpl.java |   34 +-
 .../platform/binary/PlatformBinaryProcessor.java   |    5 +-
 .../processors/platform/cache/PlatformCache.java   |    3 +
 .../cache/PlatformCacheEntryProcessorImpl.java     |   13 +-
 .../cache/PlatformCachePartialUpdateException.java |    3 +-
 .../platform/cache/affinity/PlatformAffinity.java  |    2 +-
 .../cache/affinity/PlatformAffinityFunction.java   |   13 +-
 .../affinity/PlatformAffinityFunctionTarget.java   |    3 +-
 .../cache/affinity/PlatformAffinityUtils.java      |    7 +-
 .../cache/expiry/PlatformExpiryPolicy.java         |    2 +-
 .../cache/query/PlatformContinuousQuery.java       |    3 +-
 .../cache/query/PlatformContinuousQueryImpl.java   |  107 +-
 .../query/PlatformContinuousQueryRemoteFilter.java |   17 +-
 .../cache/query/PlatformFieldsQueryCursor.java     |   19 +-
 .../platform/client/ClientBitmaskFeature.java      |    5 +-
 .../platform/client/ClientConnectionContext.java   |    2 +-
 .../platform/client/ClientMessageParser.java       |   12 +-
 .../platform/client/IgniteClientException.java     |    3 +-
 .../client/binary/ClientBinaryTypeGetResponse.java |    2 +-
 .../cache/ClientCacheConfigurationSerializer.java  |   16 +-
 .../client/cache/ClientCacheEntryQueryCursor.java  |    3 +-
 .../client/cache/ClientCacheFieldsQueryCursor.java |    3 +-
 .../client/cache/ClientCacheGetAllRequest.java     |    3 +-
 .../client/cache/ClientCacheGetAllResponse.java    |    3 +-
 .../client/cache/ClientCacheGetNamesRequest.java   |    3 +-
 .../client/cache/ClientCacheGetNamesResponse.java  |    3 +-
 .../client/cache/ClientCacheQueryCursor.java       |    5 +-
 .../platform/client/cache/ClientCacheRequest.java  |    3 +-
 .../cache/ClientCacheSqlFieldsQueryResponse.java   |    3 +-
 .../cluster/ClientClusterGetStateRequest.java      |    2 +-
 .../ClientClusterGroupGetNodeIdsResponse.java      |    3 +-
 .../ClientClusterGroupGetNodesDetailsRequest.java  |    5 +-
 ...lientClusterGroupGetNodesEndpointsResponse.java |    6 +-
 .../platform/client/compute/ClientComputeTask.java |    4 +-
 .../client/compute/ClientExecuteTaskRequest.java   |    2 +-
 .../client/service/ClientServiceInvokeRequest.java |  323 +++
 .../platform/compute/PlatformAbstractFunc.java     |    3 +-
 .../platform/compute/PlatformFullTask.java         |    2 +-
 .../cpp/PlatformCppConfigurationClosure.java       |    9 +-
 .../platform/cpp/PlatformCppConfigurationEx.java   |    3 +-
 .../datastreamer/PlatformDataStreamer.java         |    2 +-
 .../datastreamer/PlatformStreamReceiverImpl.java   |   11 +-
 .../platform/dotnet/PlatformDotNetBootstrap.java   |    3 +-
 .../platform/dotnet/PlatformDotNetCacheStore.java  |   17 +-
 .../dotnet/PlatformDotNetConfigurationClosure.java |    7 +-
 .../dotnet/PlatformDotNetConfigurationEx.java      |    5 +-
 .../dotnet/PlatformDotNetConsoleStream.java        |    3 +-
 ...latformDotNetEntityFrameworkCacheExtension.java |   17 +-
 .../PlatformDotNetEntityFrameworkCacheKey.java     |    3 +-
 ...NetEntityFrameworkIncreaseVersionProcessor.java |    3 +-
 .../events/PlatformEventFilterListenerImpl.java    |   11 +-
 .../processors/platform/events/PlatformEvents.java |    9 +-
 .../platform/message/PlatformMessageFilter.java    |    3 +-
 .../messaging/PlatformMessageFilterImpl.java       |    3 +-
 .../messaging/PlatformMessageLocalFilter.java      |    3 +-
 .../platform/messaging/PlatformMessaging.java      |    3 +-
 .../platform/services/PlatformServices.java        |   51 +-
 .../transactions/PlatformTransactions.java         |    9 +-
 .../platform/utils/PlatformConfigurationUtils.java |   20 +-
 .../platform/utils/PlatformListenable.java         |    4 +-
 .../processors/platform/utils/PlatformUtils.java   |   33 +-
 .../PlatformDotNetSessionCacheExtension.java       |    5 +-
 .../websession/PlatformDotNetSessionData.java      |    9 +-
 .../PlatformDotNetSessionLockProcessor.java        |    9 +-
 .../PlatformDotNetSessionLockResult.java           |    3 +-
 ...PlatformDotNetSessionSetAndUnlockProcessor.java |   11 +-
 .../processors/plugin/CachePluginManager.java      |    3 +-
 .../processors/query/GridQueryIndexDescriptor.java |    3 +-
 .../processors/query/GridQueryProcessor.java       |  385 +++-
 .../internal/processors/query/QueryEntityEx.java   |    5 +-
 .../internal/processors/query/QueryField.java      |    3 +-
 .../processors/query/QueryIndexDescriptorImpl.java |   11 +-
 .../internal/processors/query/QueryIndexKey.java   |    3 +-
 .../processors/query/QueryKeyValueIterable.java    |    5 +-
 .../processors/query/QueryKeyValueIterator.java    |    7 +-
 .../internal/processors/query/QuerySchema.java     |   50 +-
 .../processors/query/QueryTypeDescriptorImpl.java  |    9 +-
 .../internal/processors/query/QueryUtils.java      |   26 +-
 .../query/property/QueryFieldAccessor.java         |    3 +-
 .../query/property/QueryMethodsAccessor.java       |    3 +-
 .../property/QueryReadOnlyMethodsAccessor.java     |    3 +-
 .../SchemaIndexOperationCancellationToken.java     |    3 +-
 .../query/schema/SchemaOperationClientFuture.java  |    3 +-
 .../query/schema/SchemaOperationException.java     |    6 +
 .../query/schema/SchemaOperationManager.java       |   11 +-
 .../query/schema/SchemaOperationWorker.java        |    6 +-
 .../message/SchemaOperationStatusMessage.java      |    5 +-
 .../schema/operation/SchemaAbstractOperation.java  |    3 +-
 .../operation/SchemaAddQueryEntityOperation.java   |   82 +
 .../operation/SchemaIndexCreateOperation.java      |    3 +-
 .../schema/operation/SchemaIndexDropOperation.java |    3 +-
 .../internal/processors/rest/GridRestCommand.java  |    4 +-
 .../processors/rest/GridRestProcessor.java         |   15 +-
 .../redis/string/GridRedisMGetCommandHandler.java  |    2 +-
 .../tcp/redis/GridRedisProtocolParser.java         |   40 +
 .../AbstractSecurityAwareExternalizable.java       |   17 +
 .../processors/security/SecurityUtils.java         |   11 +-
 .../processors/service/GridServiceProxy.java       |   10 +-
 .../internal/sql/command/SqlBulkLoadCommand.java   |    7 +-
 .../sql/command/SqlCreateIndexCommand.java         |   13 +-
 .../optimizer/affinity/PartitionTableModel.java    |    3 +-
 .../ignite/internal/tck/TCKMBeanServerBuilder.java |    2 +-
 .../internal/util/GridConcurrentFactory.java       |    2 +-
 .../util/GridConcurrentMultiPairQueue.java         |    5 +-
 .../org/apache/ignite/internal/util/GridDebug.java |    4 +-
 .../apache/ignite/internal/util/GridKeyLock.java   |    2 +-
 .../apache/ignite/internal/util/IgniteUtils.java   |   30 +
 .../internal/util/SerializableTransient.java       |    3 +-
 .../apache/ignite/internal/util/lang/GridFunc.java |   14 +
 .../ignite/internal/util/lang/GridInClosure3X.java |    5 +-
 .../gridfunc/ConcurrentMapFactoryCallable.java     |    2 +-
 .../ignite/internal/util/nio/GridNioServer.java    |   10 +-
 .../apache/ignite/internal/util/scala/impl.java    |    6 +-
 .../util/tostring/GridToStringBuilder.java         |    2 +-
 .../util/tostring/GridToStringInclude.java         |    3 +-
 .../internal/util/tostring/SBLimitedLength.java    |    2 +-
 .../apache/ignite/internal/util/typedef/CI3.java   |    3 +-
 .../ignite/internal/visor/cache/VisorCache.java    |    2 +-
 .../internal/visor/cache/VisorCacheJdbcType.java   |    3 +-
 .../internal/visor/cache/VisorPartitionMap.java    |    2 +-
 .../visor/encryption/VisorChangeMasterKeyTask.java |    2 -
 .../encryption/VisorGetMasterKeyNameTask.java      |    2 -
 .../visor/misc/VisorClusterChangeTagTask.java      |   88 +
 .../visor/misc/VisorClusterChangeTagTaskArg.java   |   59 +
 .../misc/VisorClusterChangeTagTaskResult.java      |   88 +
 .../internal/visor/misc/VisorIdAndTagViewTask.java |   68 +
 .../visor/misc/VisorIdAndTagViewTaskResult.java    |   74 +
 .../visor/node/VisorMemoryConfiguration.java       |    2 +-
 .../visor/snapshot/VisorSnapshotCancelTask.java    |   60 +
 .../visor/snapshot/VisorSnapshotCreateTask.java    |    2 -
 .../websession/WebSessionAttributeProcessor.java   |   11 +-
 .../internal/websession/WebSessionEntity.java      |    9 +-
 .../AbstractNodeNameAwareMarshaller.java           |    5 +-
 .../apache/ignite/mxbean/CacheMetricsMXBean.java   |   17 +-
 .../apache/ignite/mxbean/IgniteClusterMXBean.java  |   56 +
 .../org/apache/ignite/mxbean/SnapshotMXBean.java   |   10 +-
 .../apache/ignite/mxbean/TransactionsMXBean.java   |   20 +
 .../dotnet/PlatformDotNetAffinityFunction.java     |   15 +-
 .../dotnet/PlatformDotNetBinaryConfiguration.java  |    3 +-
 .../dotnet/PlatformDotNetCacheStoreFactory.java    |    5 +-
 .../PlatformDotNetCacheStoreFactoryNative.java     |    3 +-
 .../dotnet/PlatformDotNetConfiguration.java        |    5 +-
 .../dotnet/PlatformDotNetLifecycleBean.java        |    3 +-
 .../apache/ignite/plugin/CachePluginProvider.java  |    3 +-
 .../ignite/plugin/PluginValidationException.java   |    5 +-
 .../ignite/plugin/security/SecurityPermission.java |    5 +-
 .../spi/IgniteSpiOperationTimeoutHelper.java       |   16 +
 .../spi/communication/tcp/TcpCommunicationSpi.java |  275 ++-
 .../tcp/internal/ConnectionRequestFuture.java      |   28 +
 .../tcp/internal/ConnectionRequestor.java          |   32 +
 .../tcp/internal/NodeUnreachableException.java     |   49 +
 .../internal/TcpConnectionIndexAwareMessage.java   |   31 +
 .../TcpConnectionRequestDiscoveryMessage.java      |   97 +
 .../TcpInverseConnectionResponseMessage.java       |  117 +
 .../spi/deployment/local/LocalDeploymentSpi.java   |    2 +-
 .../ignite/spi/discovery/tcp/ServerImpl.java       |  126 +-
 .../ignite/spi/discovery/tcp/TcpDiscoverySpi.java  |    9 +
 .../TcpDiscoveryServerOnlyCustomEventMessage.java  |    6 +-
 .../spi/indexing/IndexingQueryCacheFilter.java     |    3 +-
 .../spi/indexing/IndexingQueryFilterImpl.java      |    3 +-
 .../adaptive/AdaptiveLoadBalancingSpi.java         |    2 +-
 .../ignite/spi/systemview/view/CacheGroupView.java |    2 +-
 .../ignite/spi/systemview/view/CacheView.java      |    2 +-
 .../spi/systemview/view/PartitionStateView.java    |   91 +
 .../main/resources/META-INF/classnames.properties  |   66 +-
 .../test/java/org/apache/ignite/GridTestJob.java   |    3 +-
 .../RendezvousAffinityFunctionSimpleBenchmark.java |   23 +-
 ...StoreSessionListenerWriteBehindEnabledTest.java |    2 +-
 .../cache/store/CacheStoreWriteErrorTest.java      |    2 +-
 .../store/StoreResourceInjectionSelfTest.java      |   14 +-
 ...JdbcPojoWriteBehindStoreWithCoalescingTest.java |    3 +-
 .../ignite/cache/store/jdbc/model/TestPojo.java    |    2 +-
 .../org/apache/ignite/client/AsyncChannelTest.java |   16 +-
 .../ignite/client/ConnectToStartingNodeTest.java   |   12 +-
 .../org/apache/ignite/client/FunctionalTest.java   |  102 +
 .../org/apache/ignite/client/IgniteBinaryTest.java |   65 +
 .../test/java/org/apache/ignite/client/Person.java |    6 +
 .../ignite/internal/ClusterGroupSelfTest.java      |  118 +-
 .../ignite/internal/GridGetOrStartSelfTest.java    |    9 +-
 .../BinaryArrayIdentityResolverSelfTest.java       |    7 +-
 .../BinaryConfigurationConsistencySelfTest.java    |    2 +-
 .../binary/BinaryFieldsAbstractSelfTest.java       |   11 +-
 .../internal/binary/BinaryMarshallerSelfTest.java  |    2 +-
 .../BinaryObjectBuilderAdditionalSelfTest.java     |    8 +-
 .../BinaryObjectBuilderDefaultMappersSelfTest.java |    4 +-
 .../internal/binary/BinaryObjectToStringTest.java  |    2 +-
 .../BinarySerialiedFieldComparatorSelfTest.java    |   13 +-
 .../binary/GridBinaryAffinityKeySelfTest.java      |    2 +-
 .../binary/GridBinaryWildcardsSelfTest.java        |    2 +-
 ...DefaultBinaryMappersBinaryMetaDataSelfTest.java |   14 +-
 .../GridBinaryMarshalerAwareTestClass.java         |    4 +-
 .../binary/mutabletest/GridBinaryTestClasses.java  |    2 +-
 .../client/thin/AbstractThinClientTest.java        |   79 +
 .../internal/client/thin/ClusterApiTest.java       |   13 +-
 .../internal/client/thin/ClusterGroupTest.java     |   19 +-
 .../internal/client/thin/ComputeTaskTest.java      |   63 +-
 .../ignite/internal/client/thin/ServicesTest.java  |  417 ++++
 .../internal/client/thin/TestFailoverTask.java     |    7 +-
 .../internal/client/thin/TestResultCacheTask.java  |    5 +-
 .../ignite/internal/client/thin/TestTask.java      |   11 +-
 .../FullyConnectedComponentSearcherTest.java       |    2 +-
 .../internal/cluster/IgniteClusterIdTagTest.java   |  427 ++++
 .../commandline/CommandHandlerParsingTest.java     |  635 ------
 .../encryption/AbstractEncryptionTest.java         |    5 +-
 .../encryption/EncryptedCacheCreateTest.java       |    2 +-
 .../internal/encryption/MasterKeyChangeTest.java   |   43 +
 .../MessageDirectTypeIdConflictTest.java           |    1 -
 .../GridDeploymentMessageCountSelfTest.java        |    2 +-
 .../optimized/OptimizedMarshallerTest.java         |    4 +-
 .../internal/metric/IoStatisticsCacheSelfTest.java |    2 +-
 .../ignite/internal/metric/SystemViewSelfTest.java |    4 +-
 .../affinity/GridAffinityAssignmentV2Test.java     |    4 +-
 ...eateDestroyClusterReadOnlyModeAbstractTest.java |   45 +
 .../CacheCreateDestroyClusterReadOnlyModeTest.java |  186 ++
 .../processors/cache/CacheGroupMetricsTest.java    |   68 +-
 .../cache/CacheGroupsMetricsRebalanceTest.java     |    2 +-
 .../cache/CacheLockCandidatesThreadTest.java       |   13 +-
 .../processors/cache/CacheMetricsManageTest.java   |  342 ++-
 .../cache/CacheOffheapMapEntrySelfTest.java        |    2 +-
 .../processors/cache/CacheRemoveAllSelfTest.java   |    2 +-
 ...ActiveStateChangeWithNodeOutOfBaselineTest.java |    6 +-
 .../cache/ClusterReadOnlyModeTestUtils.java        |   87 +-
 .../processors/cache/ClusterStateAbstractTest.java |    2 +-
 .../cache/ClusterStateServerAbstractTest.java      |    2 +-
 ...dCacheAbstractFullApiMultithreadedSelfTest.java |    2 +-
 .../cache/GridCacheAbstractFullApiSelfTest.java    |   18 +-
 .../cache/GridCacheAbstractLocalStoreSelfTest.java |    2 +-
 .../cache/GridCacheAbstractMetricsSelfTest.java    |    2 +-
 .../cache/GridCacheAbstractRemoveFailureTest.java  |    2 +-
 .../GridCacheInterceptorAbstractSelfTest.java      |    2 +-
 ...ultinodeUpdateNearEnabledNoBackupsSelfTest.java |    2 +-
 ...ridCacheMultinodeUpdateNearEnabledSelfTest.java |    2 +-
 .../cache/GridCacheP2PUndeploySelfTest.java        |    2 +-
 .../cache/GridCachePutAllFailoverSelfTest.java     |    2 +-
 ...dLocalCacheStoreManagerDeserializationTest.java |    5 +-
 .../cache/GridLocalIgniteSerializationTest.java    |   17 +-
 .../IgniteAbstractDynamicCacheStartFailTest.java   |   20 +-
 .../processors/cache/IgniteCacheAbstractTest.java  |    2 +-
 ...IgniteCacheClusterReadOnlyModeAbstractTest.java |  263 +++
 .../IgniteCacheClusterReadOnlyModeSelfTest.java    |  531 +++++
 .../processors/cache/IgniteCacheGroupsTest.java    |    2 +-
 ...niteCacheInvokeClusterReadOnlyModeSelfTest.java |  141 ++
 .../cache/IgniteCachePeekModesAbstractTest.java    |    2 +-
 ...gniteCacheStoreClusterReadOnlyModeSelfTest.java |  302 +++
 .../cache/IgniteCacheStoreCollectionTest.java      |    2 +-
 .../cache/IgniteCacheTxNearPeekModesTest.java      |    3 +-
 .../cache/IgniteCachingProviderSelfTest.java       |    2 +-
 .../cache/IgniteClusterActivateDeactivateTest.java |   41 +-
 ...usterActivateDeactivateTestWithPersistence.java |    8 +-
 .../cache/IgniteDynamicCacheAndNodeStop.java       |   14 +-
 .../cache/IgniteDynamicCacheStartSelfTest.java     |   45 +-
 .../cache/IgniteIncompleteCacheObjectSelfTest.java |    5 +-
 ...hallerCacheClientRequestsMappingOnMissTest.java |    5 +-
 .../cache/IgniteMarshallerCacheFSRestoreTest.java  |   11 +-
 ...IgniteNearCacheClusterReadOnlyModeSelfTest.java |   33 +
 ...NearCacheInvokeClusterReadOnlyModeSelfTest.java |   35 +
 .../cache/IgniteOnePhaseCommitNearSelfTest.java    |   61 +-
 .../processors/cache/MapCacheStoreStrategy.java    |    2 +-
 .../MarshallerCacheJobRunNodeRestartTest.java      |    3 +-
 ...NonAffinityCoordinatorDynamicStartStopTest.java |    4 +-
 .../SetTxTimeoutOnPartitionMapExchangeTest.java    |    6 +-
 .../binary/BinaryMetadataMoveLegacyFolderTest.java |  225 ++
 .../cache/binary/BinaryMetadataRemoveTest.java     |  308 +++
 .../BinaryMetadataRemoveWithPersistenceTest.java   |   86 +
 .../GridCacheBinaryStoreAbstractSelfTest.java      |    4 +-
 ...ridCacheClientNodeBinaryObjectMetadataTest.java |    2 +-
 .../DataStreamProcessorBinarySelfTest.java         |    2 +-
 .../GridCacheAffinityRoutingBinarySelfTest.java    |    4 +-
 ...riesNearPartitionedByteArrayValuesSelfTest.java |    2 +-
 ...riesPartitionedOnlyByteArrayValuesSelfTest.java |    2 +-
 .../IgniteAtomicLongClusterReadOnlyTest.java       |  150 ++
 .../IgniteAtomicReferenceClusterReadOnlyTest.java  |  114 +
 .../IgniteAtomicSequenceClusterReadOnlyTest.java   |  126 ++
 .../IgniteAtomicStampedClusterReadOnlyTest.java    |  132 ++
 ...niteCollectionsClusterReadOnlyAbstractTest.java |  227 ++
 .../IgniteCountDownLatchClusterReadOnlyTest.java   |  129 ++
 .../IgniteDataStructureUniqueNameTest.java         |    2 +-
 ...tructuresCreateDeniedInClusterReadOnlyMode.java |  156 ++
 .../IgniteDataStructuresTestUtils.java             |  129 ++
 .../datastructures/IgniteLockAbstractSelfTest.java |   19 +
 .../IgniteQueueClusterReadOnlyTest.java            |   91 +
 .../IgniteSetClusterReadOnlyTest.java              |   62 +
 .../SemaphoreFailoverNoWaitingAcquirerTest.java    |    3 +-
 ...chePartitionedQueueCreateMultiNodeSelfTest.java |    1 -
 .../CacheClientsConcurrentStartTest.java           |   23 +-
 .../distributed/CacheLockChangingTopologyTest.java |    9 +-
 .../distributed/CacheOperationsInterruptTest.java  |    7 +-
 .../CachePartitionLossWithRestartsTest.java        |   36 +-
 .../cache/distributed/CachePartitionStateTest.java |    4 +-
 .../distributed/IgniteCache150ClientsTest.java     |  193 --
 ...gniteCacheClientNodePartitionsExchangeTest.java |    2 +-
 .../IgniteCacheClientReconnectTest.java            |   63 +
 .../IgniteCacheMultiClientsStartTest.java          |  193 ++
 .../distributed/IgniteCacheTxIteratorSelfTest.java |    3 +-
 .../dht/GridCacheAtomicFullApiSelfTest.java        |    2 +-
 .../dht/GridCacheDhtPreloadPerformanceTest.java    |    3 +-
 .../dht/IgniteCacheCrossCacheTxFailoverTest.java   |    2 +-
 .../dht/IgniteCacheLockFailoverSelfTest.java       |    2 +-
 .../PartitionsEvictManagerAbstractTest.java        |    2 +-
 .../eviction/EvictionPolicyFailureHandlerTest.java |    2 +-
 .../eviction/paged/PageEvictionAbstractTest.java   |    2 +-
 .../IgniteCacheExpireWhileRebalanceTest.java       |    9 +-
 .../IgniteCacheLoadAllAbstractTest.java            |    2 +-
 .../GridCacheFastNodeLeftForTransactionTest.java   |   56 +-
 .../local/GridCacheLocalMultithreadedSelfTest.java |    2 +-
 .../cache/mvcc/CacheMvccClientTopologyTest.java    |  305 +++
 .../mvcc/CacheMvccRemoteTxOnNearNodeStartTest.java |    2 +-
 .../cache/mvcc/MvccUnsupportedTxModesTest.java     |    2 +-
 .../persistence/CheckpointReadLockFailureTest.java |    2 -
 ...gniteLostPartitionsOnLeaveBaselineSelfTest.java |    2 +-
 .../IgnitePdsBinaryMetadataAsyncWritingTest.java   |   25 +-
 ...gnitePdsBinaryMetadataOnClusterRestartTest.java |   17 +-
 .../IgnitePdsCacheEntriesExpirationTest.java       |  323 +++
 .../IgnitePdsCacheRebalancingAbstractTest.java     |    6 +-
 .../persistence/IgnitePdsCorruptedIndexTest.java   |    4 +-
 .../IgnitePdsNoSpaceLeftOnDeviceTest.java          |    4 +-
 .../IgnitePersistenceSequentialCheckpointTest.java |    2 +-
 .../persistence/WalPreloadingConcurrentTest.java   |   10 +-
 .../ClientAffinityAssignmentWithBaselineTest.java  |    2 +-
 .../persistence/db/CheckpointFailingIoFactory.java |    9 +-
 .../db/IgnitePdsMultiNodePutGetRestartTest.java    |   22 +-
 .../cache/persistence/db/IgnitePdsWithTtlTest.java |    4 +-
 .../db/IgniteSequentialNodeCrashRecoveryTest.java  |  130 +-
 .../IgniteShutdownOnSupplyMessageFailureTest.java  |   17 +
 .../db/file/IgnitePdsCheckpointSimpleTest.java     |    2 +-
 .../db/file/IgnitePdsPageReplacementTest.java      |    4 +-
 .../IgniteUidAsConsistentIdMigrationTest.java      |    6 +-
 .../db/wal/HistoricalReservationTest.java          |  227 ++
 .../db/wal/IgniteWalFlushFailoverTest.java         |    2 +-
 .../db/wal/IgniteWalHistoryReservationsTest.java   |  144 +-
 .../db/wal/IgniteWalRebalanceLoggingTest.java      |  275 +++
 .../persistence/db/wal/IgniteWalRebalanceTest.java |  581 ++++-
 .../db/wal/IgniteWalRecoveryPPCTest.java           |    8 +-
 .../db/wal/IgniteWalReplayingAfterRestartTest.java |   26 +-
 .../persistence/db/wal/WalOnNodeStartTest.java     |    1 +
 .../db/wal/WalRebalanceRestartTest.java            |  321 +++
 .../db/wal/crc/IgniteDataIntegrityTests.java       |    3 +-
 .../db/wal/crc/IgnitePureJavaCrcCompatibility.java |    5 +-
 .../db/wal/reader/IgniteWalReaderTest.java         |    5 +-
 .../dumpprocessors/ToFileDumpProcessorTest.java    |    2 +-
 .../cache/persistence/file/FileDownloaderTest.java |    2 +-
 .../BPlusTreeReuseListPageMemoryImplTest.java      |    4 +-
 .../IgnitePageMemReplaceDelayedWriteUnitTest.java  |    4 +-
 .../pagemem/IgniteThrottlingUnitTest.java          |    2 +-
 .../pagemem/IndexStoragePageMemoryImplTest.java    |    2 +-
 .../pagemem/PageMemoryImplNoLoadTest.java          |    4 +-
 .../persistence/pagemem/PageMemoryImplTest.java    |    8 +-
 .../snapshot/AbstractSnapshotSelfTest.java         |   91 +-
 .../snapshot/IgniteClusterSnapshotSelfTest.java    |   51 +-
 .../snapshot/IgniteSnapshotMXBeanTest.java         |   17 +
 .../snapshot/IgniteSnapshotManagerSelfTest.java    |    6 +-
 .../standbycluster/IgniteStandByClusterTest.java   |    2 +-
 .../join/JoinActiveNodeToActiveCluster.java        |    2 +-
 .../join/JoinInActiveNodeToActiveCluster.java      |    2 +-
 ...inActiveNodeToActiveClusterWithPersistence.java |    2 +-
 ...ActiveNodeToInActiveClusterWithPersistence.java |    2 +-
 ...InActiveNodeToActiveClusterWithPersistence.java |    2 +-
 ...ActiveNodeToInActiveClusterWithPersistence.java |    2 +-
 ...niteStandByClientReconnectToNewClusterTest.java |    2 +-
 .../PageMemoryTrackerPluginProvider.java           |    2 +-
 .../ScanQueryOffheapExpiryPolicySelfTest.java      |    7 +-
 .../CacheContinuousQueryBufferLimitTest.java       |  334 +++
 ...eContinuousQueryFilterDeploymentFailedTest.java |    3 +
 .../CacheContinuousQueryLongP2PTest.java           |    4 +-
 .../AbstractDeadlockDetectionTest.java             |    5 +-
 .../transactions/PartitionUpdateCounterTest.java   |    4 +-
 ...ionIntegrityWithPrimaryIndexCorruptionTest.java |    4 +-
 .../cache/transactions/TxDeadlockCauseTest.java    |   31 +-
 .../TxPartitionCounterStateConsistencyTest.java    |  215 +-
 ...unterStateConsistencyVolatileRebalanceTest.java |    6 +
 .../TxPessimisticDeadlockDetectionTest.java        |    4 +-
 .../transactions/TxWithKeyContentionSelfTest.java  |  338 +++
 .../TxWithSmallTimeoutAndContentionOneKeyTest.java |    9 +
 .../cluster/ClusterReadOnlyModeSelfTest.java       |   57 +-
 .../TestDistibutedConfigurationPlugin.java         |    9 +-
 .../database/IgniteDbMemoryLeakAbstractTest.java   |    2 +-
 .../database/SwapPathConstructionSelfTest.java     |    6 +-
 .../datastreamer/DataStreamerImplSelfTest.java     |    5 +-
 .../failure/FailureProcessorLoggingTest.java       |    2 +-
 .../processors/igfs/IgfsAbstractSelfTest.java      |   36 +-
 .../processors/igfs/IgfsDataManagerSelfTest.java   |   13 +-
 .../processors/igfs/IgfsDualAbstractSelfTest.java  |   11 +-
 ...calSecondaryFileSystemDualAbstractSelfTest.java |   15 +-
 .../IgfsLocalSecondaryFileSystemTestAdapter.java   |   15 +-
 .../processors/igfs/IgfsMetaManagerSelfTest.java   |   11 +-
 .../ignite/internal/processors/igfs/IgfsMock.java  |    7 +-
 .../igfs/IgfsProcessorValidationSelfTest.java      |   11 +-
 .../igfs/IgfsSecondaryFileSystemTestAdapter.java   |    5 +-
 .../processors/igfs/IgfsStartCacheTest.java        |    7 +-
 .../processors/igfs/IgfsStreamsSelfTest.java       |   21 +-
 .../internal/processors/igfs/IgfsTaskSelfTest.java |   13 +-
 .../odbc/OdbcEscapeSequenceSelfTest.java           |    3 +-
 .../processors/rest/RestProcessorHangTest.java     |  148 ++
 .../rest/RestProcessorInitializationTest.java      |    2 +-
 .../cache/GridCacheCommandHandlerSelfTest.java     |    3 +-
 .../query/GridQueryCommandHandlerTest.java         |    3 +-
 .../AbstractTestSecurityPluginProvider.java        |    2 +-
 .../GridCommandHandlerSslWithSecurityTest.java     |  112 -
 ...eOperationPermissionCreateDestroyCheckTest.java |    4 +-
 .../IgniteClientContainSubjectAddressTest.java     |  101 +
 .../TestCertificateSecurityPluginProvider.java     |    2 +-
 .../AbstractContinuousQuerySandboxTest.java        |  132 ++
 .../sandbox/ContinuousQuerySandboxTest.java        |   64 +
 .../ContinuousQueryWithTransformerSandboxTest.java |   73 +
 .../GridServiceClusterReadOnlyModeTest.java        |  114 +
 .../GridServiceDeployClusterReadOnlyModeTest.java  |  393 ++++
 ...oyment2ClassLoadersOptimizedMarshallerTest.java |    2 +-
 ...loymentClassLoadingOptimizedMarshallerTest.java |    2 +-
 .../IgniteServiceProxyTimeoutInitializedTest.java  |   11 +-
 .../internal/sql/SqlParserAbstractSelfTest.java    |    3 +-
 .../util/GridConcurrentMultiPairQueueTest.java     |    9 +-
 .../offheap/GridOffHeapMapAbstractSelfTest.java    |    2 +-
 .../util/tostring/GridToStringBuilderSelfTest.java |    2 +-
 .../utils/IgniteOffheapReadWriteLockSelfTest.java  |   11 +-
 .../colocation/GridTestLifecycleBean.java          |    4 +-
 .../communication/GridIoManagerBenchmark.java      |    2 +-
 .../redeploy/GridSingleSplitsRedeployLoadTest.java |    2 +-
 .../marshaller/GridMarshallerPerformanceTest.java  |    8 +-
 .../marshaller/MarshallerContextSelfTest.java      |    3 +-
 .../messaging/IgniteMessagingSendAsyncTest.java    |    4 +-
 ...GridP2PComputeWithNestedEntryProcessorTest.java |    4 +-
 .../p2p/GridP2PScanQueryWithTransformerTest.java   |  406 ++++
 .../apache/ignite/p2p/SharedDeploymentTest.java    |   60 +-
 .../platform/AbstractPlatformServiceCallTask.java  |   30 +
 .../platform/PlatformCacheEntryEventFilter.java    |   13 +-
 .../PlatformCacheEntryEventFilterFactory.java      |    7 +-
 .../platform/PlatformCacheWriteMetricsTask.java    |   12 +-
 .../PlatformComputeActiveTaskFuturesTask.java      |   69 +
 .../PlatformComputeBinarizableArgTask.java         |   15 +-
 .../platform/PlatformComputeBroadcastTask.java     |   13 +-
 .../platform/PlatformComputeDecimalTask.java       |   17 +-
 .../ignite/platform/PlatformComputeEchoTask.java   |    7 +-
 .../platform/PlatformComputeGetThreadNameTask.java |    7 +-
 .../PlatformDefaultJavaObjectFactorySelfTest.java  |   11 +-
 .../ignite/platform/PlatformDeployServiceTask.java |   18 +-
 .../platform/PlatformEventsWriteEventTask.java     |   20 +-
 .../ignite/platform/PlatformExceptionTask.java     |   30 +-
 .../platform/PlatformIsPartitionReservedTask.java  |    7 +-
 .../PlatformJavaObjectFactoryProxySelfTest.java    |   11 +-
 .../ignite/platform/PlatformMaxMemoryTask.java     |    9 +-
 .../ignite/platform/PlatformMinMemoryTask.java     |    9 +-
 .../PlatformServiceCallCollectionsTask.java        |    9 +-
 .../PlatformServiceCallCollectionsThinTask.java    |   65 +
 .../ignite/platform/PlatformServiceCallTask.java   |   58 +-
 .../platform/PlatformServiceCallThinTask.java      |   76 +
 .../ignite/platform/PlatformSqlQueryTask.java      |   21 +-
 .../ignite/platform/PlatformStartIgniteTask.java   |    7 +-
 .../ignite/platform/PlatformStopIgniteTask.java    |    7 +-
 .../ignite/platform/PlatformStringTestTask.java    |    7 +-
 .../ignite/platform/PlatformThreadNamesTask.java   |    9 +-
 .../lifecycle/PlatformJavaLifecycleTask.java       |    9 +-
 .../security/SecurityPermissionSetBuilderTest.java |    2 +-
 .../session/GridSessionCheckpointSelfTest.java     |    2 +-
 ...unicationInverseConnectionEstablishingTest.java |  417 ++++
 ...municationSpiSkipWaitHandshakeOnClientTest.java |    2 +-
 .../tcp/TcpCommunicationSpiFreezingClientTest.java |    2 +-
 .../discovery/LongClientConnectToClusterTest.java  |   12 +-
 .../TestReconnectSecurityPluginProvider.java       |    2 +-
 .../spi/discovery/tcp/IgniteClientConnectTest.java |    5 +-
 .../tcp/TcpDiscoverySnapshotHistoryTest.java       |    3 +-
 .../discovery/tcp/TcpDiscoverySpiMBeanTest.java    |    5 +-
 .../apache/ignite/ssl/MultipleSSLContextsTest.java |   21 -
 .../stream/socket/SocketStreamerSelfTest.java      |    4 +-
 .../apache/ignite/testframework/GridTestUtils.java |   28 +-
 .../ConfigVariationsTestSuiteBuilder.java          |    2 +-
 .../testframework/http/GridEmbeddedHttpServer.java |   10 +-
 .../testframework/junits/GridAbstractTest.java     |   60 +-
 .../apache/ignite/testframework/junits/Repeat.java |    5 +-
 .../junits/common/GridCommonAbstractTest.java      |   11 +-
 .../common/GridRollingRestartAbstractTest.java     |    5 +-
 .../junits/multijvm/IgniteClusterProcessProxy.java |   15 +
 .../IgniteBasicWithPersistenceTestSuite.java       |   15 +-
 .../testsuites/IgniteBinaryObjectsTestSuite.java   |   10 +-
 .../IgniteCacheDataStructuresSelfTestSuite.java    |   17 +
 .../IgniteCacheFullApiSelfTestSuite.java           |   11 +
 .../testsuites/IgniteCacheMvccTestSuite.java       |    2 +
 .../testsuites/IgniteCacheMvccTestSuite5.java      |    2 +
 .../testsuites/IgniteCacheMvccTestSuite6.java      |    4 +-
 .../ignite/testsuites/IgniteCacheTestSuite2.java   |    2 +-
 .../ignite/testsuites/IgniteCacheTestSuite5.java   |    2 +
 .../ignite/testsuites/IgniteCacheTestSuite6.java   |    4 +-
 .../ignite/testsuites/IgniteCacheTestSuite7.java   |    3 +
 .../ignite/testsuites/IgniteCacheTestSuite8.java   |    2 +-
 .../ignite/testsuites/IgniteIgfsTestSuite.java     |   20 +-
 .../testsuites/IgniteMarshallerSelfTestSuite.java  |    1 -
 .../ignite/testsuites/IgniteP2PSelfTestSuite.java  |    6 +-
 .../ignite/testsuites/IgnitePdsMvccTestSuite2.java |    2 +
 .../ignite/testsuites/IgnitePdsMvccTestSuite4.java |    2 +
 .../ignite/testsuites/IgnitePdsTestSuite2.java     |    3 +
 .../ignite/testsuites/IgnitePdsTestSuite4.java     |    9 +-
 .../testsuites/IgniteRestHandlerTestSuite.java     |    4 +-
 .../testsuites/IgniteServiceGridTestSuite.java     |    4 +
 .../IgniteSpiCommunicationSelfTestSuite.java       |    5 +-
 .../ignite/testsuites/IgniteUtilSelfTestSuite.java |    8 +-
 .../ignite/testsuites/SecurityTestSuite.java       |   12 +-
 .../ignite/thread/ThreadPoolMetricsTest.java       |  131 ++
 .../util/GridCommandHandlerAbstractTest.java       |  437 ----
 .../util/GridCommandHandlerClusterByClassTest.java | 1739 ---------------
 .../apache/ignite/util/GridCommandHandlerTest.java | 2151 -------------------
 .../ignite/util/mbeans/GridMBeanBaselineTest.java  |    4 +-
 ...ridCommandHandlerClusterByClassTest_help.output |   31 +
 ...andHandlerClusterByClassWithSSLTest_help.output |   31 +
 modules/core/src/test/resources/tde.jks            |  Bin 813 -> 1033 bytes
 .../modulestest/IgniteLaunchInModularEnvTest.java  |    5 +-
 .../cache/persistence/file/AlignedBuffers.java     |    2 +-
 .../file/AlignedBuffersDirectFileIO.java           |    6 +-
 .../cache/persistence/file/IgniteNativeIoLib.java  |    6 +-
 modules/extdata/p2p/META-INF/ignite.xml            |    2 +-
 .../CacheDeploymentCachePluginConfiguration.java   |    3 +-
 .../ignite/tests/p2p/SingleSplitTestTask.java      |   79 -
 .../tests/p2p/cache/ScanQueryTestTransformer.java  |   42 +
 .../p2p/cache/ScanQueryTestTransformerWrapper.java |   41 +
 .../tests/p2p/classic/SingleSplitTestTask.java     |   80 +
 .../ignite/tests/p2p/compute/ExternalLambda.java   |   40 +
 ...tformTestPluginConfigurationClosureFactory.java |    5 +-
 .../plugin/PlatformTestPluginProvider.java         |    7 +-
 .../plugin/cache/PlatformGetCachePluginsTask.java  |    7 +-
 ...latformTestCachePluginConfigurationClosure.java |    5 +-
 .../cache/PlatformTestCachePluginProvider.java     |    3 +-
 .../uri/tasks/GridUriDeploymentTestTask10.java     |    5 +-
 .../uri/tasks/GridUriDeploymentTestTask11.java     |    5 +-
 .../uri/tasks/GridUriDeploymentTestTask8.java      |    5 +-
 .../uri/tasks/GridUriDeploymentTestTask9.java      |    7 +-
 .../tasks/GridUriDeploymentTestWithNameTask10.java |    5 +-
 .../tasks/GridUriDeploymentTestWithNameTask11.java |    5 +-
 .../tasks/GridUriDeploymentTestWithNameTask8.java  |    5 +-
 .../ignite/tests/p2p/compute/ExternalLambda.java   |   40 +
 .../gce/TcpDiscoveryGoogleStorageIpFinder.java     |   20 +-
 .../testsuites/GeoSpatialIndexingTestSuite.java    |    2 +-
 .../hadoop/fs/BasicHadoopFileSystemFactory.java    |    9 +-
 .../ignite/hadoop/fs/HadoopFileSystemFactory.java  |    3 +-
 .../fs/IgniteHadoopIgfsSecondaryFileSystem.java    |    9 +-
 .../hadoop/fs/KerberosHadoopFileSystemFactory.java |    5 +-
 .../IgniteHadoopWeightedMapReducePlanner.java      |   33 +-
 .../planner/HadoopAbstractMapReducePlanner.java    |   11 +-
 .../ignite/hadoop/util/BasicUserNameMapper.java    |    3 +-
 .../ignite/hadoop/util/ChainedUserNameMapper.java  |    3 +-
 .../apache/ignite/hadoop/util/UserNameMapper.java  |    3 +-
 .../processors/hadoop/HadoopAttributes.java        |   11 +-
 .../processors/hadoop/HadoopCommonUtils.java       |    5 +-
 .../processors/hadoop/HadoopExternalSplit.java     |    5 +-
 .../processors/hadoop/HadoopHelperImpl.java        |    5 +-
 .../processors/hadoop/HadoopProcessor.java         |    9 +-
 .../hadoop/delegate/HadoopDelegateUtils.java       |    7 +-
 .../delegate/HadoopFileSystemFactoryDelegate.java  |    3 +-
 .../hadoop/impl/HadoopMapReduceCounterGroup.java   |    7 +-
 .../hadoop/impl/HadoopMapReduceCounters.java       |   21 +-
 .../processors/hadoop/impl/HadoopUtils.java        |   25 +-
 .../HadoopBasicFileSystemFactoryDelegate.java      |   11 +-
 .../HadoopCachingFileSystemFactoryDelegate.java    |    3 +-
 .../HadoopDefaultFileSystemFactoryDelegate.java    |    3 +-
 .../HadoopFileSystemCounterWriterDelegateImpl.java |    7 +-
 .../HadoopIgfsSecondaryFileSystemDelegateImpl.java |   17 +-
 .../HadoopKerberosFileSystemFactoryDelegate.java   |    5 +-
 .../hadoop/impl/fs/HadoopFileSystemCacheUtils.java |    5 +-
 .../hadoop/impl/fs/HadoopLazyConcurrentMap.java    |    9 +-
 .../hadoop/impl/fs/HadoopLocalFileSystemV1.java    |    3 +-
 .../hadoop/impl/fs/HadoopLocalFileSystemV2.java    |    7 +-
 .../hadoop/impl/fs/HadoopRawLocalFileSystem.java   |   19 +-
 .../processors/hadoop/impl/igfs/HadoopIgfs.java    |    7 +-
 .../processors/hadoop/impl/igfs/HadoopIgfsEx.java  |    3 +-
 .../hadoop/impl/igfs/HadoopIgfsInputStream.java    |    7 +-
 .../hadoop/impl/igfs/HadoopIgfsIpcIo.java          |   27 +-
 .../hadoop/impl/igfs/HadoopIgfsOutProc.java        |    7 +-
 .../hadoop/impl/igfs/HadoopIgfsOutputStream.java   |    5 +-
 .../hadoop/impl/igfs/HadoopIgfsProperties.java     |    3 +-
 .../impl/igfs/HadoopIgfsProxyInputStream.java      |    5 +-
 .../impl/igfs/HadoopIgfsProxyOutputStream.java     |    5 +-
 ...pIgfsSecondaryFileSystemPositionedReadable.java |    3 +-
 .../hadoop/impl/igfs/HadoopIgfsUtils.java          |    5 +-
 .../hadoop/impl/proto/HadoopClientProtocol.java    |    5 +-
 .../hadoop/impl/v1/HadoopV1CleanupTask.java        |    3 +-
 .../processors/hadoop/impl/v1/HadoopV1Counter.java |    7 +-
 .../hadoop/impl/v1/HadoopV1OutputCollector.java    |    3 +-
 .../hadoop/impl/v1/HadoopV1SetupTask.java          |    3 +-
 .../hadoop/impl/v1/HadoopV1Splitter.java           |    9 +-
 .../processors/hadoop/impl/v1/HadoopV1Task.java    |    5 +-
 .../hadoop/impl/v2/HadoopSerializationWrapper.java |   11 +-
 .../hadoop/impl/v2/HadoopV2CleanupTask.java        |    3 +-
 .../processors/hadoop/impl/v2/HadoopV2Context.java |    7 +-
 .../processors/hadoop/impl/v2/HadoopV2Counter.java |    5 +-
 .../processors/hadoop/impl/v2/HadoopV2Job.java     |   39 +-
 .../hadoop/impl/v2/HadoopV2JobResourceManager.java |   21 +-
 .../hadoop/impl/v2/HadoopV2SetupTask.java          |    3 +-
 .../hadoop/impl/v2/HadoopV2Splitter.java           |   13 +-
 .../processors/hadoop/impl/v2/HadoopV2Task.java    |    3 +-
 .../hadoop/impl/v2/HadoopV2TaskContext.java        |   21 +-
 .../impl/v2/HadoopWritableSerialization.java       |    7 +-
 .../hadoop/jobtracker/HadoopJobMetadata.java       |    2 +-
 .../hadoop/jobtracker/HadoopJobTracker.java        |    6 +-
 .../hadoop/mapreduce/MapReduceClient.java          |    7 +-
 .../hadoop/planner/HadoopDefaultMapReducePlan.java |    7 +-
 .../hadoop/planner/HadoopMapReducePlanGroup.java   |    5 +-
 .../planner/HadoopMapReducePlanTopology.java       |    5 +-
 .../processors/hadoop/shuffle/HadoopShuffle.java   |   13 +-
 .../hadoop/shuffle/HadoopShuffleJob.java           |   21 +-
 .../hadoop/shuffle/HadoopShuffleRemoteState.java   |    3 +-
 .../shuffle/direct/HadoopDirectDataInput.java      |    9 +-
 .../shuffle/direct/HadoopDirectDataOutput.java     |    5 +-
 .../direct/HadoopDirectDataOutputContext.java      |    5 +-
 .../hadoop/taskexecutor/HadoopExecutorService.java |    2 +-
 .../external/HadoopExternalTaskExecutor.java       |    4 +-
 .../processors/hadoop/HadoopTestClassLoader.java   |    9 +-
 .../hadoop/impl/HadoopAbstractWordCountTest.java   |    2 +-
 .../hadoop/impl/HadoopCommandLineTest.java         |    2 +-
 .../processors/hadoop/impl/HadoopGroupingTest.java |   21 +-
 .../hadoop/impl/HadoopPlannerMockJob.java          |    7 +-
 .../hadoop/impl/HadoopTaskExecutionSelfTest.java   |    2 +-
 .../processors/hadoop/impl/HadoopTasksV1Test.java  |    2 +-
 .../processors/hadoop/impl/HadoopTasksV2Test.java  |    2 +-
 .../impl/HadoopTasksVersionsAbstractTest.java      |    2 +-
 .../processors/hadoop/impl/HadoopTestUtils.java    |    7 +-
 .../hadoop/impl/HadoopUserLibsSelfTest.java        |    5 +-
 .../hadoop/impl/HadoopV2JobSelfTest.java           |    2 +-
 .../impl/HadoopWeightedMapReducePlannerTest.java   |   27 +-
 .../hadoop/impl/examples/HadoopPopularWords.java   |    2 +-
 .../impl/igfs/HadoopFIleSystemFactorySelfTest.java |   11 +-
 .../impl/igfs/HadoopIgfsDualAbstractSelfTest.java  |    7 +-
 .../HadoopIgfsSecondaryFileSystemTestAdapter.java  |    2 +-
 ...HadoopSecondaryFileSystemConfigurationTest.java |   13 +-
 .../igfs/IgniteHadoopFileSystemLoggerSelfTest.java |   11 +-
 .../HadoopConcurrentHashMultimapSelftest.java      |    4 +-
 .../shuffle/collections/HadoopHashMapSelfTest.java |   11 +-
 .../collections/HadoopSkipListSelfTest.java        |    4 +-
 .../shuffle/streams/HadoopDataStreamSelfTest.java  |    1 -
 .../taskexecutor/HadoopExecutorServiceTest.java    |    5 +-
 .../HadoopExternalTaskExecutionSelfTest.java       |    2 +-
 .../impl/util/BasicUserNameMapperSelfTest.java     |    5 +-
 .../impl/util/ChainedUserNameMapperSelfTest.java   |    5 +-
 .../hadoop/state/HadoopGroupingTestState.java      |    5 +-
 .../state/HadoopJobTrackerSelfTestState.java       |    3 +-
 .../HadoopMapReduceEmbeddedSelfTestState.java      |    3 +-
 .../state/HadoopTaskExecutionSelfTestValues.java   |    3 +-
 .../ignite/testsuites/IgniteHadoopTestSuite.java   |   95 +-
 .../processors/cache/query/QueryTable.java         |    3 +-
 .../processors/query/h2/CommandProcessor.java      |   43 +-
 .../processors/query/h2/CommandResult.java         |    3 +-
 .../processors/query/h2/ConcurrentStripedPool.java |   32 +-
 .../processors/query/h2/ConnectionManager.java     |    7 +-
 .../processors/query/h2/H2DatabaseType.java        |    7 +-
 .../processors/query/h2/H2SqlFieldMetadata.java    |    9 +-
 .../processors/query/h2/H2StatementCache.java      |   22 +-
 .../processors/query/h2/IgniteH2Indexing.java      |   16 +-
 .../processors/query/h2/IndexBuildClosure.java     |    2 +-
 .../query/h2/IndexRebuildPartialClosure.java       |   11 +-
 .../internal/processors/query/h2/UpdateResult.java |    5 +-
 .../processors/query/h2/database/H2TreeIndex.java  |   12 +
 .../query/h2/dml/DmlBulkLoadDataConverter.java     |    3 +-
 .../query/h2/dml/DmlPageProcessingErrorResult.java |    5 +-
 .../query/h2/dml/DmlPageProcessingResult.java      |    3 +-
 .../query/h2/dml/DmlUpdateResultsIterator.java     |    5 +-
 .../processors/query/h2/opt/GridH2ProxyIndex.java  |    5 +-
 .../query/h2/opt/GridH2ProxySpatialIndex.java      |    5 +-
 .../processors/query/h2/opt/GridH2Table.java       |   48 +-
 .../processors/query/h2/opt/GridLuceneIndex.java   |    2 +-
 .../processors/query/h2/opt/H2CacheRow.java        |   19 +-
 .../processors/query/h2/opt/H2TableScanIndex.java  |    3 +-
 .../processors/query/h2/opt/QueryContextKey.java   |    3 +-
 .../query/h2/opt/join/BroadcastCursor.java         |    9 +-
 .../query/h2/opt/join/CursorIteratorWrapper.java   |    3 +-
 .../query/h2/opt/join/DistributedJoinContext.java  |    7 +-
 .../h2/opt/join/ProxyDistributedLookupBatch.java   |    5 +-
 .../processors/query/h2/opt/join/RangeSource.java  |    7 +-
 .../processors/query/h2/opt/join/RangeStream.java  |   13 +-
 .../query/h2/sql/GridSqlQueryParser.java           |    2 +-
 .../query/h2/sql/SplitterQueryModel.java           |    5 +-
 .../processors/query/h2/sql/SplitterUtils.java     |    3 +-
 .../processors/query/h2/sys/SqlSystemIndex.java    |    3 +-
 .../processors/query/h2/twostep/MapRequestKey.java |    3 +-
 .../query/h2/twostep/PartitionReservation.java     |    5 +-
 .../h2/twostep/ReducePartitionsSpecializer.java    |    3 +-
 .../query/h2/twostep/ReduceSourceKey.java          |    3 +-
 .../query/h2/twostep/ReduceTableEngine.java        |    7 +-
 .../visor/verify/ValidateIndexesClosure.java       |    3 +-
 .../org/apache/ignite/client/ClientTestSuite.java  |    2 +
 .../apache/ignite/client/FunctionalQueryTest.java  |   36 +-
 ...aryMetadataConcurrentUpdateWithIndexesTest.java |    2 +-
 .../cache/BinarySerializationQuerySelfTest.java    |   23 +-
 .../cache/CacheIteratorScanQueryTest.java          |    7 +-
 .../cache/CacheRegisterMetadataLocallyTest.java    |    2 +-
 .../ClientReconnectAfterClusterRestartTest.java    |    2 +-
 .../GridCacheSqlDdlClusterReadOnlyModeTest.java    |  172 ++
 .../IgniteCacheAbstractFieldsQuerySelfTest.java    |    4 +-
 ...gniteCacheJoinPartitionedAndReplicatedTest.java |   11 +-
 .../IgniteCacheLockPartitionOnAffinityRunTest.java |    2 +-
 .../IgniteCachePrimitiveFieldsQuerySelfTest.java   |    5 +-
 .../cache/IgniteCacheQueryH2IndexingLeakTest.java  |  202 +-
 .../IgniteDynamicEnableIndexingRestoreTest.java    |  274 +++
 ...ingleNodeWithIndexingPutGetPersistenceTest.java |    2 +-
 .../cache/QueryEntityCaseMismatchTest.java         |    9 +-
 ...acheDistributedQueryDefaultTimeoutSelfTest.java |    2 +-
 ...tributedQueryStopOnCancelOrTimeoutSelfTest.java |    2 +-
 .../near/IgniteSqlQueryWithBaselineTest.java       |    4 +-
 .../cache/index/AbstractSchemaSelfTest.java        |    2 +-
 .../index/DynamicEnableIndexingAbstractTest.java   |  305 +++
 .../index/DynamicEnableIndexingBasicSelfTest.java  |  160 ++
 .../DynamicEnableIndexingConcurrentSelfTest.java   |  636 ++++++
 .../cache/index/H2DynamicTableSelfTest.java        |  104 +-
 .../cache/index/H2RowCachePageEvictionTest.java    |    1 +
 .../index/IoStatisticsBasicIndexSelfTest.java      |    2 +-
 .../cache/index/QueryEntityValidationSelfTest.java |   68 +
 ...niteCacheLocalQueryCancelOrTimeoutSelfTest.java |    2 +-
 .../cache/metric/SqlViewExporterSpiTest.java       |  196 +-
 .../cache/mvcc/CacheMvccTxNodeMappingTest.java     |    4 +-
 .../cache/mvcc/MvccRepeatableReadBulkOpsTest.java  |    6 +-
 .../db/IgniteCacheGroupsWithRestartsTest.java      |   35 +-
 .../persistence/db/wal/IgniteWalRecoveryTest.java  |  200 +-
 .../IgniteClusterSnapshotWithIndexesTest.java      |   15 +-
 .../ttl/CacheTtlAtomicPartitionedSelfTest.java     |    2 +-
 ...ntConnectorConfigurationValidationSelfTest.java |   17 +-
 .../processors/client/IgniteDataStreamerTest.java  |    2 +
 .../query/CreateIndexOnInvalidDataTypeTest.java    |  207 ++
 .../query/IgniteQueryDedicatedPoolTest.java        |    2 +-
 .../processors/query/RunningQueriesTest.java       |    2 +-
 .../query/SqlNotNullKeyValueFieldTest.java         |  122 ++
 .../query/SqlPartOfComplexPkLookupTest.java        |    2 +-
 .../processors/query/SqlSystemViewsSelfTest.java   |   22 +-
 .../query/h2/GridIndexFullRebuildTest.java         |    2 +-
 .../query/h2/GridIndexRebuildSelfTest.java         |   66 +-
 .../query/h2/sql/ParameterTypeInferenceTest.java   |   11 +-
 .../IgniteBinaryCacheQueryTestSuite.java           |    6 +-
 .../IgniteBinaryCacheQueryTestSuite2.java          |    8 +
 .../testsuites/IgniteCacheMvccSqlTestSuite.java    |    2 +-
 .../testsuites/IgniteCacheQuerySelfTestSuite3.java |    4 +-
 .../testsuites/IgniteCacheQuerySelfTestSuite6.java |    2 +-
 ...teCacheWithIndexingAndPersistenceTestSuite.java |   14 -
 .../IgniteCacheWithIndexingTestSuite.java          |    2 +
 ...idCommandHandlerIndexingClusterByClassTest.java |  197 --
 .../util/GridCommandHandlerIndexingTest.java       |  347 ---
 .../ignite/util/KillCommandsCommandShTest.java     |  176 --
 .../apache/ignite/util/KillCommandsMXBeanTest.java |   51 +-
 .../apache/ignite/util/KillCommandsSQLTest.java    |    5 +-
 .../org/apache/ignite/util/KillCommandsTests.java  |    8 +-
 .../stream/jms11/IgniteJmsStreamerTestSuite.java   |    4 +-
 .../cache/jta/AbstractCacheJtaSelfTest.java        |    4 +-
 .../ignite/testsuites/IgniteJtaTestSuite.java      |    2 +-
 .../ignite/stream/kafka/TestKafkaBroker.java       |    4 +-
 .../kubernetes/TcpDiscoveryKubernetesIpFinder.java |   26 +-
 .../ignite/mesos/resource/IgniteProvider.java      |    4 +-
 .../org/apache/ignite/ml/h2o/H2OMojoModel.java     |    7 +-
 .../apache/ignite/ml/h2o/H2OMojoModelParser.java   |    5 +-
 .../gmm/CovarianceMatricesAggregator.java          |    9 +-
 .../gmm/NewComponentStatisticsAggregator.java      |    3 +-
 .../ignite/ml/dataset/feature/ObjectHistogram.java |    6 +-
 .../BootstrappedDatasetPartition.java              |    3 +-
 .../impl/bootstrapping/BootstrappedVector.java     |    5 +-
 .../ignite/ml/dataset/primitive/SimpleDataset.java |    2 +-
 .../ignite/ml/knn/NNClassificationModel.java       |    2 +-
 .../main/java/org/apache/ignite/ml/math/Blas.java  |    2 +-
 .../ml/math/distances/ChebyshevDistance.java       |   31 +
 .../ignite/ml/math/distances/CosineSimilarity.java |   31 +
 .../ignite/ml/math/distances/DistanceMeasure.java  |   22 +-
 .../ml/math/distances/EuclideanDistance.java       |   16 +-
 .../ignite/ml/math/distances/HammingDistance.java  |   18 -
 .../ignite/ml/math/distances/JaccardIndex.java     |   41 +
 .../ml/math/distances/ManhattanDistance.java       |   18 -
 .../ml/math/distances/MinkowskiDistance.java       |   63 +
 .../ignite/ml/math/isolve/lsqr/AbstractLSQR.java   |    2 +-
 .../ignite/ml/math/isolve/lsqr/LSQROnHeap.java     |    2 +-
 .../matrix/storage/SparseMatrixStorage.java        |    8 +-
 .../math/primitives/vector/impl/SparseVector.java  |    2 +-
 .../vector/storage/SparseVectorStorage.java        |    4 +-
 .../apache/ignite/ml/math/stat/Distribution.java   |    3 +-
 .../ignite/ml/math/stat/DistributionMixture.java   |    7 +-
 .../ignite/ml/multiclass/MultiClassModel.java      |    7 +-
 .../discrete/DiscreteNaiveBayesModel.java          |    5 +-
 .../gaussian/GaussianNaiveBayesModel.java          |    5 +-
 .../updatecalculators/RPropParameterUpdate.java    |    9 +-
 .../updatecalculators/SimpleGDParameterUpdate.java |    7 +-
 .../ml/selection/cv/DebugCrossValidation.java      |    3 +-
 .../scoring/cursor/LocalLabelPairCursor.java       |    7 +-
 .../selection/scoring/evaluator/package-info.java  |    4 +-
 .../randomforest/data/impurity/GiniHistogram.java  |   13 +-
 .../data/impurity/ImpurityHistogram.java           |    3 +-
 .../data/impurity/ImpurityHistogramsComputer.java  |   13 +-
 .../randomforest/data/impurity/MSEHistogram.java   |    9 +-
 .../data/statistics/LeafValuesComputer.java        |   13 +-
 .../NormalDistributionStatisticsComputer.java      |    9 +-
 .../primitives/vector/VectorGenerator.java         |   15 +-
 .../primitives/vector/VectorGeneratorsFamily.java  |    9 +-
 .../apache/ignite/ml/common/KeepBinaryTest.java    |    3 +-
 .../convergence/ConvergenceCheckerTest.java        |    7 +-
 .../deploy/DeployingContextImplTest.java           |    2 +-
 .../apache/ignite/ml/knn/LabeledDatasetHelper.java |    5 +-
 .../ignite/ml/math/MathImplLocalTestSuite.java     |    4 +
 .../ml/math/distances/CosineSimilarityTest.java    |   41 +
 .../ignite/ml/math/distances/DistanceTest.java     |  108 +-
 .../ignite/ml/math/distances/JaccardIndexTest.java |   43 +
 .../ignite/ml/nn/MLPTrainerIntegrationTest.java    |   10 +-
 .../org/apache/ignite/ml/nn/MLPTrainerTest.java    |   18 +-
 .../ml/selection/cv/CrossValidationTest.java       |    9 +-
 .../gini/GiniImpurityMeasureCalculatorTest.java    |    2 +-
 .../mse/MSEImpurityMeasureCalculatorTest.java      |    2 +-
 .../data/impurity/MSEHistogramTest.java            |    5 +-
 modules/mqtt/README.txt                            |   29 -
 modules/mqtt/licenses/apache-2.0.txt               |  202 --
 modules/mqtt/pom.xml                               |  123 --
 .../apache/ignite/stream/mqtt/MqttStreamer.java    |  709 ------
 .../apache/ignite/stream/mqtt/package-info.java    |   22 -
 .../ignite/stream/mqtt/IgniteMqttStreamerTest.java |  649 ------
 .../stream/mqtt/IgniteMqttStreamerTestSuite.java   |   32 -
 .../apache/ignite/stream/mqtt/package-info.java    |   22 -
 .../opencensus/OpenCensusMetricExporterSpi.java    |   14 +-
 .../OpenCensusMetricExporterSpiTest.java           |    4 +-
 .../org/apache/ignite/osgi/IgniteOsgiUtils.java    |    2 +-
 modules/platforms/cpp/CMakeLists.txt               |   83 +
 modules/platforms/cpp/DEVNOTES.txt                 |   77 +-
 modules/platforms/cpp/Makefile.am                  |   77 -
 modules/platforms/cpp/Makefile.amrel               |   59 -
 modules/platforms/cpp/binary/CMakeLists.txt        |   73 +
 modules/platforms/cpp/binary/Makefile.am           |   74 -
 modules/platforms/cpp/binary/configure.ac          |   62 -
 modules/platforms/cpp/binary/include/Makefile.am   |   51 -
 modules/platforms/cpp/cmake/FindIgnite.cmake       |   45 +
 modules/platforms/cpp/cmake/FindODBC.cmake         |  148 ++
 modules/platforms/cpp/common/CMakeLists.txt        |   81 +
 modules/platforms/cpp/common/Makefile.am           |   63 -
 modules/platforms/cpp/common/configure.ac          |   62 -
 modules/platforms/cpp/common/include/Makefile.am   |   45 -
 .../cpp/common/os/linux/include/Makefile.am        |   25 -
 .../os/linux/include/ignite/common/concurrent_os.h |    6 +-
 .../common/os/linux/src/common/platform_utils.cpp  |    5 +-
 modules/platforms/cpp/configure.ac                 |  126 --
 modules/platforms/cpp/configure.acrel              |  109 -
 modules/platforms/cpp/core-test/CMakeLists.txt     |   76 +
 modules/platforms/cpp/core-test/Makefile.am        |   96 -
 modules/platforms/cpp/core-test/configure.ac       |   62 -
 .../platforms/cpp/core-test/include/Makefile.am    |   24 -
 modules/platforms/cpp/core/CMakeLists.txt          |   54 +
 modules/platforms/cpp/core/Makefile.am             |   85 -
 modules/platforms/cpp/core/configure.ac            |   62 -
 modules/platforms/cpp/core/ignite.pc.in            |    9 -
 modules/platforms/cpp/core/include/Makefile.am     |   82 -
 modules/platforms/cpp/examples/CMakeLists.txt      |   36 +
 modules/platforms/cpp/examples/Makefile.am         |   28 -
 modules/platforms/cpp/examples/README.txt          |   21 +-
 .../cpp/examples/compute-example/CMakeLists.txt    |   31 +
 .../cpp/examples/compute-example/Makefile.am       |   59 -
 modules/platforms/cpp/examples/configure.ac        |   64 -
 .../continuous-query-example/CMakeLists.txt        |   31 +
 .../examples/continuous-query-example/Makefile.am  |   58 -
 modules/platforms/cpp/examples/include/Makefile.am |   24 -
 .../cpp/examples/odbc-example/CMakeLists.txt       |   33 +
 .../cpp/examples/odbc-example/Makefile.am          |   59 -
 .../cpp/examples/put-get-example/CMakeLists.txt    |   31 +
 .../cpp/examples/put-get-example/Makefile.am       |   58 -
 .../cpp/examples/query-example/CMakeLists.txt      |   31 +
 .../cpp/examples/query-example/Makefile.am         |   58 -
 .../thin-client-put-get-example/CMakeLists.txt     |   28 +
 .../thin-client-put-get-example/Makefile.am        |   53 -
 modules/platforms/cpp/ignite/CMakeLists.txt        |   32 +
 modules/platforms/cpp/ignite/Makefile.am           |   61 -
 modules/platforms/cpp/ignite/configure.ac          |   62 -
 modules/platforms/cpp/jni/CMakeLists.txt           |   43 +
 modules/platforms/cpp/jni/Makefile.am              |   65 -
 modules/platforms/cpp/jni/configure.ac             |   62 -
 modules/platforms/cpp/jni/include/Makefile.am      |   25 -
 modules/platforms/cpp/jni/os/linux/src/utils.cpp   |   33 +-
 modules/platforms/cpp/jni/os/win/src/utils.cpp     |   24 +-
 modules/platforms/cpp/network/CMakeLists.txt       |   74 +
 modules/platforms/cpp/network/Makefile.am          |   63 -
 modules/platforms/cpp/network/configure.ac         |   62 -
 modules/platforms/cpp/network/include/Makefile.am  |   28 -
 .../os/linux/src/network/tcp_socket_client.cpp     |    5 +-
 .../cpp/network/src/network/ssl/ssl_gateway.cpp    |   16 +-
 modules/platforms/cpp/odbc-test/CMakeLists.txt     |  104 +
 modules/platforms/cpp/odbc-test/Makefile.am        |  127 --
 modules/platforms/cpp/odbc-test/config/ssl/ca.pem  |   50 +-
 .../cpp/odbc-test/config/ssl/client_full.pem       |  132 +-
 .../cpp/odbc-test/config/ssl/client_unknown.pem    |   94 +-
 .../odbc-test/config/ssl/generate_certificates.sh  |  119 +
 .../platforms/cpp/odbc-test/config/ssl/server.jks  |  Bin 4256 -> 2392 bytes
 .../platforms/cpp/odbc-test/config/ssl/trust.jks   |  Bin 1089 -> 1199 bytes
 .../platforms/cpp/odbc-test/include/Makefile.am    |   26 -
 modules/platforms/cpp/odbc/CMakeLists.txt          |  108 +
 modules/platforms/cpp/odbc/Makefile.am             |  106 -
 modules/platforms/cpp/odbc/configure.ac            |   62 -
 modules/platforms/cpp/odbc/include/Makefile.am     |   73 -
 .../platforms/cpp/thin-client-test/CMakeLists.txt  |   53 +
 modules/platforms/cpp/thin-client-test/Makefile.am |   79 -
 .../cpp/thin-client-test/config/ssl/ca.pem         |   50 +-
 .../thin-client-test/config/ssl/client_full.pem    |  132 +-
 .../thin-client-test/config/ssl/client_unknown.pem |   94 +-
 .../config/ssl/generate_certificates.sh            |  119 +
 .../cpp/thin-client-test/config/ssl/server.jks     |  Bin 4256 -> 2392 bytes
 .../cpp/thin-client-test/config/ssl/trust.jks      |  Bin 1089 -> 1199 bytes
 .../platforms/cpp/thin-client-test/configure.ac    |   62 -
 .../cpp/thin-client-test/include/Makefile.am       |   24 -
 modules/platforms/cpp/thin-client/CMakeLists.txt   |   48 +
 modules/platforms/cpp/thin-client/Makefile.am      |   75 -
 .../platforms/cpp/thin-client/include/Makefile.am  |   32 -
 .../ExpiryCacheHolderTest.cs                       |    7 +-
 .../Apache.Ignite.Core.Tests.DotNetCore.csproj     |   37 +
 .../Common/TestRunner.cs                           |    2 +-
 .../Apache.Ignite.Core.Tests.csproj                |    3 +
 .../ApiParity/ClusterParityTest.cs                 |    4 +-
 .../Cache/CacheAbstractTransactionalTest.cs        |   55 +-
 .../Cache/CacheTestAsyncWrapper.cs                 |    8 +-
 .../Cache/OptimisticTransactionTest.cs             |  134 ++
 .../Cache/Platform/PlatformCacheTest.cs            |  277 +--
 .../Cache/Query/CacheQueriesTest.cs                |   42 +-
 .../Continuous/ContinuousQueryAbstractTest.cs      |  142 +-
 .../Continuous/ContinuousQueryAtomicBackupTest.cs  |    7 +-
 .../ContinuousQueryAtomicNoBackupTest.cs           |    7 +-
 .../ContinuousQueryNoBackupAbstractTest.cs         |    3 +-
 .../ContinuousQueryTransactionalBackupTest.cs      |    3 +
 .../ContinuousQueryTransactionalNoBackupTest.cs    |    3 +
 .../Client/ClientConnectionTest.cs                 |   48 +-
 .../Client/Compute/ComputeClientTests.cs           |  134 +-
 .../IgniteConfigurationTest.cs                     |    2 +-
 .../IgniteLockFailoverTests.cs                     |  105 +
 .../Apache.Ignite.Core.Tests/IgniteLockTests.cs    |  329 +++
 .../Process/ListDataReader.cs                      |    5 +
 .../Services/CallPlatformServiceTest.cs            |   37 +-
 .../Services/ServicesTest.cs                       |  173 +-
 .../dotnet/Apache.Ignite.Core.Tests/TestBase.cs    |   31 +-
 .../Apache.Ignite.Core.Tests/TestUtils.Common.cs   |   33 +-
 .../Apache.Ignite.Core/Apache.Ignite.Core.csproj   |    5 +
 .../dotnet/Apache.Ignite.Core/Cache/ICache.cs      |   42 +-
 .../Query/Continuous/IContinuousQueryHandle.cs     |    2 +-
 .../Continuous/IContinuousQueryHandleFields.cs     |   37 +
 .../Apache.Ignite.Core/Cache/Query/QueryBase.cs    |   17 +-
 .../Cache/Query/SqlFieldsQuery.cs                  |   43 +-
 .../Apache.Ignite.Core/Client/ClientStatusCode.cs  |   12 +-
 .../Configuration/LockConfiguration.cs             |   68 +
 .../platforms/dotnet/Apache.Ignite.Core/IIgnite.cs |   33 +-
 .../dotnet/Apache.Ignite.Core/IIgniteLock.cs       |   81 +
 .../Apache.Ignite.Core/Impl/Cache/CacheImpl.cs     |  148 +-
 .../Query/Continuous/ContinuousQueryHandleImpl.cs  |   53 +-
 .../Impl/Cache/Query/FieldsQueryCursor.cs          |   20 +-
 .../Impl/Cache/Query/IQueryBaseInternal.cs         |   39 +
 .../Impl/Cache/Query/QueryCursorBase.cs            |   96 +-
 .../Impl/Client/Cache/CacheClient.cs               |   28 +-
 .../Client/Cache/Query/ClientFieldsQueryCursor.cs  |    6 +-
 .../Impl/Client/Cache/Query/ClientQueryCursor.cs   |    6 +-
 .../Client/Cache/Query/ClientQueryCursorBase.cs    |   19 +-
 .../Impl/Client/ClientNotificationHandler.cs       |   25 +-
 .../Apache.Ignite.Core/Impl/Client/ClientSocket.cs |   67 +-
 .../Impl/Client/Compute/ComputeClient.cs           |   59 +-
 .../Apache.Ignite.Core/Impl/Common/Classpath.cs    |    9 +-
 .../Impl/Common/DelegateConverter.cs               |   65 +-
 .../Apache.Ignite.Core/Impl/ExceptionUtils.cs      |    6 +-
 .../dotnet/Apache.Ignite.Core/Impl/Ignite.cs       |   37 +-
 .../dotnet/Apache.Ignite.Core/Impl/IgniteLock.cs   |  114 +
 .../Impl/Transactions/CacheTransactionManager.cs   |   24 +-
 .../Impl/Unmanaged/UnmanagedCallbacks.cs           |    2 +
 .../Apache.Ignite.DotNetCore.sln.DotSettings       |    2 +
 .../http/jetty/GridJettyObjectMapper.java          |   12 +-
 .../protocols/http/jetty/GridJettyRestHandler.java |    6 +-
 .../jetty/IgniteBinaryObjectJsonDeserializer.java  |    8 +-
 .../protocols/http/jetty/RestSetupSimpleTest.java  |    4 +-
 modules/rocketmq/README.txt                        |   25 -
 modules/rocketmq/pom.xml                           |   94 -
 .../ignite/stream/rocketmq/RocketMQStreamer.java   |  151 --
 .../ignite/stream/rocketmq/package-info.java       |   21 -
 .../stream/rocketmq/RocketMQStreamerTest.java      |  215 --
 .../stream/rocketmq/RocketMQStreamerTestSuite.java |   31 -
 .../ignite/stream/rocketmq/TestRocketMQServer.java |  148 --
 .../ignite/stream/rocketmq/package-info.java       |   21 -
 .../schedule/IgniteScheduleProcessor.java          |    2 +-
 .../processors/schedule/ScheduleFutureImpl.java    |    8 +-
 .../spark/JavaStandaloneIgniteRDDSelfTest.java     |    7 +-
 .../spark/JavaStandaloneIgniteRDDSelfTest.java     |    7 +-
 modules/spring-data-2.0/README.txt                 |   15 +
 modules/spring-data-2.0/pom.xml                    |    6 +
 .../springdata20/repository/IgniteRepository.java  |   73 +-
 .../repository/config/DynamicQueryConfig.java      |  348 +++
 .../config/EnableIgniteRepositories.java           |    4 +-
 .../IgniteRepositoryConfigurationExtension.java    |    2 +-
 .../springdata20/repository/config/Query.java      |  106 +-
 .../repository/config/RepositoryConfig.java        |   38 +-
 .../repository/query/DeclaredQuery.java            |   96 +
 .../repository/query/EmptyDeclaredQuery.java       |   74 +
 .../query/ExpressionBasedStringQuery.java          |  153 ++
 .../springdata20/repository/query/IgniteQuery.java |   74 +-
 .../repository/query/IgniteQueryGenerator.java     |   33 +-
 .../repository/query/IgniteRepositoryQuery.java    |  955 ++++++++-
 .../springdata20/repository/query/QueryUtils.java  |  307 +++
 .../springdata20/repository/query/StringQuery.java |  879 ++++++++
 .../repository/query/spel/SpelEvaluator.java       |   96 +
 .../repository/query/spel/SpelQueryContext.java    |  342 +++
 .../repository/support/ConditionFalse.java         |    5 +-
 .../support/IgniteRepositoryFactory.java           |  195 +-
 .../support/IgniteRepositoryFactoryBean.java       |   58 +-
 .../repository/support/IgniteRepositoryImpl.java   |  129 +-
 .../IgniteSpringDataCrudSelfExpressionTest.java    |   49 +-
 .../springdata/IgniteSpringDataCrudSelfTest.java   |  154 +-
 .../IgniteSpringDataQueriesSelfTest.java           |  102 +-
 .../springdata/misc/ApplicationConfiguration.java  |   53 +-
 .../ignite/springdata/misc/CacheNamesBean.java     |   11 +-
 .../ignite/springdata/misc/FullNameProjection.java |   33 +
 .../org/apache/ignite/springdata/misc/Person.java  |   18 +-
 .../apache/ignite/springdata/misc/PersonKey.java   |   54 +
 .../ignite/springdata/misc/PersonProjection.java   |   43 +
 .../ignite/springdata/misc/PersonRepository.java   |   39 +-
 .../misc/PersonRepositoryOtherIgniteInstance.java  |  143 ++
 .../misc/PersonRepositoryWithCompoundKey.java      |   28 +
 .../springdata/misc/PersonSecondRepository.java    |    2 +-
 .../misc/SampleEvaluationContextExtension.java     |   92 +
 modules/spring-data-2.2/README.txt                 |   15 +
 modules/spring-data-2.2/pom.xml                    |    6 +
 .../springdata22/repository/IgniteRepository.java  |   73 +-
 .../repository/config/DynamicQueryConfig.java      |  348 +++
 .../config/EnableIgniteRepositories.java           |    5 +-
 .../config/IgniteRepositoriesRegistar.java         |    1 +
 .../IgniteRepositoryConfigurationExtension.java    |    2 +-
 .../springdata22/repository/config/Query.java      |  105 +-
 .../repository/config/RepositoryConfig.java        |   38 +
 .../repository/query/DeclaredQuery.java            |   96 +
 .../repository/query/EmptyDeclaredQuery.java       |   74 +
 .../query/ExpressionBasedStringQuery.java          |  153 ++
 .../springdata22/repository/query/IgniteQuery.java |   74 +-
 .../repository/query/IgniteQueryGenerator.java     |   33 +-
 .../repository/query/IgniteRepositoryQuery.java    |  955 ++++++++-
 .../springdata22/repository/query/QueryUtils.java  |  307 +++
 .../springdata22/repository/query/StringQuery.java |  879 ++++++++
 .../repository/support/ConditionFalse.java         |    5 +-
 .../support/IgniteRepositoryFactory.java           |  195 +-
 .../support/IgniteRepositoryFactoryBean.java       |   58 +-
 .../repository/support/IgniteRepositoryImpl.java   |  129 +-
 .../IgniteSpringDataCrudSelfExpressionTest.java    |   50 +-
 .../springdata/IgniteSpringDataCrudSelfTest.java   |  158 +-
 .../IgniteSpringDataQueriesSelfTest.java           |  102 +-
 .../springdata/misc/ApplicationConfiguration.java  |   53 +-
 .../ignite/springdata/misc/CacheNamesBean.java     |   12 +-
 .../ignite/springdata/misc/FullNameProjection.java |   33 +
 .../org/apache/ignite/springdata/misc/Person.java  |   18 +-
 .../apache/ignite/springdata/misc/PersonKey.java   |   54 +
 .../ignite/springdata/misc/PersonProjection.java   |   43 +
 .../ignite/springdata/misc/PersonRepository.java   |   40 +-
 .../misc/PersonRepositoryOtherIgniteInstance.java  |  143 ++
 .../misc/PersonRepositoryWithCompoundKey.java      |   28 +
 .../springdata/misc/PersonSecondRepository.java    |    3 +-
 .../misc/SampleEvaluationContextExtension.java     |   93 +
 .../repository/query/IgniteRepositoryQuery.java    |   72 +-
 .../repository/support/IgniteRepositoryImpl.java   |   51 +-
 .../springdata/IgniteSpringDataCrudSelfTest.java   |  169 +-
 .../IgniteSpringDataQueriesSelfTest.java           |    2 +-
 .../springdata/misc/ApplicationConfiguration.java  |   25 +-
 .../org/apache/ignite/springdata/misc/Person.java  |   19 +-
 .../apache/ignite/springdata/misc/PersonKey.java   |   54 +
 .../ignite/springdata/misc/PersonRepository.java   |    7 +-
 .../misc/PersonRepositoryWithCompoundKey.java      |   28 +
 .../GridServiceInjectionSpringResourceTest.java    |   13 +-
 .../ignite/testsuites/IgniteSpringTestSuite.java   |   12 +-
 .../util/nodestart/StartNodeCallableImpl.java      |   10 +-
 .../tools/ant/beautifier/GridJavadocAntTask.java   |    5 +-
 .../ignite/tools/javadoc/IgniteLinkTaglet.java     |  109 +-
 .../ignite/tools/javadoc/IgniteLinkTaglet.java     |    4 +-
 .../visor/commands/start/VisorStartCommand.scala   |    4 +-
 .../apache/ignite/console/agent/AgentLauncher.java |    6 +-
 .../apache/ignite/console/agent/AgentUtils.java    |    6 +-
 .../console/agent/handlers/AbstractListener.java   |    6 +-
 .../console/agent/handlers/ClusterListener.java    |    6 +-
 .../console/agent/handlers/DatabaseListener.java   |    2 +-
 .../ignite/console/agent/rest/RestExecutor.java    |    4 +-
 .../ignite/console/demo/AgentClusterDemo.java      |    6 +-
 .../console/agent/rest/RestExecutorSelfTest.java   |    6 +-
 .../apache/ignite/webtest/TestJtaTxServlet.java    |    2 +-
 .../ignite/cache/websession/WebSessionV2.java      |   21 +-
 .../internal/websession/WebSessionSelfTest.java    |   20 +-
 .../config/benchmark-thin-services.properties      |   78 +
 .../yardstick/config/ignite-services-config.xml    |   51 +
 .../ignite/yardstick/IgniteAbstractBenchmark.java  |    2 +-
 .../ignite/yardstick/IgniteBenchmarkArguments.java |    6 +-
 .../cache/IgniteCreateIndexBenchmark.java          |   17 +-
 .../cache/IgniteInvokeWithInjectionBenchmark.java  |    5 +-
 .../cache/IgnitePutGetWithPageReplacements.java    |   13 +-
 .../yardstick/cache/IgnitePutValue8Benchmark.java  |    3 +-
 .../cache/WaitMapExchangeFinishCallable.java       |    2 +-
 .../failover/IgniteFailoverAbstractBenchmark.java  |    2 +-
 .../IgniteThinServiceInvocationBenchmark.java      |   45 +
 .../yardstick/thin/service/SimpleService.java      |   28 +
 .../yardstick/thin/service/SimpleServiceImpl.java  |   46 +
 .../yardstick/upload/UploadBenchmarkArguments.java |    2 +-
 .../zk/ZookeeperDiscoverySpiTestSuite2.java        |    6 +-
 parent/pom.xml                                     |   35 +-
 pom.xml                                            |  105 +-
 1587 files changed, 51586 insertions(+), 21819 deletions(-)

diff --cc modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/query/PlatformContinuousQueryImpl.java
index 67dedc5,f9269a4..aac092e
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/query/PlatformContinuousQueryImpl.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/query/PlatformContinuousQueryImpl.java
@@@ -250,6 -227,66 +227,74 @@@ public class PlatformContinuousQueryImp
      }
  
      /**
+      * Gets the initial query cursor.
+      *
+      * @param initialQry Initial query.
+      * @return Cursor.
+      */
+     private PlatformAbstractQueryCursor getInitialQueryCursor(Query initialQry) {
+         if (initialQry == null)
+             return null;
+ 
+         int batchSize = initialQry.getPageSize() > 0 ? initialQry.getPageSize() : Query.DFLT_PAGE_SIZE;
+ 
+         if (initialQry instanceof SqlFieldsQuery)
+             return new PlatformFieldsQueryCursor(platformCtx, new QueryCursorEx<List<?>>() {
+                 @Override public Iterator<List<?>> iterator() {
+                     return cursor.iterator();
+                 }
+ 
+                 @Override public List<List<?>> getAll() {
+                     return cursor.getAll();
+                 }
+ 
+                 @Override public void close() {
+                     // No-op: do not close whole continuous query when initial query cursor closes.
+                 }
+ 
+                 @Override public void getAll(Consumer<List<?>> clo) throws IgniteCheckedException {
+                     for (List t : this)
+                         clo.consume(t);
+                 }
+ 
+                 @Override public List<GridQueryFieldMetadata> fieldsMeta() {
+                     return ((QueryCursorEx)cursor).fieldsMeta();
+                 }
++
++                @Override public boolean isQuery() {
++                    return false;
++                }
+             }, batchSize);
+ 
+         return new PlatformQueryCursor(platformCtx, new QueryCursorEx<Cache.Entry>() {
+             @Override public Iterator<Cache.Entry> iterator() {
+                 return cursor.iterator();
+             }
+ 
+             @Override public List<Cache.Entry> getAll() {
+                 return cursor.getAll();
+             }
+ 
+             @Override public void close() {
+                 // No-op: do not close whole continuous query when initial query cursor closes.
+             }
+ 
+             @Override public void getAll(Consumer<Cache.Entry> clo) throws IgniteCheckedException {
+                 for (Cache.Entry t : this)
+                     clo.consume(t);
+             }
+ 
+             @Override public List<GridQueryFieldMetadata> fieldsMeta() {
+                 return null;
+             }
++
++            @Override public boolean isQuery() {
++                return false;
++            }
+         }, batchSize);
+     }
+ 
+     /**
       * Internal close routine.
       */
      private void close0() {
diff --cc pom.xml
index fc5cf8f,deb91fe..3bbee8f
--- a/pom.xml
+++ b/pom.xml
@@@ -95,7 -93,7 +93,8 @@@
          <module>modules/ml/xgboost-model-parser</module>
          <module>modules/ml/h2o-model-parser</module>
          <module>modules/opencensus</module>
+         <module>modules/control-utility</module>
 +        <module>modules/calcite</module>
      </modules>
  
      <profiles>


Mime
View raw message