You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by gv...@apache.org on 2020/07/13 11:20:01 UTC
[ignite] 01/02: Merge branch 'master' into ignite-12248
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 <gv...@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>