Merge branch ignite-gg-8.0.4.ea2 into ignite-gg-12163
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/b0a53669 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/b0a53669 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/b0a53669 Branch: refs/heads/ignite-5075-pds Commit: b0a5366942323eecd93aae22517899a27e6a12c4 Parents: 6ec62bb 59bc11b Author: Alexey Goncharuk <[email protected]> Authored: Fri May 19 13:27:24 2017 +0300 Committer: Alexey Goncharuk <[email protected]> Committed: Fri May 19 13:27:24 2017 +0300 ---------------------------------------------------------------------- RELEASE_NOTES.txt | 36 + assembly/dependencies-fabric.xml | 5 +- examples/config/example-cache.xml | 1 + examples/config/example-memory-policies.xml | 22 +- examples/pom-standalone-lgpl.xml | 2 +- examples/pom-standalone.xml | 2 +- examples/pom.xml | 38 +- examples/rest/http-rest-example.php | 4 +- .../hibernate/HibernateL2CacheExample.java | 12 +- .../examples/datagrid/CacheQueryExample.java | 54 +- .../datagrid/MemoryPoliciesExample.java | 16 +- .../client/memcache/MemcacheRestExample.java | 2 +- .../MemcacheRestExampleNodeStartup.java | 1 + .../streaming/wordcount/QueryWords.java | 3 +- .../ml/math/matrix/CacheMatrixExample.java | 23 +- .../ml/math/matrix/ExampleMatrixStorage.java | 3 +- .../math/matrix/MatrixCustomStorageExample.java | 6 +- .../examples/ml/math/matrix/MatrixExample.java | 4 +- .../ml/math/matrix/OffHeapMatrixExample.java | 6 +- .../matrix/SparseDistributedMatrixExample.java | 8 +- .../ml/math/matrix/SparseMatrixExample.java | 4 +- .../examples/ml/math/tracer/TracerExample.java | 2 +- .../ml/math/vector/CacheVectorExample.java | 19 +- .../ml/math/vector/ExampleVectorStorage.java | 7 +- .../ml/math/vector/OffHeapVectorExample.java | 2 +- .../ml/math/vector/SparseVectorExample.java | 4 - .../math/vector/VectorCustomStorageExample.java | 4 - .../examples/ml/math/vector/VectorExample.java | 6 +- .../examples/IndexingBridgeMethodTest.java | 93 - .../IgniteExamplesJ8SelfTestSuite.java | 2 - .../apache/ignite/gridify/AbstractAopTest.java | 4 +- .../gridify/ExternalNonSpringAopSelfTest.java | 6 +- .../jmh/cache/JmhCacheAbstractBenchmark.java | 7 +- .../benchmarks/jmh/tree/BPlusTreeBenchmark.java | 15 +- .../stream/camel/IgniteCamelStreamerTest.java | 10 +- .../cassandra/common/PropertyMappingHelper.java | 21 +- .../persistence/KeyPersistenceSettings.java | 18 +- .../store/cassandra/persistence/PojoField.java | 21 +- .../cassandra/persistence/PojoKeyField.java | 7 - .../cassandra/persistence/PojoValueField.java | 6 - .../persistence/ValuePersistenceSettings.java | 12 +- .../ignite/ignite-cassandra-server-template.xml | 3 - .../tests/ignite-cassandra-client-template.xml | 3 - .../org/apache/ignite/tests/pojos/Person.java | 10 +- .../org/apache/ignite/tests/pojos/Product.java | 7 - .../apache/ignite/tests/pojos/ProductOrder.java | 8 - .../ClientAbstractMultiThreadedSelfTest.java | 37 +- .../client/ClientDefaultCacheSelfTest.java | 6 +- .../ClientAbstractMultiNodeSelfTest.java | 25 +- .../integration/ClientAbstractSelfTest.java | 9 +- .../jdbc2/JdbcAbstractDmlStatementSelfTest.java | 16 +- .../jdbc2/JdbcComplexQuerySelfTest.java | 5 +- .../internal/jdbc2/JdbcConnectionSelfTest.java | 5 +- .../jdbc2/JdbcDistributedJoinsQueryTest.java | 6 +- .../jdbc2/JdbcDynamicIndexAbstractSelfTest.java | 14 +- .../jdbc2/JdbcInsertStatementSelfTest.java | 4 +- .../jdbc2/JdbcMergeStatementSelfTest.java | 4 +- .../internal/jdbc2/JdbcMetadataSelfTest.java | 31 +- .../internal/jdbc2/JdbcNoDefaultCacheTest.java | 45 +- .../jdbc2/JdbcPreparedStatementSelfTest.java | 4 +- .../internal/jdbc2/JdbcResultSetSelfTest.java | 6 +- .../internal/jdbc2/JdbcStatementSelfTest.java | 4 +- .../internal/jdbc2/JdbcStreamingSelfTest.java | 14 +- .../rest/AbstractRestProcessorSelfTest.java | 2 +- .../JettyRestProcessorAbstractSelfTest.java | 341 +-- .../rest/JettyRestProcessorSignedSelfTest.java | 4 +- .../rest/RestBinaryProtocolSelfTest.java | 101 +- .../rest/RestMemcacheProtocolSelfTest.java | 47 +- .../processors/rest/RestProcessorTest.java | 2 +- .../rest/TaskCommandHandlerSelfTest.java | 7 +- .../processors/rest/TestBinaryClient.java | 23 +- .../tcp/redis/RedisProtocolSelfTest.java | 8 +- .../jdbc/AbstractJdbcPojoQuerySelfTest.java | 2 +- .../ignite/jdbc/JdbcConnectionSelfTest.java | 5 +- .../ignite/jdbc/JdbcMetadataSelfTest.java | 8 +- .../ignite/jdbc/JdbcNoDefaultCacheTest.java | 3 +- .../ignite/jdbc/JdbcPojoQuerySelfTest.java | 2 +- .../jdbc/JdbcPreparedStatementSelfTest.java | 2 +- .../ignite/jdbc/JdbcResultSetSelfTest.java | 2 +- .../ignite/jdbc/JdbcStatementSelfTest.java | 2 +- .../clients/src/test/resources/spring-cache.xml | 10 - .../src/main/java/org/apache/ignite/Ignite.java | 15 +- .../java/org/apache/ignite/IgniteCache.java | 11 - .../java/org/apache/ignite/IgniteCompute.java | 22 +- .../org/apache/ignite/IgniteFileSystem.java | 4 +- .../apache/ignite/IgniteSystemProperties.java | 3 + .../java/org/apache/ignite/MemoryMetrics.java | 89 +- .../org/apache/ignite/cache/CacheMetrics.java | 8 - .../org/apache/ignite/cache/QueryEntity.java | 81 + .../org/apache/ignite/cache/query/Query.java | 48 + .../ignite/cache/query/SqlFieldsQuery.java | 26 + .../org/apache/ignite/cache/query/SqlQuery.java | 26 + .../cache/query/annotations/QuerySqlField.java | 2 +- .../cache/query/annotations/QueryTextField.java | 4 +- .../store/jdbc/CacheAbstractJdbcStore.java | 66 +- .../cache/store/jdbc/CacheJdbcPojoStore.java | 1 - .../apache/ignite/cluster/ClusterMetrics.java | 4 +- .../org/apache/ignite/cluster/ClusterNode.java | 11 +- .../configuration/CacheConfiguration.java | 132 +- .../configuration/DataPageEvictionMode.java | 31 +- .../configuration/ExecutorConfiguration.java | 115 + .../configuration/FileSystemConfiguration.java | 25 - .../configuration/IgniteConfiguration.java | 82 +- .../configuration/MemoryConfiguration.java | 142 +- .../MemoryPolicyConfiguration.java | 126 +- .../org/apache/ignite/events/CacheEvent.java | 3 - .../java/org/apache/ignite/events/Event.java | 1 - .../org/apache/ignite/events/EventType.java | 111 +- .../apache/ignite/events/SwapSpaceEvent.java | 105 - .../org/apache/ignite/igfs/IgfsMetrics.java | 5 +- .../igfs/secondary/IgfsSecondaryFileSystem.java | 4 +- .../local/LocalIgfsSecondaryFileSystem.java | 2 +- .../ignite/internal/ExecutorAwareMessage.java | 31 + .../ignite/internal/GridJobExecuteRequest.java | 32 +- .../ignite/internal/GridKernalContext.java | 8 + .../ignite/internal/GridKernalContextImpl.java | 12 + .../ignite/internal/GridTaskSessionImpl.java | 15 +- .../ignite/internal/IgniteComputeImpl.java | 108 +- .../org/apache/ignite/internal/IgniteEx.java | 12 +- .../apache/ignite/internal/IgniteKernal.java | 90 +- .../org/apache/ignite/internal/IgnitionEx.java | 66 + .../internal/cluster/ClusterGroupAdapter.java | 23 +- .../ignite/internal/cluster/ClusterGroupEx.java | 5 +- .../managers/communication/GridIoManager.java | 25 +- .../managers/communication/GridIoMessage.java | 18 +- .../managers/indexing/GridIndexingManager.java | 44 - .../ignite/internal/mem/DirectMemory.java | 55 - .../internal/mem/DirectMemoryProvider.java | 19 +- .../mem/file/MappedFileMemoryProvider.java | 153 +- .../mem/unsafe/UnsafeMemoryProvider.java | 69 +- .../pagemem/impl/PageMemoryNoStoreImpl.java | 408 ++-- .../affinity/GridAffinityProcessor.java | 67 +- .../cache/CacheClusterMetricsMXBeanImpl.java | 5 - .../cache/CacheLocalMetricsMXBeanImpl.java | 5 - .../processors/cache/CacheMetricsImpl.java | 32 +- .../processors/cache/CacheMetricsSnapshot.java | 13 - .../cache/DynamicCacheDescriptor.java | 24 + .../processors/cache/GridCacheAdapter.java | 48 +- .../processors/cache/GridCacheAtomicFuture.java | 5 - .../cache/GridCacheBatchSwapEntry.java | 76 - .../processors/cache/GridCacheContext.java | 23 - .../processors/cache/GridCacheEntryEx.java | 23 - .../GridCacheEntryInfoCollectSwapListener.java | 70 - .../cache/GridCacheEvictionManager.java | 95 +- .../processors/cache/GridCacheMapEntry.java | 75 +- .../processors/cache/GridCacheMvccManager.java | 10 +- .../processors/cache/GridCacheProcessor.java | 226 +- .../processors/cache/GridCacheProxyImpl.java | 24 - .../cache/GridCacheSharedContext.java | 24 +- .../processors/cache/GridCacheSwapEntry.java | 82 - .../cache/GridCacheSwapEntryImpl.java | 339 --- .../processors/cache/GridCacheSwapListener.java | 33 - .../cache/GridCacheTryPutFailedException.java | 28 - .../processors/cache/GridCacheUtils.java | 239 ++- .../cache/IgniteCacheOffheapManager.java | 3 - .../cache/IgniteCacheOffheapManagerImpl.java | 5 - .../processors/cache/IgniteCacheProxy.java | 28 +- .../processors/cache/IgniteInternalCache.java | 18 - .../cache/binary/BinaryMetadataHolder.java | 7 + .../cache/binary/BinaryMetadataTransport.java | 34 +- .../binary/CacheObjectBinaryProcessorImpl.java | 27 +- .../binary/ClientMetadataRequestFuture.java | 5 + .../IgniteCacheDatabaseSharedManager.java | 354 ++-- .../cache/database/MemoryMetricsImpl.java | 24 +- .../cache/database/MemoryMetricsMXBeanImpl.java | 108 + .../cache/database/MemoryMetricsSnapshot.java | 85 + .../processors/cache/database/MemoryPolicy.java | 7 +- .../evict/FairFifoPageEvictionTracker.java | 6 +- .../evict/PageAbstractEvictionTracker.java | 92 +- .../evict/Random2LruPageEvictionTracker.java | 6 +- .../evict/RandomLruPageEvictionTracker.java | 6 +- .../CacheDataStructuresManager.java | 34 + .../distributed/GridDistributedLockRequest.java | 14 +- .../distributed/GridDistributedTxMapping.java | 68 +- .../GridDistributedTxRemoteAdapter.java | 2 +- .../cache/distributed/dht/GridDhtGetFuture.java | 38 +- .../distributed/dht/GridDhtLocalPartition.java | 3 +- .../dht/GridDhtTransactionalCacheAdapter.java | 1 - .../cache/distributed/dht/GridDhtTxLocal.java | 2 +- .../distributed/dht/GridDhtTxPrepareFuture.java | 28 +- .../dht/GridPartitionedSingleGetFuture.java | 3 - .../GridDhtAtomicAbstractUpdateFuture.java | 9 +- .../dht/atomic/GridDhtAtomicCache.java | 96 +- .../atomic/GridDhtAtomicSingleUpdateFuture.java | 3 - .../dht/atomic/GridDhtAtomicUpdateFuture.java | 3 - .../GridNearAtomicAbstractUpdateFuture.java | 79 +- .../GridNearAtomicSingleUpdateFuture.java | 137 +- .../dht/atomic/GridNearAtomicUpdateFuture.java | 157 +- .../dht/preloader/GridDhtPartitionDemander.java | 12 - .../GridDhtPartitionsAbstractMessage.java | 6 + .../dht/preloader/GridDhtPreloader.java | 18 +- .../distributed/near/GridNearAtomicCache.java | 5 - .../distributed/near/GridNearCacheAdapter.java | 5 - .../distributed/near/GridNearCacheEntry.java | 4 +- ...arOptimisticSerializableTxPrepareFuture.java | 218 +- .../near/GridNearOptimisticTxPrepareFuture.java | 95 +- .../GridNearPessimisticTxPrepareFuture.java | 186 +- .../near/GridNearSingleGetRequest.java | 4 +- .../near/GridNearTxFinishFuture.java | 6 +- .../cache/distributed/near/GridNearTxLocal.java | 30 +- .../near/GridNearTxPrepareFutureAdapter.java | 30 +- .../processors/cache/local/GridLocalCache.java | 3 +- .../cache/local/GridLocalLockFuture.java | 3 - .../local/atomic/GridLocalAtomicCache.java | 35 +- .../cache/query/GridCacheQueryManager.java | 73 +- .../cache/store/CacheOsStoreManager.java | 3 + .../store/GridCacheStoreManagerAdapter.java | 11 +- .../cache/transactions/IgniteTxAdapter.java | 16 +- .../cache/transactions/IgniteTxEntry.java | 39 +- .../cache/transactions/IgniteTxHandler.java | 49 +- .../IgniteTxImplicitSingleStateImpl.java | 6 + .../transactions/IgniteTxLocalAdapter.java | 7 +- .../cache/transactions/IgniteTxLocalState.java | 10 + .../cache/transactions/IgniteTxManager.java | 27 +- .../cache/transactions/IgniteTxState.java | 2 +- .../cache/transactions/IgniteTxStateImpl.java | 52 +- .../cache/transactions/TxDeadlock.java | 19 +- .../cache/transactions/TxLocksResponse.java | 37 +- .../closure/GridClosureProcessor.java | 154 +- .../datastructures/DataStructuresProcessor.java | 64 +- .../datastructures/GridCacheAtomicLongImpl.java | 626 +++--- .../GridCacheAtomicReferenceImpl.java | 356 +++- .../GridCacheAtomicSequenceImpl.java | 88 +- .../GridCacheAtomicStampedImpl.java | 341 +-- .../GridCacheCountDownLatchImpl.java | 58 +- .../datastructures/GridCacheLockImpl.java | 103 +- .../datastructures/GridCacheQueueProxy.java | 292 +-- .../datastructures/GridCacheSemaphoreImpl.java | 292 ++- .../datastructures/GridCacheSetProxy.java | 152 +- .../GridTransactionalCacheQueueImpl.java | 8 +- .../internal/processors/igfs/IgfsAsyncImpl.java | 4 +- .../processors/igfs/IgfsDataManager.java | 36 +- .../internal/processors/igfs/IgfsImpl.java | 6 +- .../processors/igfs/IgfsIpcHandler.java | 2 +- .../processors/igfs/IgfsMetaManager.java | 6 +- .../igfs/IgfsSecondaryFileSystemImpl.java | 4 +- .../igfs/client/IgfsClientSetTimesCallable.java | 2 +- .../IgfsMetaDirectoryListingAddProcessor.java | 5 +- .../processors/job/GridJobProcessor.java | 41 +- .../internal/processors/job/GridJobWorker.java | 15 +- .../platform/PlatformContextImpl.java | 11 - .../platform/cache/PlatformCache.java | 34 +- .../platform/cluster/PlatformClusterGroup.java | 17 + .../utils/PlatformConfigurationUtils.java | 213 +- .../internal/processors/pool/PoolProcessor.java | 25 + .../processors/query/GridQueryIndexing.java | 40 +- .../processors/query/GridQueryProcessor.java | 240 +-- .../query/GridQueryTypeDescriptor.java | 12 + .../query/QueryTypeDescriptorImpl.java | 34 +- .../internal/processors/query/QueryUtils.java | 135 +- .../handlers/cache/GridCacheCommandHandler.java | 4 +- .../redis/GridRedisRestCommandHandler.java | 3 + .../redis/key/GridRedisDelCommandHandler.java | 1 + .../key/GridRedisExistsCommandHandler.java | 1 + .../server/GridRedisDbSizeCommandHandler.java | 1 + .../string/GridRedisAppendCommandHandler.java | 3 + .../string/GridRedisGetCommandHandler.java | 1 + .../string/GridRedisGetRangeCommandHandler.java | 1 + .../string/GridRedisGetSetCommandHandler.java | 1 + .../string/GridRedisIncrDecrCommandHandler.java | 2 + .../string/GridRedisMGetCommandHandler.java | 1 + .../string/GridRedisMSetCommandHandler.java | 1 + .../string/GridRedisSetCommandHandler.java | 1 + .../string/GridRedisSetRangeCommandHandler.java | 2 + .../string/GridRedisStrlenCommandHandler.java | 1 + .../tcp/GridTcpMemcachedNioListener.java | 5 +- .../service/GridServiceProcessor.java | 9 +- .../session/GridTaskSessionProcessor.java | 10 +- .../processors/task/GridTaskProcessor.java | 69 +- .../processors/task/GridTaskWorker.java | 3 +- .../ignite/internal/util/GridIntIterator.java | 33 + .../ignite/internal/util/GridIntList.java | 21 +- .../ignite/internal/util/IgniteUtils.java | 46 +- .../lang/gridfunc/PredicateCollectionView.java | 7 +- .../util/lang/gridfunc/PredicateMapView.java | 6 - .../util/lang/gridfunc/PredicateSetView.java | 6 - .../lang/gridfunc/ReadOnlyCollectionView.java | 6 - .../lang/gridfunc/ReadOnlyCollectionView2X.java | 6 - .../lang/gridfunc/TransformCollectionView.java | 7 +- .../util/lang/gridfunc/TransformMapView.java | 6 - .../internal/visor/VisorMultiNodeTask.java | 9 +- .../visor/binary/VisorBinaryMetadata.java | 8 +- .../VisorBinaryMetadataCollectorTask.java | 16 +- .../VisorBinaryMetadataCollectorTaskArg.java | 71 + .../VisorBinaryMetadataCollectorTaskResult.java | 4 +- .../cache/VisorCacheAffinityConfiguration.java | 8 +- .../visor/cache/VisorCacheClearTask.java | 19 +- .../visor/cache/VisorCacheClearTaskArg.java | 72 + .../visor/cache/VisorCacheConfiguration.java | 162 +- .../VisorCacheConfigurationCollectorJob.java | 12 +- .../VisorCacheConfigurationCollectorTask.java | 5 +- ...VisorCacheConfigurationCollectorTaskArg.java | 74 + .../visor/cache/VisorCacheLoadTask.java | 5 +- .../visor/cache/VisorCacheLoadTaskArg.java | 2 +- .../visor/cache/VisorCacheMetadataTask.java | 14 +- .../visor/cache/VisorCacheMetadataTaskArg.java | 72 + .../visor/cache/VisorCacheNodesTask.java | 12 +- .../visor/cache/VisorCacheNodesTaskArg.java | 72 + .../cache/VisorCacheRebalanceConfiguration.java | 26 + .../visor/cache/VisorCacheRebalanceTask.java | 13 +- .../visor/cache/VisorCacheRebalanceTaskArg.java | 73 + .../visor/cache/VisorCacheResetMetricsTask.java | 14 +- .../cache/VisorCacheResetMetricsTaskArg.java | 72 + .../visor/cache/VisorCacheStartArg.java | 100 - .../visor/cache/VisorCacheStopTask.java | 17 +- .../visor/cache/VisorCacheStopTaskArg.java | 72 + .../cache/VisorCacheStoreConfiguration.java | 14 + .../internal/visor/cache/VisorPartitionMap.java | 24 +- .../compute/VisorComputeCancelSessionsTask.java | 13 +- .../VisorComputeCancelSessionsTaskArg.java | 76 + .../visor/compute/VisorGatewayTask.java | 87 +- .../internal/visor/debug/VisorThreadInfo.java | 64 +- .../visor/debug/VisorThreadMonitorInfo.java | 8 +- .../internal/visor/file/VisorFileBlockArg.java | 114 - .../visor/igfs/VisorIgfsFormatTask.java | 14 +- .../visor/igfs/VisorIgfsFormatTaskArg.java | 72 + .../internal/visor/igfs/VisorIgfsMetrics.java | 3 +- .../visor/igfs/VisorIgfsProfilerClearTask.java | 24 +- .../igfs/VisorIgfsProfilerClearTaskArg.java | 72 + .../igfs/VisorIgfsProfilerClearTaskResult.java | 6 +- .../visor/igfs/VisorIgfsProfilerTask.java | 18 +- .../visor/igfs/VisorIgfsProfilerTaskArg.java | 72 + .../visor/igfs/VisorIgfsResetMetricsTask.java | 13 +- .../igfs/VisorIgfsResetMetricsTaskArg.java | 73 + .../internal/visor/log/VisorLogSearchArg.java | 114 - .../internal/visor/misc/VisorAckTask.java | 14 +- .../internal/visor/misc/VisorAckTaskArg.java | 72 + .../misc/VisorChangeGridActiveStateTask.java | 12 +- .../misc/VisorChangeGridActiveStateTaskArg.java | 71 + .../visor/node/VisorBasicConfiguration.java | 224 +- .../visor/node/VisorBinaryConfiguration.java | 131 ++ .../node/VisorBinaryTypeConfiguration.java | 150 ++ .../visor/node/VisorCacheKeyConfiguration.java | 108 + .../visor/node/VisorExecutorConfiguration.java | 108 + .../node/VisorExecutorServiceConfiguration.java | 115 + .../visor/node/VisorGridConfiguration.java | 110 + .../visor/node/VisorHadoopConfiguration.java | 145 ++ .../visor/node/VisorIgfsConfiguration.java | 55 +- .../visor/node/VisorMemoryConfiguration.java | 2 +- .../node/VisorMemoryPolicyConfiguration.java | 43 +- .../visor/node/VisorNodeDataCollectorTask.java | 4 +- .../node/VisorNodeDataCollectorTaskResult.java | 4 +- .../internal/visor/node/VisorNodePingTask.java | 13 +- .../visor/node/VisorNodePingTaskArg.java | 73 + .../visor/node/VisorNodeSuppressedErrors.java | 6 +- .../node/VisorNodeSuppressedErrorsTask.java | 12 +- .../node/VisorNodeSuppressedErrorsTaskArg.java | 74 + .../visor/node/VisorOdbcConfiguration.java | 114 + .../visor/node/VisorRestConfiguration.java | 207 +- .../node/VisorSegmentationConfiguration.java | 13 + .../visor/node/VisorServiceConfiguration.java | 176 ++ .../internal/visor/query/VisorQueryArg.java | 155 -- .../visor/query/VisorQueryCancelTask.java | 12 +- .../visor/query/VisorQueryCancelTaskArg.java | 71 + .../visor/query/VisorQueryCleanupTask.java | 10 +- .../visor/query/VisorQueryCleanupTaskArg.java | 75 + .../visor/query/VisorQueryConfiguration.java | 12 - .../VisorQueryDetailMetricsCollectorTask.java | 17 +- ...VisorQueryDetailMetricsCollectorTaskArg.java | 71 + .../query/VisorQueryResetDetailMetricsTask.java | 6 +- .../visor/query/VisorQueryResetMetricsTask.java | 18 +- .../query/VisorQueryResetMetricsTaskArg.java | 72 + .../query/VisorRunningQueriesCollectorTask.java | 16 +- .../VisorRunningQueriesCollectorTaskArg.java | 71 + .../internal/visor/query/VisorScanQueryArg.java | 157 -- .../visor/service/VisorCancelServiceTask.java | 12 +- .../service/VisorCancelServiceTaskArg.java | 72 + .../internal/visor/util/VisorTaskUtils.java | 23 + .../ignite/mxbean/CacheMetricsMXBean.java | 4 - .../ignite/mxbean/MemoryMetricsMXBean.java | 94 +- .../org/apache/ignite/spi/IgniteSpiAdapter.java | 32 + .../spi/IgniteSpiOperationTimeoutHelper.java | 8 +- .../jobstealing/JobStealingCollisionSpi.java | 2 +- .../communication/tcp/TcpCommunicationSpi.java | 6 +- .../ignite/spi/discovery/tcp/ClientImpl.java | 31 +- .../ignite/spi/discovery/tcp/ServerImpl.java | 142 +- .../spi/discovery/tcp/TcpDiscoverySpi.java | 139 +- .../spi/discovery/tcp/TcpDiscoverySpiMBean.java | 26 +- .../tcp/internal/TcpDiscoveryNode.java | 33 +- .../TcpDiscoveryClientHeartbeatMessage.java | 72 - .../TcpDiscoveryClientMetricsUpdateMessage.java | 72 + .../messages/TcpDiscoveryHeartbeatMessage.java | 338 --- .../TcpDiscoveryMetricsUpdateMessage.java | 338 +++ .../spi/indexing/IndexingQueryFilter.java | 2 +- .../apache/ignite/spi/indexing/IndexingSpi.java | 19 - .../spi/indexing/noop/NoopIndexingSpi.java | 10 - .../adaptive/AdaptiveLoadBalancingSpi.java | 12 +- .../resources/META-INF/classnames.properties | 61 +- .../spring-cache-client-benchmark-1.xml | 3 - .../spring-cache-client-benchmark-2.xml | 3 - .../spring-cache-client-benchmark-3.xml | 3 - .../core/src/test/config/discovery-stress.xml | 2 +- modules/core/src/test/config/example-cache.xml | 3 - modules/core/src/test/config/igfs-loopback.xml | 18 - modules/core/src/test/config/igfs-shmem.xml | 18 - .../src/test/config/load/cache-benchmark.xml | 4 - .../test/config/load/cache-client-benchmark.xml | 2 - .../config/load/dsi-49-server-production.xml | 2 - .../core/src/test/config/load/dsi-load-base.xml | 3 +- .../src/test/config/load/dsi-load-client.xml | 2 - .../src/test/config/load/dsi-load-server.xml | 2 - .../src/test/config/load/merge-sort-base.xml | 7 +- .../core/src/test/config/spring-cache-load.xml | 1 + .../core/src/test/config/spring-cache-swap.xml | 2 + .../src/test/config/spring-cache-teststore.xml | 2 + .../core/src/test/config/spring-multicache.xml | 17 - .../test/config/store/jdbc/ignite-jdbc-type.xml | 6 + .../config/streamer/spring-streamer-base.xml | 5 +- .../config/websession/example-cache-base.xml | 3 - .../GridCacheAffinityBackupsSelfTest.java | 2 +- .../java/org/apache/ignite/GridTestJob.java | 19 + .../apache/ignite/GridTestStoreNodeStartup.java | 2 +- .../java/org/apache/ignite/GridTestTask.java | 18 +- .../ignite/IgniteCacheAffinitySelfTest.java | 2 +- .../cache/IgniteWarmupClosureSelfTest.java | 2 +- .../ignite/cache/LargeEntryUpdateTest.java | 2 +- .../affinity/AffinityClientNodeSelfTest.java | 14 +- ...ityFunctionBackupFilterAbstractSelfTest.java | 8 +- ...unctionExcludeNeighborsAbstractSelfTest.java | 4 +- .../affinity/AffinityHistoryCleanupTest.java | 2 +- .../local/LocalAffinityFunctionTest.java | 2 +- ...cheStoreSessionListenerAbstractSelfTest.java | 6 +- .../store/GridCacheBalancingStoreSelfTest.java | 8 +- .../IgniteCacheExpiryStoreLoadSelfTest.java | 2 +- .../store/StoreResourceInjectionSelfTest.java | 2 +- .../CacheJdbcPojoStoreAbstractSelfTest.java | 19 +- ...BinaryMarshallerStoreKeepBinarySelfTest.java | 28 + ...lerStoreKeepBinaryWithSqlEscapeSelfTest.java | 28 + .../store/jdbc/CacheJdbcPojoStoreTest.java | 147 +- ...CacheJdbcBlobStoreMultithreadedSelfTest.java | 8 +- .../internal/ClusterNodeMetricsSelfTest.java | 16 +- .../ignite/internal/GridAffinityMappedTest.java | 11 +- .../internal/GridAffinityP2PSelfTest.java | 9 +- .../ignite/internal/GridAffinitySelfTest.java | 9 +- .../internal/GridCacheRecreateLockTest.java | 78 - .../GridCancelledJobsMetricsSelfTest.java | 4 +- .../ignite/internal/GridDiscoverySelfTest.java | 2 +- ...ridFailFastNodeFailureDetectionSelfTest.java | 4 +- .../GridJobCollisionCancelSelfTest.java | 2 +- .../GridJobMasterLeaveAwareSelfTest.java | 8 +- .../GridProjectionForCachesSelfTest.java | 13 +- ...ectionLocalJobMultipleArgumentsSelfTest.java | 4 +- .../ignite/internal/GridStartStopSelfTest.java | 8 +- .../GridTaskFailoverAffinityRunTest.java | 4 +- .../IgniteClientReconnectApiExceptionTest.java | 18 +- .../IgniteClientReconnectAtomicsTest.java | 15 +- .../IgniteClientReconnectCacheTest.java | 82 +- ...eClientReconnectContinuousProcessorTest.java | 10 +- .../IgniteClientReconnectFailoverTest.java | 4 +- .../internal/IgniteClientReconnectStopTest.java | 2 +- .../IgniteComputeEmptyClusterGroupTest.java | 8 +- ...eConcurrentEntryProcessorAccessStopTest.java | 2 +- .../internal/TestRecordingCommunicationSpi.java | 38 +- ...ryConfigurationCustomSerializerSelfTest.java | 4 +- .../internal/binary/BinaryEnumsSelfTest.java | 2 +- .../BinaryObjectBuilderAdditionalSelfTest.java | 2 +- .../internal/binary/BinaryTreeSelfTest.java | 4 +- .../binary/GridBinaryAffinityKeySelfTest.java | 30 +- ...aultBinaryMappersBinaryMetaDataSelfTest.java | 4 +- .../IgniteVariousConnectionNumberTest.java | 4 +- .../GridDeploymentMessageCountSelfTest.java | 6 +- .../GridDiscoveryManagerAliveCacheSelfTest.java | 6 +- .../OptimizedMarshallerNodeFailoverTest.java | 6 +- .../pagemem/impl/PageMemoryNoLoadSelfTest.java | 18 +- .../GridCacheTxLoadFromStoreOnLockSelfTest.java | 2 +- .../GridAffinityProcessorAbstractSelfTest.java | 2 +- .../CacheAtomicSingleMessageCountSelfTest.java | 4 +- .../cache/CacheClientStoreSelfTest.java | 2 +- .../cache/CacheConcurrentReadThroughTest.java | 2 +- .../cache/CacheConfigurationLeakTest.java | 4 +- .../cache/CacheDeferredDeleteQueueTest.java | 4 +- .../CacheDeferredDeleteSanitySelfTest.java | 4 +- ...cheDhtLocalPartitionAfterRemoveSelfTest.java | 6 +- .../cache/CacheEnumOperationsAbstractTest.java | 2 +- ...CacheExchangeMessageDuplicatedStateTest.java | 18 +- .../cache/CacheFutureExceptionSelfTest.java | 2 +- .../cache/CacheGetEntryAbstractTest.java | 16 +- .../processors/cache/CacheGetFromJobTest.java | 2 +- ...erceptorPartitionCounterLocalSanityTest.java | 2 +- ...torPartitionCounterRandomOperationsTest.java | 2 +- .../CacheMemoryPolicyConfigurationTest.java | 26 +- .../processors/cache/CacheNamesSelfTest.java | 8 +- .../CacheNamesWithSpecialCharactersTest.java | 4 +- .../cache/CacheNearReaderUpdateTest.java | 2 +- ...cheNearUpdateTopologyChangeAbstractTest.java | 8 +- .../cache/CacheOffheapMapEntrySelfTest.java | 2 +- .../processors/cache/CachePutIfAbsentTest.java | 2 +- .../cache/CacheReadThroughRestartSelfTest.java | 8 +- .../cache/CacheRebalancingSelfTest.java | 4 +- .../cache/CacheRemoveAllSelfTest.java | 4 +- .../CacheSerializableTransactionsTest.java | 6 +- .../CacheStartupInDeploymentModesTest.java | 4 +- .../CacheStoreUsageMultinodeAbstractTest.java | 8 +- ...eUsageMultinodeDynamicStartAbstractTest.java | 4 +- .../processors/cache/CacheTxFastFinishTest.java | 4 +- .../processors/cache/CrossCacheLockTest.java | 4 +- ...sCacheTxNearEnabledRandomOperationsTest.java | 28 + .../cache/CrossCacheTxRandomOperationsTest.java | 25 +- .../EntryVersionConsistencyReadThroughTest.java | 10 +- .../GridCacheAbstractFailoverSelfTest.java | 8 +- .../cache/GridCacheAbstractFullApiSelfTest.java | 159 +- .../GridCacheAbstractLocalStoreSelfTest.java | 26 +- .../cache/GridCacheAbstractMetricsSelfTest.java | 102 +- .../GridCacheAbstractRemoveFailureTest.java | 6 +- .../cache/GridCacheAbstractSelfTest.java | 8 +- ...acheAbstractUsersAffinityMapperSelfTest.java | 7 +- .../cache/GridCacheAffinityApiSelfTest.java | 26 +- .../cache/GridCacheAffinityRoutingSelfTest.java | 10 +- ...eAtomicEntryProcessorDeploymentSelfTest.java | 2 +- .../GridCacheAtomicMessageCountSelfTest.java | 6 +- .../cache/GridCacheBasicApiAbstractTest.java | 30 +- .../cache/GridCacheClearLocallySelfTest.java | 8 +- .../cache/GridCacheConcurrentMapSelfTest.java | 11 +- .../GridCacheConcurrentTxMultiNodeTest.java | 10 +- .../GridCacheConditionalDeploymentSelfTest.java | 4 +- ...idCacheConfigurationConsistencySelfTest.java | 2 +- .../GridCacheDaemonNodeAbstractSelfTest.java | 8 +- .../cache/GridCacheDeploymentSelfTest.java | 46 +- .../cache/GridCacheEntryMemorySizeSelfTest.java | 4 +- .../cache/GridCacheEntryVersionSelfTest.java | 16 +- .../GridCacheEvictionEventAbstractTest.java | 2 +- .../GridCacheFinishPartitionsSelfTest.java | 16 +- ...CacheFullTextQueryMultithreadedSelfTest.java | 2 +- .../cache/GridCacheIncrementTransformTest.java | 4 +- .../GridCacheInterceptorAbstractSelfTest.java | 8 +- .../cache/GridCacheIteratorPerformanceTest.java | 6 +- .../cache/GridCacheKeyCheckSelfTest.java | 6 +- .../GridCacheMarshallerTxAbstractTest.java | 10 +- .../GridCacheMarshallingNodeJoinSelfTest.java | 4 +- .../GridCacheMissingCommitVersionSelfTest.java | 2 +- ...GridCacheMixedPartitionExchangeSelfTest.java | 4 +- .../cache/GridCacheMultiUpdateLockSelfTest.java | 6 +- ...ridCacheMultinodeUpdateAbstractSelfTest.java | 6 +- .../cache/GridCacheMvccFlagsTest.java | 4 +- .../cache/GridCacheMvccManagerSelfTest.java | 9 +- .../cache/GridCacheMvccPartitionedSelfTest.java | 34 +- .../processors/cache/GridCacheMvccSelfTest.java | 58 +- .../cache/GridCacheNestedTxAbstractTest.java | 12 +- .../cache/GridCacheObjectToStringSelfTest.java | 4 +- ...HeapMultiThreadedUpdateAbstractSelfTest.java | 20 +- ...CacheOffHeapMultiThreadedUpdateSelfTest.java | 14 +- .../cache/GridCacheOffheapUpdateSelfTest.java | 14 +- .../cache/GridCachePartitionedGetSelfTest.java | 16 +- ...hePartitionedProjectionAffinitySelfTest.java | 8 +- .../GridCachePreloadingEvictionsSelfTest.java | 14 +- .../cache/GridCachePutAllFailoverSelfTest.java | 1 - .../GridCacheQueryIndexingDisabledSelfTest.java | 2 +- .../GridCacheQueryInternalKeysSelfTest.java | 6 +- .../GridCacheReferenceCleanupSelfTest.java | 10 +- ...ridCacheReplicatedSynchronousCommitTest.java | 6 +- .../GridCacheReturnValueTransferSelfTest.java | 4 +- .../processors/cache/GridCacheStopSelfTest.java | 8 +- ...ridCacheStoreManagerDeserializationTest.java | 3 + .../cache/GridCacheStorePutxSelfTest.java | 2 +- .../cache/GridCacheStoreValueBytesSelfTest.java | 4 +- .../cache/GridCacheSwapPreloadSelfTest.java | 10 +- ...acheTcpClientDiscoveryMultiThreadedTest.java | 4 +- .../processors/cache/GridCacheTestEntryEx.java | 15 - ...cheTransactionalAbstractMetricsSelfTest.java | 8 +- .../GridCacheTtlManagerEvictionSelfTest.java | 6 +- .../cache/GridCacheTtlManagerLoadTest.java | 4 +- .../GridCacheTtlManagerNotificationTest.java | 8 +- .../cache/GridCacheTtlManagerSelfTest.java | 12 +- .../GridCacheValueBytesPreloadingSelfTest.java | 12 +- ...idCacheValueConsistencyAbstractSelfTest.java | 14 +- .../GridCacheVariableTopologySelfTest.java | 4 +- .../cache/GridCacheVersionMultinodeTest.java | 2 +- .../GridCacheVersionTopologyChangeTest.java | 2 +- ...ProjectionForCachesOnDaemonNodeSelfTest.java | 16 +- .../IgniteCacheAbstractStopBusySelfTest.java | 3 +- .../cache/IgniteCacheAbstractTest.java | 12 +- ...IgniteCacheBinaryEntryProcessorSelfTest.java | 6 +- .../IgniteCacheConfigVariationsFullApiTest.java | 45 - ...teCacheConfigurationDefaultTemplateTest.java | 6 +- .../IgniteCacheConfigurationTemplateTest.java | 29 +- ...niteCacheCopyOnReadDisabledAbstractTest.java | 2 +- .../cache/IgniteCacheDynamicStopSelfTest.java | 10 +- .../IgniteCacheEntryListenerAbstractTest.java | 6 +- ...niteCacheEntryListenerExpiredEventsTest.java | 2 +- .../IgniteCacheEntryProcessorCallTest.java | 8 +- .../IgniteCacheEntryProcessorNodeJoinTest.java | 16 +- ...niteCacheExpireAndUpdateConsistencyTest.java | 2 +- ...IgniteCacheGetCustomCollectionsSelfTest.java | 2 +- .../cache/IgniteCacheIncrementTxTest.java | 10 +- .../cache/IgniteCacheInvokeAbstractTest.java | 2 +- ...gniteCacheInvokeReadThroughAbstractTest.java | 2 +- ...gniteCacheLoadRebalanceEvictionSelfTest.java | 6 +- .../IgniteCacheManyAsyncOperationsTest.java | 2 +- .../cache/IgniteCacheObjectPutSelfTest.java | 2 +- ...CacheP2pUnmarshallingRebalanceErrorTest.java | 4 +- .../IgniteCachePartitionMapUpdateTest.java | 4 +- .../cache/IgniteCachePeekModesAbstractTest.java | 22 +- .../IgniteCacheReadThroughStoreCallTest.java | 2 +- ...iteCacheScanPredicateDeploymentSelfTest.java | 2 +- .../cache/IgniteCacheSerializationSelfTest.java | 4 +- .../cache/IgniteCacheStartStopLoadTest.java | 2 +- .../cache/IgniteCacheStoreCollectionTest.java | 4 +- .../IgniteCacheStoreValueAbstractTest.java | 34 +- .../cache/IgniteCacheTxPreloadNoWriteTest.java | 12 +- .../IgniteClientAffinityAssignmentSelfTest.java | 22 +- .../IgniteDaemonNodeMarshallerCacheTest.java | 2 +- .../cache/IgniteDynamicCacheAndNodeStop.java | 4 +- .../cache/IgniteDynamicCacheFilterTest.java | 10 +- ...eDynamicCacheStartNoExchangeTimeoutTest.java | 34 +- .../cache/IgniteDynamicCacheStartSelfTest.java | 36 +- ...niteDynamicCacheStartStopConcurrentTest.java | 6 +- .../IgniteDynamicClientCacheStartSelfTest.java | 44 +- .../cache/IgniteExchangeFutureHistoryTest.java | 2 +- ...iteMarshallerCacheClassNameConflictTest.java | 8 +- ...lerCacheClientRequestsMappingOnMissTest.java | 22 +- ...eMarshallerCacheConcurrentReadWriteTest.java | 8 +- .../cache/IgniteOnePhaseCommitInvokeTest.java | 211 ++ .../cache/IgniteOnePhaseCommitNearSelfTest.java | 8 +- .../cache/IgnitePutAllLargeBatchSelfTest.java | 12 +- ...tAllUpdateNonPreloadedPartitionSelfTest.java | 6 +- .../IgniteStartCacheInTransactionSelfTest.java | 18 +- .../cache/IgniteStaticCacheStartSelfTest.java | 2 +- ...gniteTopologyValidatorAbstractCacheTest.java | 37 +- ...iteTopologyValidatorAbstractTxCacheTest.java | 20 +- ...niteTopologyValidatorGridSplitCacheTest.java | 2 +- .../processors/cache/IgniteTxAbstractTest.java | 6 +- .../IgniteTxConcurrentGetAbstractTest.java | 6 +- .../cache/IgniteTxConfigCacheSelfTest.java | 2 +- .../IgniteTxExceptionAbstractSelfTest.java | 46 +- .../cache/IgniteTxMultiNodeAbstractTest.java | 58 +- .../IgniteTxMultiThreadedAbstractTest.java | 4 +- .../cache/IgniteTxReentryAbstractSelfTest.java | 2 +- .../IgniteTxStoreExceptionAbstractSelfTest.java | 34 +- .../cache/MemoryPolicyConfigValidationTest.java | 127 +- .../binary/BinaryMetadataUpdatesFlowTest.java | 14 +- .../CacheKeepBinaryWithInterceptorTest.java | 6 +- ...yAtomicEntryProcessorDeploymentSelfTest.java | 6 +- ...naryObjectMetadataExchangeMultinodeTest.java | 16 +- ...acheBinaryObjectUserClassloaderSelfTest.java | 4 +- ...naryObjectsAbstractDataStreamerSelfTest.java | 4 +- ...aryObjectsAbstractMultiThreadedSelfTest.java | 2 +- .../GridCacheBinaryObjectsAbstractSelfTest.java | 8 +- .../GridCacheBinaryStoreAbstractSelfTest.java | 2 +- ...ntNodeBinaryObjectMetadataMultinodeTest.java | 8 +- ...CacheClientNodeBinaryObjectMetadataTest.java | 4 +- .../GridDataStreamerImplSelfTest.java | 20 +- ...IgniteCacheAbstractExecutionContextTest.java | 4 +- .../MemoryPolicyInitializationTest.java | 313 +++ ...eAbstractDataStructuresFailoverSelfTest.java | 66 +- ...CacheAtomicReferenceApiSelfAbstractTest.java | 6 +- ...idCacheAtomicStampedApiSelfAbstractTest.java | 2 +- .../GridCacheQueueApiSelfAbstractTest.java | 2 +- .../GridCacheQueueCleanupSelfTest.java | 10 +- .../GridCacheSequenceApiSelfAbstractTest.java | 2 +- .../GridCacheSetAbstractSelfTest.java | 2 +- .../GridCacheSetFailoverAbstractSelfTest.java | 2 +- .../IgniteAtomicLongApiAbstractSelfTest.java | 2 +- .../IgniteCountDownLatchAbstractSelfTest.java | 2 +- ...IgniteDataStructuresNoClassOnServerTest.java | 30 + .../IgniteLockAbstractSelfTest.java | 2 +- .../IgniteSemaphoreAbstractSelfTest.java | 2 +- ...achePartitionedAtomicSequenceTxSelfTest.java | 2 +- ...idCachePartitionedNodeRestartTxSelfTest.java | 24 +- ...PartitionedQueueCreateMultiNodeSelfTest.java | 4 +- ...acheAsyncOperationsFailoverAbstractTest.java | 4 +- .../distributed/CacheAsyncOperationsTest.java | 2 +- .../CacheGetFutureHangsSelfTest.java | 4 +- .../CacheGetInsideLockChangingTopologyTest.java | 2 +- .../CacheLateAffinityAssignmentTest.java | 43 +- ...CacheLoadingConcurrentGridStartSelfTest.java | 20 +- .../CacheLockReleaseNodeLeaveTest.java | 26 +- .../CacheNoValueClassOnServerNodeTest.java | 112 +- .../CachePutAllFailoverAbstractTest.java | 2 +- .../CacheTryLockMultithreadedTest.java | 4 +- ...tractDistributedByteArrayValuesSelfTest.java | 43 - .../GridCacheAbstractJobExecutionTest.java | 14 +- .../GridCacheAbstractNodeRestartSelfTest.java | 2 +- ...tractPartitionedByteArrayValuesSelfTest.java | 2 +- .../GridCacheAbstractPrimarySyncSelfTest.java | 6 +- .../GridCacheBasicOpAbstractTest.java | 26 +- .../GridCacheClientModesAbstractSelfTest.java | 20 +- .../GridCacheEntrySetAbstractSelfTest.java | 2 +- .../distributed/GridCacheLockAbstractTest.java | 6 +- .../distributed/GridCacheMixedModeSelfTest.java | 4 +- .../GridCacheMultiNodeAbstractTest.java | 10 +- .../GridCacheMultiNodeLockAbstractTest.java | 27 +- ...dCacheMultithreadedFailoverAbstractTest.java | 2 +- .../GridCacheNodeFailureAbstractTest.java | 9 +- ...ridCachePartitionNotLoadedEventSelfTest.java | 4 +- ...chePartitionedReloadAllAbstractSelfTest.java | 8 +- .../GridCachePreloadEventsAbstractSelfTest.java | 4 +- ...GridCachePreloadRestartAbstractSelfTest.java | 1 - .../GridCacheTransformEventSelfTest.java | 2 +- ...niteBinaryMetadataUpdateNodeRestartTest.java | 2 +- .../distributed/IgniteCache150ClientsTest.java | 4 +- ...heClientMultiNodeUpdateTopologyLockTest.java | 201 ++ ...niteCacheClientNodeChangingTopologyTest.java | 130 +- .../IgniteCacheClientNodeConcurrentStart.java | 2 +- ...teCacheClientNodePartitionsExchangeTest.java | 16 +- .../IgniteCacheClientReconnectTest.java | 2 +- .../IgniteCacheConnectionRecoveryTest.java | 2 +- .../distributed/IgniteCacheCreatePutTest.java | 6 +- .../distributed/IgniteCacheGetRestartTest.java | 4 +- .../distributed/IgniteCacheManyClientsTest.java | 6 +- .../IgniteCacheMessageRecoveryAbstractTest.java | 4 +- ...eCacheMessageRecoveryIdleConnectionTest.java | 2 +- .../IgniteCacheNearRestartRollbackSelfTest.java | 6 +- .../distributed/IgniteCachePrimarySyncTest.java | 4 +- .../IgniteCacheReadFromBackupTest.java | 17 +- .../IgniteCacheServerNodeConcurrentStart.java | 6 +- .../IgniteCacheSingleGetMessageTest.java | 2 +- .../IgniteCacheSizeFailoverTest.java | 6 +- .../IgniteCacheSystemTransactionsSelfTest.java | 6 +- .../IgniteNoClassOnServerAbstractTest.java | 135 ++ .../IgniteTxCachePrimarySyncTest.java | 62 +- ...teSynchronizationModesMultithreadedTest.java | 15 +- ...iteTxConsistencyRestartAbstractSelfTest.java | 12 +- ...xOriginatingNodeFailureAbstractSelfTest.java | 10 +- ...cOriginatingNodeFailureAbstractSelfTest.java | 22 +- .../IgniteTxTimeoutAbstractTest.java | 2 +- ...heAbstractTransformWriteThroughSelfTest.java | 2 +- .../dht/GridCacheAtomicNearCacheSelfTest.java | 50 +- .../dht/GridCacheColocatedDebugTest.java | 112 +- ...eColocatedOptimisticTransactionSelfTest.java | 2 +- ...dCacheColocatedTxSingleThreadedSelfTest.java | 2 +- .../dht/GridCacheDhtEntrySelfTest.java | 6 +- ...GridCacheDhtEvictionNearReadersSelfTest.java | 8 +- .../dht/GridCacheDhtMappingSelfTest.java | 4 +- .../dht/GridCacheDhtPreloadBigDataSelfTest.java | 10 +- .../dht/GridCacheDhtPreloadDelayedSelfTest.java | 26 +- .../GridCacheDhtPreloadDisabledSelfTest.java | 10 +- .../GridCacheDhtPreloadMessageCountTest.java | 8 +- .../dht/GridCacheDhtPreloadPutGetSelfTest.java | 4 +- .../dht/GridCacheDhtPreloadSelfTest.java | 18 +- .../GridCacheDhtPreloadStartStopSelfTest.java | 4 +- .../dht/GridCacheDhtPreloadUnloadSelfTest.java | 24 +- ...ePartitionedNearDisabledMetricsSelfTest.java | 12 +- ...idCachePartitionedPreloadEventsSelfTest.java | 6 +- ...dCachePartitionedTopologyChangeSelfTest.java | 18 +- ...itionedTxOriginatingNodeFailureSelfTest.java | 10 +- ...ridCachePartitionedUnloadEventsSelfTest.java | 10 +- .../dht/GridCacheTxNodeFailureSelfTest.java | 12 +- .../dht/GridNearCacheTxNodeFailureSelfTest.java | 31 - .../IgniteCacheCommitDelayTxRecoveryTest.java | 22 +- .../dht/IgniteCacheConcurrentPutGetRemove.java | 2 +- .../IgniteCacheCrossCacheTxFailoverTest.java | 5 +- .../dht/IgniteCacheLockFailoverSelfTest.java | 8 +- .../dht/IgniteCacheMultiTxLockSelfTest.java | 3 +- ...artitionedBackupNodeFailureRecoveryTest.java | 6 +- ...ePrimaryNodeFailureRecoveryAbstractTest.java | 12 +- .../IgniteCachePutRetryAbstractSelfTest.java | 33 +- .../dht/IgniteCachePutRetryAtomicSelfTest.java | 4 +- ...gniteCachePutRetryTransactionalSelfTest.java | 8 +- .../dht/IgniteCacheTxRecoveryRollbackTest.java | 37 +- .../dht/IgniteCrossCacheTxSelfTest.java | 8 + .../dht/IgniteTxReentryColocatedSelfTest.java | 2 +- ...eAtomicInvalidPartitionHandlingSelfTest.java | 12 +- .../atomic/GridCacheAtomicPreloadSelfTest.java | 10 +- .../atomic/IgniteCacheAtomicProtocolTest.java | 78 +- ...tomicClientOnlyMultiNodeFullApiSelfTest.java | 57 +- ...eAtomicNearOnlyMultiNodeFullApiSelfTest.java | 2 +- ...AtomicPartitionedTckMetricsSelfTestImpl.java | 8 +- .../near/GridCacheGetStoreErrorSelfTest.java | 4 +- .../near/GridCacheNearEvictionSelfTest.java | 6 +- .../near/GridCacheNearMetricsSelfTest.java | 32 +- .../near/GridCacheNearMultiGetSelfTest.java | 6 +- .../near/GridCacheNearMultiNodeSelfTest.java | 14 +- ...idCacheNearOnlyMultiNodeFullApiSelfTest.java | 10 +- .../near/GridCacheNearOnlyTopologySelfTest.java | 16 +- .../GridCacheNearPartitionedClearSelfTest.java | 2 +- .../GridCacheNearReaderPreloadSelfTest.java | 2 +- .../near/GridCacheNearReadersSelfTest.java | 36 +- .../near/GridCacheNearTxForceKeyTest.java | 8 +- .../near/GridCacheNearTxMultiNodeSelfTest.java | 18 +- ...AffinityExcludeNeighborsPerformanceTest.java | 2 +- .../GridCachePartitionedAffinitySelfTest.java | 8 +- ...ionedClientOnlyNoPrimaryFullApiSelfTest.java | 4 +- .../GridCachePartitionedEvictionSelfTest.java | 2 +- ...titionedExplicitLockNodeFailureSelfTest.java | 4 +- ...GridCachePartitionedFilteredPutSelfTest.java | 2 +- .../GridCachePartitionedFullApiSelfTest.java | 8 +- ...idCachePartitionedHitsAndMissesSelfTest.java | 5 +- .../GridCachePartitionedLoadCacheSelfTest.java | 2 +- ...achePartitionedMultiNodeCounterSelfTest.java | 24 +- ...achePartitionedMultiNodeFullApiSelfTest.java | 93 +- ...ePartitionedMultiThreadedPutGetSelfTest.java | 8 +- .../GridCachePartitionedNodeRestartTest.java | 1 - ...ePartitionedOptimisticTxNodeRestartTest.java | 1 - .../GridCachePartitionedStorePutSelfTest.java | 6 +- .../GridCachePartitionedTxSalvageSelfTest.java | 4 +- ...achePartitionedTxSingleThreadedSelfTest.java | 2 +- .../near/GridCachePutArrayValueSelfTest.java | 2 +- ...idCacheRendezvousAffinityClientSelfTest.java | 2 +- .../near/GridPartitionedBackupLoadSelfTest.java | 4 +- .../near/IgniteCacheNearOnlyTxTest.java | 24 +- .../near/IgniteCacheNearReadCommittedTest.java | 4 +- .../near/IgniteTxReentryNearSelfTest.java | 2 +- .../near/NearCacheMultithreadedUpdateTest.java | 8 +- .../near/NearCachePutAllMultinodeTest.java | 4 +- .../near/NearCacheSyncUpdateTest.java | 4 +- .../near/NoneRebalanceModeSelfTest.java | 4 +- ...cingDelayedPartitionMapExchangeSelfTest.java | 8 +- .../GridCacheRebalancingOrderingTest.java | 2 +- .../GridCacheRebalancingSyncCheckDataTest.java | 6 +- .../GridCacheRebalancingSyncSelfTest.java | 10 +- ...eRebalancingUnmarshallingFailedSelfTest.java | 2 +- ...stractReplicatedByteArrayValuesSelfTest.java | 2 +- .../GridCacheReplicatedNodeRestartSelfTest.java | 2 - ...idCacheReplicatedUnswapAdvancedSelfTest.java | 151 -- .../GridCacheSyncReplicatedPreloadSelfTest.java | 14 +- .../GridCacheReplicatedPreloadSelfTest.java | 50 +- ...eplicatedPreloadStartStopEventsSelfTest.java | 2 +- .../cache/eviction/EvictionAbstractTest.java | 13 +- ...heConcurrentEvictionConsistencySelfTest.java | 2 +- .../GridCacheConcurrentEvictionsSelfTest.java | 2 +- .../GridCacheEmptyEntriesAbstractSelfTest.java | 2 +- .../GridCacheEvictionFilterSelfTest.java | 4 +- .../GridCacheEvictionTouchSelfTest.java | 8 +- .../lru/LruNearEvictionPolicySelfTest.java | 7 +- .../LruNearOnlyNearEvictionPolicySelfTest.java | 9 +- .../paged/PageEvictionAbstractTest.java | 22 +- ...LruNearEnabledPageEvictionMultinodeTest.java | 28 + ...LruNearEnabledPageEvictionMultinodeTest.java | 28 + .../SortedEvictionPolicyPerformanceTest.java | 2 +- .../IgniteCacheClientNearCacheExpiryTest.java | 4 +- .../IgniteCacheExpiryPolicyAbstractTest.java | 10 +- ...eCacheExpiryPolicyWithStoreAbstractTest.java | 6 +- .../expiry/IgniteCacheLargeValueExpireTest.java | 4 +- ...eCacheOnlyOneTtlCleanupThreadExistsTest.java | 5 +- .../expiry/IgniteCacheTtlCleanupSelfTest.java | 8 +- .../IgniteCacheLoadAllAbstractTest.java | 2 +- .../IgniteCacheStoreSessionAbstractTest.java | 5 +- ...acheStoreSessionWriteBehindAbstractTest.java | 2 +- .../IgniteCacheTxStoreSessionTest.java | 22 +- ...dCacheAtomicLocalTckMetricsSelfTestImpl.java | 8 +- .../GridCacheLocalByteArrayValuesSelfTest.java | 2 +- .../local/GridCacheLocalFullApiSelfTest.java | 4 +- .../cache/local/GridCacheLocalLockSelfTest.java | 6 +- .../GridCacheLocalMultithreadedSelfTest.java | 2 +- .../local/GridCacheLocalTxTimeoutSelfTest.java | 2 +- .../BinaryTxCacheLocalEntriesSelfTest.java | 2 +- .../cache/query/IndexingSpiQuerySelfTest.java | 26 +- .../cache/query/IndexingSpiQueryTxSelfTest.java | 10 - .../continuous/CacheContinuousBatchAckTest.java | 2 +- ...eContinuousQueryAsyncFilterListenerTest.java | 2 +- ...acheContinuousQueryExecuteInPrimaryTest.java | 2 +- ...ContinuousQueryFailoverAbstractSelfTest.java | 85 +- ...ontinuousQueryOperationFromCallbackTest.java | 2 +- .../CacheContinuousQueryOperationP2PTest.java | 2 +- .../CacheContinuousQueryOrderingEventTest.java | 2 +- ...acheContinuousQueryRandomOperationsTest.java | 2 +- .../CacheKeepBinaryIterationTest.java | 2 +- .../ClientReconnectContinuousQueryTest.java | 4 +- ...yRemoteFilterMissingInClassPathSelfTest.java | 2 +- ...ridCacheContinuousQueryAbstractSelfTest.java | 68 +- ...dCacheContinuousQueryNodesFilteringTest.java | 2 +- ...dCacheContinuousQueryReplicatedSelfTest.java | 8 +- ...eContinuousQueryReplicatedTxOneNodeTest.java | 4 +- ...CacheContinuousQueryClientReconnectTest.java | 6 +- .../IgniteCacheContinuousQueryClientTest.java | 18 +- ...eCacheContinuousQueryImmutableEntryTest.java | 10 +- ...teCacheContinuousQueryNoUnsubscribeTest.java | 14 +- ...IgniteCacheContinuousQueryReconnectTest.java | 8 +- ...BehindStorePartitionedMultiNodeSelfTest.java | 6 +- .../IgniteCacheWriteBehindNoUpdateSelfTest.java | 2 +- ...CacheClientWriteBehindStoreAbstractTest.java | 2 +- ...ClientWriteBehindStoreNonCoalescingTest.java | 2 +- ...DeadlockDetectionMessageMarshallingTest.java | 116 ++ .../TxDeadlockDetectionUnmasrhalErrorsTest.java | 225 ++ ...simisticDeadlockDetectionCrossCacheTest.java | 3 +- .../TxPessimisticDeadlockDetectionTest.java | 2 +- .../CacheVersionedEntryAbstractTest.java | 10 +- ...puteCustomExecutorConfigurationSelfTest.java | 85 + .../IgniteComputeCustomExecutorSelfTest.java | 245 +++ .../processors/database/BPlusTreeSelfTest.java | 26 +- .../database/FreeListImplSelfTest.java | 26 +- .../database/IgniteDbAbstractTest.java | 2 +- .../database/IgniteDbDynamicCacheSelfTest.java | 5 +- .../IgniteDbMemoryLeakAbstractTest.java | 2 +- .../database/IgniteDbPutGetAbstractTest.java | 48 +- .../database/MemoryMetricsSelfTest.java | 5 +- .../database/MetadataStorageSelfTest.java | 21 +- .../DataStreamProcessorSelfTest.java | 58 +- .../datastreamer/DataStreamerImplSelfTest.java | 10 +- .../DataStreamerMultiThreadedSelfTest.java | 2 +- .../DataStreamerUpdateAfterLoadTest.java | 5 +- .../IgniteDataStreamerPerformanceTest.java | 3 +- ...faultIgfsSecondaryFileSystemTestAdapter.java | 2 +- .../processors/igfs/IgfsAbstractSelfTest.java | 17 +- ...lockMessageSystemPoolStarvationSelfTest.java | 4 +- .../processors/igfs/IgfsCacheSelfTest.java | 3 +- .../igfs/IgfsDataManagerSelfTest.java | 3 +- .../igfs/IgfsDualAbstractSelfTest.java | 6 +- .../processors/igfs/IgfsIgniteMock.java | 7 - ...IgfsLocalSecondaryFileSystemTestAdapter.java | 2 +- .../processors/igfs/IgfsMaxSizeSelfTest.java | 121 -- .../igfs/IgfsMetaManagerSelfTest.java | 3 +- .../internal/processors/igfs/IgfsMock.java | 2 +- .../processors/igfs/IgfsOneClientNodeTest.java | 7 +- .../processors/igfs/IgfsProcessorSelfTest.java | 3 +- ...gfsSecondaryFileSystemInjectionSelfTest.java | 2 +- .../IgfsSecondaryFileSystemTestAdapter.java | 2 +- .../processors/igfs/IgfsSizeSelfTest.java | 50 +- .../processors/igfs/IgfsStartCacheTest.java | 4 +- .../processors/igfs/IgfsStreamsSelfTest.java | 3 +- .../processors/igfs/IgfsTaskSelfTest.java | 4 +- .../IgfsAbstractRecordResolverSelfTest.java | 4 +- .../cache/GridCacheCommandHandlerSelfTest.java | 4 + .../query/GridQueryCommandHandlerTest.java | 2 +- .../service/GridServiceClientNodeTest.java | 7 +- .../GridServiceProcessorAbstractSelfTest.java | 2 +- .../ServicePredicateAccessCacheTest.java | 2 +- .../IgniteOffheapReadWriteLockSelfTest.java | 18 +- .../loadtests/GridCacheMultiNodeLoadTest.java | 1 - .../cache/GridCacheAbstractLoadTest.java | 5 +- .../cache/GridCacheDataStructuresLoadTest.java | 2 +- .../loadtests/cache/GridCacheLoadTest.java | 4 +- .../loadtests/cache/GridCacheSwapLoadTest.java | 320 --- .../capacity/GridCapacityLoadTest.java | 2 +- .../capacity/spring-capacity-cache.xml | 5 +- .../loadtests/colocation/spring-colocation.xml | 5 - .../GridContinuousOperationsLoadTest.java | 2 +- .../GridCachePartitionedAtomicLongLoadTest.java | 3 +- ...ridSingleSplitsNewNodesAbstractLoadTest.java | 11 +- ...idSingleSplitsNewNodesMulticastLoadTest.java | 9 +- .../loadtests/discovery/GridGcTimeoutTest.java | 2 +- .../marshaller/GridMarshallerAbstractTest.java | 10 +- .../p2p/GridP2PSameClassLoaderSelfTest.java | 2 +- .../platform/PlatformCacheWriteMetricsTask.java | 5 - .../platform/PlatformComputeEchoTask.java | 11 +- .../ignite/platform/PlatformSqlQueryTask.java | 2 +- .../CacheCheckpointSpiSecondCacheSelfTest.java | 7 +- .../communication/GridCacheMessageSelfTest.java | 2 +- .../tcp/GridCacheDhtLockBackupSelfTest.java | 6 +- .../discovery/AbstractDiscoverySelfTest.java | 19 +- ...gniteClientReconnectMassiveShutdownTest.java | 4 +- ...lientDiscoverySpiFailureTimeoutSelfTest.java | 245 ++- .../tcp/TcpClientDiscoverySpiSelfTest.java | 79 +- .../tcp/TcpDiscoveryMultiThreadedTest.java | 12 +- .../spi/discovery/tcp/TcpDiscoverySelfTest.java | 34 +- .../tcp/TcpDiscoverySpiConfigSelfTest.java | 4 +- .../TcpDiscoverySpiFailureTimeoutSelfTest.java | 51 +- .../GridInternalTasksLoadBalancingSelfTest.java | 7 +- .../stream/socket/SocketStreamerSelfTest.java | 6 +- .../ignite/testframework/GridTestNode.java | 7 + .../ignite/testframework/GridTestUtils.java | 2 +- .../configvariations/ConfigVariations.java | 2 - .../testframework/junits/GridAbstractTest.java | 27 +- .../junits/GridTestKernalContext.java | 5 +- .../ignite/testframework/junits/IgniteMock.java | 4 + .../junits/common/GridCommonAbstractTest.java | 178 +- .../multijvm/IgniteCacheProcessProxy.java | 5 - .../multijvm/IgniteClusterProcessProxy.java | 9 +- .../junits/multijvm/IgniteProcessProxy.java | 5 - .../testframework/test/ParametersTest.java | 7 +- ...ObjectsCacheDataStructuresSelfTestSuite.java | 7 +- .../IgniteCacheEvictionSelfTestSuite.java | 4 + .../IgniteCacheFailoverTestSuite.java | 2 - .../ignite/testsuites/IgniteCacheTestSuite.java | 4 + .../testsuites/IgniteCacheTestSuite2.java | 7 + .../testsuites/IgniteCacheTestSuite3.java | 2 - .../testsuites/IgniteComputeGridTestSuite.java | 7 +- .../ignite/testsuites/IgniteIgfsTestSuite.java | 5 +- .../TxDeadlockDetectionTestSuite.java | 4 + .../webapp/META-INF/ignite-webapp-config.xml | 13 - modules/extdata/p2p/pom.xml | 6 + .../tests/p2p/CacheDeploymentTestTask1.java | 2 +- .../tests/p2p/CacheDeploymentTestTask3.java | 2 +- .../p2p/GridP2PContinuousDeploymentTask1.java | 2 +- .../p2p/NoValueClassOnServerAbstractClient.java | 90 + .../CacheNoValueClassOnServerTestClient.java | 79 +- ...DataStructuresNoClassOnServerTestClient.java | 181 ++ .../sink/flink/FlinkIgniteSinkSelfTest.java | 4 +- .../query/h2/opt/GridH2SpatialIndex.java | 32 +- .../query/h2/H2IndexingAbstractGeoSelfTest.java | 5 +- .../fs/IgniteHadoopIgfsSecondaryFileSystem.java | 4 +- .../org/apache/ignite/hadoop/package-info.java | 22 - ...doopIgfsSecondaryFileSystemDelegateImpl.java | 2 +- .../hadoop/impl/igfs/HadoopIgfsInProc.java | 2 +- .../hadoop/impl/HadoopAbstractSelfTest.java | 4 +- .../HadoopIgfs20FileSystemAbstractSelfTest.java | 1 - ...adoopIgfsSecondaryFileSystemTestAdapter.java | 2 +- modules/hibernate-4.2/README.txt | 48 + modules/hibernate-4.2/licenses/apache-2.0.txt | 202 ++ modules/hibernate-4.2/pom.xml | 159 ++ .../HibernateAbstractRegionAccessStrategy.java | 102 + .../hibernate/HibernateCollectionRegion.java | 100 + .../cache/hibernate/HibernateEntityRegion.java | 112 + .../hibernate/HibernateGeneralDataRegion.java | 76 + .../cache/hibernate/HibernateKeyWrapper.java | 73 + .../hibernate/HibernateNaturalIdRegion.java | 103 + .../hibernate/HibernateQueryResultsRegion.java | 70 + .../ignite/cache/hibernate/HibernateRegion.java | 99 + .../cache/hibernate/HibernateRegionFactory.java | 179 ++ .../hibernate/HibernateTimestampsRegion.java | 39 + .../HibernateTransactionalDataRegion.java | 84 + .../ignite/cache/hibernate/package-info.java | 24 + .../hibernate/CacheHibernateBlobStore.java | 542 +++++ .../CacheHibernateBlobStoreEntry.hbm.xml | 31 + .../hibernate/CacheHibernateBlobStoreEntry.java | 89 + .../CacheHibernateBlobStoreFactory.java | 235 +++ .../CacheHibernateStoreSessionListener.java | 222 ++ .../cache/store/hibernate/package-info.java | 22 + .../src/test/config/factory-cache.xml | 59 + .../src/test/config/factory-cache1.xml | 61 + .../config/factory-incorrect-store-cache.xml | 56 + .../HibernateL2CacheConfigurationSelfTest.java | 409 ++++ .../hibernate/HibernateL2CacheMultiJvmTest.java | 440 ++++ .../hibernate/HibernateL2CacheSelfTest.java | 1954 +++++++++++++++++ .../HibernateL2CacheTransactionalSelfTest.java | 154 ++ ...nateL2CacheTransactionalUseSyncSelfTest.java | 31 + .../CacheHibernateBlobStoreNodeRestartTest.java | 46 + .../CacheHibernateBlobStoreSelfTest.java | 113 + .../CacheHibernateStoreFactorySelfTest.java | 288 +++ ...heHibernateStoreSessionListenerSelfTest.java | 238 +++ .../cache/store/hibernate/hibernate.cfg.xml | 42 + .../cache/store/hibernate/package-info.java | 22 + .../IgniteBinaryHibernateTestSuite.java | 37 + .../testsuites/IgniteHibernateTestSuite.java | 57 + modules/hibernate-5.1/README.txt | 48 + modules/hibernate-5.1/licenses/apache-2.0.txt | 202 ++ modules/hibernate-5.1/pom.xml | 159 ++ .../HibernateAbstractRegionAccessStrategy.java | 103 + .../hibernate/HibernateCollectionRegion.java | 114 + .../cache/hibernate/HibernateEntityRegion.java | 128 ++ .../hibernate/HibernateGeneralDataRegion.java | 79 + .../cache/hibernate/HibernateKeyWrapper.java | 109 + .../hibernate/HibernateNaturalIdRegion.java | 113 + .../hibernate/HibernateQueryResultsRegion.java | 70 + .../ignite/cache/hibernate/HibernateRegion.java | 99 + .../cache/hibernate/HibernateRegionFactory.java | 168 ++ .../hibernate/HibernateTimestampsRegion.java | 39 + .../HibernateTransactionalDataRegion.java | 84 + .../ignite/cache/hibernate/package-info.java | 24 + .../hibernate/CacheHibernateBlobStore.java | 543 +++++ .../CacheHibernateBlobStoreEntry.hbm.xml | 31 + .../hibernate/CacheHibernateBlobStoreEntry.java | 89 + .../CacheHibernateBlobStoreFactory.java | 235 +++ .../CacheHibernateStoreSessionListener.java | 224 ++ .../cache/store/hibernate/package-info.java | 22 + .../src/test/config/factory-cache.xml | 59 + .../src/test/config/factory-cache1.xml | 61 + .../config/factory-incorrect-store-cache.xml | 56 + .../HibernateL2CacheConfigurationSelfTest.java | 407 ++++ .../hibernate/HibernateL2CacheMultiJvmTest.java | 429 ++++ .../hibernate/HibernateL2CacheSelfTest.java | 1960 ++++++++++++++++++ .../HibernateL2CacheTransactionalSelfTest.java | 154 ++ ...nateL2CacheTransactionalUseSyncSelfTest.java | 31 + .../CacheHibernateBlobStoreNodeRestartTest.java | 46 + .../CacheHibernateBlobStoreSelfTest.java | 114 + .../CacheHibernateStoreFactorySelfTest.java | 256 +++ ...heHibernateStoreSessionListenerSelfTest.java | 242 +++ .../cache/store/hibernate/hibernate.cfg.xml | 42 + .../cache/store/hibernate/package-info.java | 22 + .../IgniteBinaryHibernate5TestSuite.java | 37 + .../testsuites/IgniteHibernate5TestSuite.java | 57 + modules/hibernate-core/pom.xml | 84 + .../HibernateAccessStrategyAdapter.java | 340 +++ .../HibernateAccessStrategyFactory.java | 235 +++ .../cache/hibernate/HibernateCacheProxy.java | 801 +++++++ .../hibernate/HibernateExceptionConverter.java | 29 + .../hibernate/HibernateKeyTransformer.java | 29 + .../HibernateNonStrictAccessStrategy.java | 230 ++ .../HibernateReadOnlyAccessStrategy.java | 105 + .../HibernateReadWriteAccessStrategy.java | 326 +++ .../HibernateTransactionalAccessStrategy.java | 141 ++ .../ignite/cache/hibernate/package-info.java | 24 + modules/hibernate/README.txt | 48 - modules/hibernate/licenses/apache-2.0.txt | 202 -- modules/hibernate/pom.xml | 146 -- .../HibernateAbstractRegionAccessStrategy.java | 98 - .../HibernateAccessStrategyAdapter.java | 379 ---- .../cache/hibernate/HibernateCacheProxy.java | 811 -------- .../hibernate/HibernateCollectionRegion.java | 100 - .../cache/hibernate/HibernateEntityRegion.java | 112 - .../hibernate/HibernateGeneralDataRegion.java | 71 - .../hibernate/HibernateKeyTransformer.java | 28 - .../cache/hibernate/HibernateKeyWrapper.java | 72 - .../hibernate/HibernateNaturalIdRegion.java | 100 - .../HibernateNonStrictAccessStrategy.java | 222 -- .../hibernate/HibernateQueryResultsRegion.java | 70 - .../HibernateReadOnlyAccessStrategy.java | 107 - .../HibernateReadWriteAccessStrategy.java | 328 --- .../ignite/cache/hibernate/HibernateRegion.java | 99 - .../cache/hibernate/HibernateRegionFactory.java | 266 --- .../hibernate/HibernateTimestampsRegion.java | 39 - .../HibernateTransactionalAccessStrategy.java | 141 -- .../HibernateTransactionalDataRegion.java | 107 - .../ignite/cache/hibernate/package-info.java | 24 - .../hibernate/CacheHibernateBlobStore.java | 542 ----- .../CacheHibernateBlobStoreEntry.hbm.xml | 31 - .../hibernate/CacheHibernateBlobStoreEntry.java | 89 - .../CacheHibernateBlobStoreFactory.java | 235 --- .../CacheHibernateStoreSessionListener.java | 222 -- .../cache/store/hibernate/package-info.java | 22 - .../hibernate/src/test/config/factory-cache.xml | 59 - .../src/test/config/factory-cache1.xml | 61 - .../config/factory-incorrect-store-cache.xml | 56 - .../HibernateL2CacheConfigurationSelfTest.java | 408 ---- .../hibernate/HibernateL2CacheSelfTest.java | 1949 ----------------- .../HibernateL2CacheTransactionalSelfTest.java | 154 -- ...nateL2CacheTransactionalUseSyncSelfTest.java | 31 - .../CacheHibernateBlobStoreNodeRestartTest.java | 46 - .../CacheHibernateBlobStoreSelfTest.java | 113 - .../CacheHibernateStoreFactorySelfTest.java | 285 --- ...heHibernateStoreSessionListenerSelfTest.java | 238 --- .../cache/store/hibernate/hibernate.cfg.xml | 42 - .../cache/store/hibernate/package-info.java | 22 - .../IgniteBinaryHibernateTestSuite.java | 37 - .../testsuites/IgniteHibernateTestSuite.java | 57 - modules/hibernate5/README.txt | 48 - modules/hibernate5/licenses/apache-2.0.txt | 202 -- modules/hibernate5/pom.xml | 146 -- .../HibernateAbstractRegionAccessStrategy.java | 99 - .../HibernateAccessStrategyAdapter.java | 379 ---- .../cache/hibernate/HibernateCacheProxy.java | 811 -------- .../hibernate/HibernateCollectionRegion.java | 114 - .../cache/hibernate/HibernateEntityRegion.java | 129 -- .../hibernate/HibernateGeneralDataRegion.java | 72 - .../hibernate/HibernateKeyTransformer.java | 28 - .../cache/hibernate/HibernateKeyWrapper.java | 108 - .../hibernate/HibernateNaturalIdRegion.java | 113 - .../HibernateNonStrictAccessStrategy.java | 222 -- .../hibernate/HibernateQueryResultsRegion.java | 70 - .../HibernateReadOnlyAccessStrategy.java | 107 - .../HibernateReadWriteAccessStrategy.java | 328 --- .../ignite/cache/hibernate/HibernateRegion.java | 99 - .../cache/hibernate/HibernateRegionFactory.java | 255 --- .../hibernate/HibernateTimestampsRegion.java | 39 - .../HibernateTransactionalAccessStrategy.java | 141 -- .../HibernateTransactionalDataRegion.java | 107 - .../ignite/cache/hibernate/package-info.java | 24 - .../hibernate/CacheHibernateBlobStore.java | 542 ----- .../CacheHibernateBlobStoreEntry.hbm.xml | 31 - .../hibernate/CacheHibernateBlobStoreEntry.java | 89 - .../CacheHibernateBlobStoreFactory.java | 235 --- .../CacheHibernateStoreSessionListener.java | 223 -- .../cache/store/hibernate/package-info.java | 22 - .../src/test/config/factory-cache.xml | 59 - .../src/test/config/factory-cache1.xml | 61 - .../config/factory-incorrect-store-cache.xml | 56 - .../HibernateL2CacheConfigurationSelfTest.java | 409 ---- .../hibernate/HibernateL2CacheSelfTest.java | 1948 ----------------- .../HibernateL2CacheTransactionalSelfTest.java | 154 -- ...nateL2CacheTransactionalUseSyncSelfTest.java | 31 - .../CacheHibernateBlobStoreNodeRestartTest.java | 46 - .../CacheHibernateBlobStoreSelfTest.java | 113 - .../CacheHibernateStoreFactorySelfTest.java | 326 --- ...heHibernateStoreSessionListenerSelfTest.java | 241 --- .../cache/store/hibernate/hibernate.cfg.xml | 42 - .../cache/store/hibernate/package-info.java | 22 - .../IgniteBinaryHibernate5TestSuite.java | 37 - .../testsuites/IgniteHibernate5TestSuite.java | 57 - .../query/h2/DmlStatementsProcessor.java | 17 +- .../processors/query/h2/IgniteH2Indexing.java | 317 +-- .../query/h2/database/H2PkHashIndex.java | 6 +- .../query/h2/database/H2TreeIndex.java | 6 +- .../query/h2/database/InlineIndexHelper.java | 14 - .../query/h2/ddl/DdlStatementsProcessor.java | 19 +- .../query/h2/dml/UpdatePlanBuilder.java | 32 +- .../query/h2/opt/GridH2AbstractKeyValueRow.java | 165 +- .../query/h2/opt/GridH2CollocationModel.java | 4 +- .../query/h2/opt/GridH2IndexBase.java | 22 +- .../query/h2/opt/GridH2KeyValueRowOffheap.java | 76 +- .../query/h2/opt/GridH2KeyValueRowOnheap.java | 6 +- .../query/h2/opt/GridH2MetaTable.java | 8 +- .../query/h2/opt/GridH2PrimaryScanIndex.java | 7 +- .../query/h2/opt/GridH2ProxyIndex.java | 204 ++ .../query/h2/opt/GridH2ProxySpatialIndex.java | 70 + .../processors/query/h2/opt/GridH2Row.java | 2 +- .../query/h2/opt/GridH2RowDescriptor.java | 76 +- .../query/h2/opt/GridH2ScanIndex.java | 4 +- .../processors/query/h2/opt/GridH2Table.java | 206 +- .../query/h2/opt/GridH2TreeIndex.java | 7 +- .../query/h2/opt/GridLuceneIndex.java | 4 +- .../processors/query/h2/sql/DmlAstUtils.java | 39 +- .../processors/query/h2/sql/GridSqlAlias.java | 20 +- .../query/h2/sql/GridSqlQueryParser.java | 4 + .../processors/query/h2/sql/GridSqlTable.java | 46 + .../query/h2/twostep/GridMapQueryExecutor.java | 5 +- .../query/h2/twostep/GridMergeIndex.java | 1 + .../query/h2/twostep/GridMergeIndexSorted.java | 6 +- .../h2/twostep/GridMergeIndexUnsorted.java | 6 +- .../query/h2/twostep/GridMergeTable.java | 12 +- .../h2/twostep/GridReduceQueryExecutor.java | 251 ++- .../query/h2/twostep/GridThreadLocalTable.java | 14 +- .../h2/twostep/msg/GridH2QueryRequest.java | 64 +- .../cache/BinarySerializationQuerySelfTest.java | 5 +- .../CacheBinaryKeyConcurrentQueryTest.java | 2 +- .../cache/CacheIndexStreamerTest.java | 4 +- .../CacheOffheapBatchIndexingBaseTest.java | 2 +- .../CacheOperationsWithExpirationTest.java | 2 +- .../cache/CacheQueryBuildValueTest.java | 4 +- .../cache/CacheQueryEvictDataLostTest.java | 2 +- .../cache/CacheQueryFilterExpiredTest.java | 2 +- .../CacheRandomOperationsMultithreadedTest.java | 2 +- ...CacheScanPartitionQueryFallbackSelfTest.java | 12 +- .../cache/CacheSqlQueryValueCopySelfTest.java | 18 +- ...ryDuplicateIndexObjectsAbstractSelfTest.java | 159 -- .../cache/GridCacheOffHeapSelfTest.java | 480 +---- .../GridCacheOffheapIndexEntryEvictTest.java | 4 +- .../cache/GridCacheQuerySimpleBenchmark.java | 2 +- .../cache/GridCacheQueryTestValue.java | 2 +- .../cache/GridIndexingWithNoopSwapSelfTest.java | 2 +- .../IgniteBinaryObjectFieldsQuerySelfTest.java | 9 +- .../IgniteBinaryObjectQueryArgumentsTest.java | 8 +- ...eBinaryWrappedObjectFieldsQuerySelfTest.java | 3 +- .../IgniteCacheAbstractFieldsQuerySelfTest.java | 44 +- ...niteCacheAbstractInsertSqlQuerySelfTest.java | 2 +- .../cache/IgniteCacheAbstractQuerySelfTest.java | 6 +- .../IgniteCacheAbstractSqlDmlQuerySelfTest.java | 2 +- .../IgniteCacheCollocatedQuerySelfTest.java | 6 +- ...acheConfigurationPrimitiveTypesSelfTest.java | 14 +- .../IgniteCacheCrossCacheJoinRandomTest.java | 2 +- .../IgniteCacheDeleteSqlQuerySelfTest.java | 6 +- ...acheDistributedJoinCollocatedAndNotTest.java | 2 +- ...acheDistributedJoinCustomAffinityMapper.java | 2 +- .../IgniteCacheDistributedJoinNoIndexTest.java | 2 +- ...ributedJoinPartitionedAndReplicatedTest.java | 2 +- ...CacheDistributedJoinQueryConditionsTest.java | 2 +- .../cache/IgniteCacheDistributedJoinTest.java | 12 +- .../IgniteCacheFieldsQueryNoDataSelfTest.java | 2 +- ...teCacheFullTextQueryNodeJoiningSelfTest.java | 6 +- ...PartitionedAndReplicatedCollocationTest.java | 2 +- ...teCacheJoinPartitionedAndReplicatedTest.java | 2 +- ...IgniteCacheJoinQueryWithAffinityKeyTest.java | 22 +- .../cache/IgniteCacheLargeResultSelfTest.java | 4 +- ...eLockPartitionOnAffinityRunAbstractTest.java | 4 + .../IgniteCacheMultipleIndexedTypesTest.java | 2 +- .../IgniteCacheObjectKeyIndexingSelfTest.java | 6 +- .../cache/IgniteCacheOffheapEvictQueryTest.java | 2 +- .../cache/IgniteCacheOffheapIndexScanTest.java | 4 +- ...hePartitionedQueryMultiThreadedSelfTest.java | 4 +- .../cache/IgniteCacheQueriesLoadTest1.java | 2 +- .../IgniteCacheQueryH2IndexingLeakTest.java | 4 +- .../cache/IgniteCacheQueryIndexSelfTest.java | 4 +- .../cache/IgniteCacheQueryLoadSelfTest.java | 14 +- .../IgniteCacheQueryMultiThreadedSelfTest.java | 40 +- ...gniteCacheSqlQueryMultiThreadedSelfTest.java | 6 +- .../IgniteCacheStarvationOnRebalanceTest.java | 2 +- .../IgniteCacheUpdateSqlQuerySelfTest.java | 8 +- ...ClientReconnectCacheQueriesFailoverTest.java | 10 +- .../cache/IgniteCrossCachesJoinsQueryTest.java | 79 +- .../cache/QueryEntityCaseMismatchTest.java | 2 +- .../cache/SqlFieldsQuerySelfTest.java | 2 +- ...ateIndexObjectPartitionedAtomicSelfTest.java | 38 - ...xObjectPartitionedTransactionalSelfTest.java | 41 - ...stributedPartitionQueryAbstractSelfTest.java | 652 ++++++ ...utedPartitionQueryConfigurationSelfTest.java | 92 + ...butedPartitionQueryNodeRestartsSelfTest.java | 114 + ...eCacheDistributedPartitionQuerySelfTest.java | 90 + ...niteCacheDistributedQueryCancelSelfTest.java | 6 +- ...butedQueryStopOnCancelOrTimeoutSelfTest.java | 6 +- .../IgniteCachePartitionedQuerySelfTest.java | 2 +- .../IgniteCacheQueryNoRebalanceSelfTest.java | 4 +- .../near/IgniteCacheQueryNodeFailTest.java | 4 +- .../IgniteCacheQueryNodeRestartSelfTest.java | 2 +- .../IgniteCacheQueryNodeRestartSelfTest2.java | 7 +- .../cache/index/AbstractSchemaSelfTest.java | 53 +- .../DynamicIndexAbstractBasicSelfTest.java | 188 +- .../DynamicIndexAbstractConcurrentSelfTest.java | 127 +- .../index/DynamicIndexAbstractSelfTest.java | 42 +- .../cache/index/SchemaExchangeSelfTest.java | 57 +- ...eCacheLocalQueryCancelOrTimeoutSelfTest.java | 6 +- .../cache/ttl/CacheTtlAbstractSelfTest.java | 6 +- ...gniteDbSingleNodeWithIndexingPutGetTest.java | 5 +- .../query/IgniteQueryDedicatedPoolTest.java | 12 +- .../query/IgniteSqlDistributedJoinSelfTest.java | 2 +- .../query/IgniteSqlKeyValueFieldsTest.java | 392 ++++ .../query/IgniteSqlSchemaIndexingTest.java | 2 +- .../query/IgniteSqlSplitterSelfTest.java | 90 +- .../h2/GridIndexingSpiAbstractSelfTest.java | 14 +- .../query/h2/IgniteSqlQueryMinMaxTest.java | 4 +- .../h2/database/InlineIndexHelperTest.java | 48 +- .../query/h2/sql/GridQueryParsingTest.java | 36 +- .../IgniteBinaryCacheQueryTestSuite.java | 5 - .../IgniteCacheQuerySelfTestSuite.java | 10 + .../stream/jms11/IgniteJmsStreamerTest.java | 28 +- ...CacheJtaConfigurationValidationSelfTest.java | 2 +- ...CacheJtaFactoryConfigValidationSelfTest.java | 2 +- ...titionedCacheJtaLookupClassNameSelfTest.java | 2 +- .../stream/kafka/connect/IgniteSourceTask.java | 4 - .../kafka/KafkaIgniteStreamerSelfTest.java | 8 +- .../java/org/apache/ignite/ml/math/Algebra.java | 89 +- .../ignite/ml/math/IdentityValueMapper.java | 3 +- .../java/org/apache/ignite/ml/math/Matrix.java | 32 +- .../org/apache/ignite/ml/math/MurmurHash.java | 16 +- .../java/org/apache/ignite/ml/math/Tracer.java | 61 +- .../java/org/apache/ignite/ml/math/Vector.java | 3 +- .../decompositions/CholeskyDecomposition.java | 8 +- .../math/decompositions/EigenDecomposition.java | 4 +- .../ml/math/decompositions/LUDecomposition.java | 8 +- .../ignite/ml/math/functions/Functions.java | 21 +- .../ml/math/impls/matrix/PivotedMatrixView.java | 2 +- .../impls/matrix/SparseDistributedMatrix.java | 12 +- .../storage/matrix/CacheMatrixStorage.java | 15 +- .../matrix/DenseOffHeapMatrixStorage.java | 14 +- .../storage/matrix/FunctionMatrixStorage.java | 16 +- .../matrix/SparseDistributedMatrixStorage.java | 3 - .../matrix/SparseLocalOnHeapMatrixStorage.java | 18 +- .../storage/vector/CacheVectorStorage.java | 12 +- .../storage/vector/ConstantVectorStorage.java | 9 +- .../storage/vector/FunctionVectorStorage.java | 16 +- .../storage/vector/MatrixVectorStorage.java | 18 +- .../storage/vector/PivotedVectorStorage.java | 15 +- .../SingleElementVectorDelegateStorage.java | 12 +- .../vector/SingleElementVectorStorage.java | 10 +- .../vector/SparseLocalOffHeapVectorStorage.java | 2 + .../vector/SparseLocalOnHeapVectorStorage.java | 9 +- .../ml/math/impls/vector/MatrixVectorView.java | 19 +- .../ml/math/impls/vector/PivotedVectorView.java | 13 +- .../ml/math/impls/vector/RandomVector.java | 5 +- .../math/impls/vector/SingleElementVector.java | 103 +- .../org/apache/ignite/ml/math/TracerTest.java | 11 +- .../ml/math/impls/matrix/CacheMatrixTest.java | 10 +- .../impls/matrix/MatrixKeyMapperForTests.java | 19 +- .../storage/matrix/MatrixStorageFixtures.java | 18 +- .../SparseLocalOffHeapVectorStorageTest.java | 3 +- .../math/impls/vector/AbstractVectorTest.java | 41 +- .../ml/math/impls/vector/CacheVectorTest.java | 4 +- .../stream/mqtt/IgniteMqttStreamerTest.java | 12 +- .../osgi-karaf/src/main/resources/features.xml | 2 +- modules/osgi/README.txt | 30 - .../cpp/core-test/config/cache-identity-32.xml | 7 +- .../cpp/core-test/config/cache-query-32.xml | 6 +- .../config/cache-query-continuous-32.xml | 6 +- .../config/cache-query-continuous-default.xml | 1 - .../core-test/config/cache-query-default.xml | 6 + .../cpp/core-test/config/cache-store-32.xml | 6 +- .../cpp/core-test/config/cache-test-32.xml | 6 +- .../cpp/core-test/src/cache_query_test.cpp | 82 + .../cpp/odbc-test/config/queries-default.xml | 5 + .../cpp/odbc-test/config/queries-test-32.xml | 6 +- .../odbc-test/config/queries-test-noodbc-32.xml | 6 +- .../cpp/odbc-test/include/complex_type.h | 25 + .../cpp/odbc-test/src/queries_test.cpp | 148 ++ .../ExpiryCacheHolderTest.cs | 10 + .../Config/ignite-config.xml | 1 - .../Apache.Ignite.Core.Tests.csproj | 2 + .../Binary/BinaryCompactFooterInteropTest.cs | 2 +- .../Binary/BinaryDynamicRegistrationTest.cs | 18 +- .../Binary/JavaBinaryInteropTest.cs | 6 +- .../BinaryConfigurationTest.cs | 2 +- .../Cache/Affinity/AffinityFieldTest.cs | 4 +- .../Cache/Affinity/AffinityFunctionTest.cs | 2 +- .../Cache/Affinity/AffinityTest.cs | 4 +- .../Cache/CacheAbstractTest.cs | 58 - .../Cache/CacheConfigurationTest.cs | 43 +- .../Cache/CacheForkedTest.cs | 2 +- .../Cache/CacheMetricsTest.cs | 4 +- .../Cache/CacheNearTest.cs | 34 +- .../Cache/CacheTestAsyncWrapper.cs | 22 +- .../Cache/PartitionLossTest.cs | 260 +++ .../Cache/Query/CacheLinqTest.cs | 30 +- .../Cache/Query/CacheQueriesTest.cs | 52 + .../Query/Continuous/ContinuousQueryTest.cs | 115 + .../Compute/CancellationTest.cs | 4 +- .../Compute/ComputeApiTest.cs | 30 +- .../Config/Compute/compute-grid1.xml | 4 +- .../Config/Compute/compute-grid2.xml | 1 - .../Config/Compute/compute-standalone.xml | 4 +- .../Config/Dynamic/dynamic-data.xml | 2 - .../Config/cache-binarizables.xml | 4 +- .../Config/cache-query-continuous.xml | 4 - .../native-client-test-cache-affinity.xml | 1 + .../Config/native-client-test-cache.xml | 9 - .../Config/spring-test.xml | 14 + .../DataStructures/AtomicReferenceTest.cs | 2 - .../Apache.Ignite.Core.Tests/EventsTest.cs | 13 +- .../IgniteConfigurationSerializerTest.cs | 69 +- .../IgniteConfigurationTest.cs | 87 +- .../IgniteStartStopTest.cs | 2 +- .../Apache.Ignite.Core.Tests/MarshallerTest.cs | 24 +- .../Apache.Ignite.Core.Tests/TestUtils.cs | 9 +- .../Apache.Ignite.Core.csproj | 4 + .../Cache/Configuration/CacheConfiguration.cs | 50 +- .../Cache/Configuration/DataPageEvictionMode.cs | 59 + .../Cache/Configuration/MemoryConfiguration.cs | 172 ++ .../Configuration/MemoryPolicyConfiguration.cs | 144 ++ .../Configuration/NearCacheConfiguration.cs | 2 +- .../Cache/Configuration/PartitionLossPolicy.cs | 68 + .../Cache/Configuration/QueryEntity.cs | 20 + .../dotnet/Apache.Ignite.Core/Cache/ICache.cs | 21 +- .../Apache.Ignite.Core/Cache/ICacheMetrics.cs | 8 - .../Discovery/Tcp/TcpDiscoverySpi.cs | 43 - .../dotnet/Apache.Ignite.Core/IIgnite.cs | 15 +- .../Apache.Ignite.Core/IgniteConfiguration.cs | 42 + .../IgniteConfigurationSection.xsd | 163 +- .../Apache.Ignite.Core/Impl/Cache/CacheImpl.cs | 56 +- .../Impl/Cache/CacheMetricsImpl.cs | 7 - .../Apache.Ignite.Core/Impl/Cache/CacheOp.cs | 6 +- .../Impl/Cluster/ClusterGroupImpl.cs | 27 + .../Impl/Common/DelegateConverter.cs | 1 + .../Apache.Ignite.Core/Impl/Compute/Compute.cs | 12 + .../Impl/Compute/ComputeImpl.cs | 2 + .../dotnet/Apache.Ignite.Core/Impl/Ignite.cs | 30 +- .../Apache.Ignite.Core/Impl/IgniteUtils.cs | 10 +- .../Apache.Ignite.Core/Impl/NativeMethods.cs | 50 + .../Impl/Unmanaged/UnmanagedUtils.cs | 8 +- .../Impl/CacheQueryExpressionVisitor.cs | 14 +- .../Impl/CacheQueryModelVisitor.cs | 12 +- modules/platforms/dotnet/build.ps1 | 12 +- .../Datagrid/MultiTieredCacheExample.cs | 2 +- .../http/jetty/GridJettyObjectMapper.java | 13 +- modules/rocketmq/README.txt | 25 + modules/rocketmq/licenses/apache-2.0.txt | 202 ++ modules/rocketmq/pom.xml | 81 + .../stream/rocketmq/RocketMQStreamer.java | 151 ++ .../ignite/stream/rocketmq/package-info.java | 21 + .../stream/rocketmq/RocketMQStreamerTest.java | 214 ++ .../rocketmq/RocketMQStreamerTestSuite.java | 37 + .../stream/rocketmq/TestRocketMQServer.java | 148 ++ .../ignite/stream/rocketmq/package-info.java | 21 + .../scala/org/apache/ignite/scalar/scalar.scala | 19 +- .../scalar/src/test/resources/spring-cache.xml | 4 +- .../scalar/tests/ScalarCacheQueriesSpec.scala | 2 +- .../spark/JavaEmbeddedIgniteRDDSelfTest.java | 2 +- .../spark/JavaStandaloneIgniteRDDSelfTest.java | 2 +- modules/spring-data/pom.xml | 2 +- .../support/IgniteRepositoryFactoryBean.java | 7 + .../spring/GridSpringCacheManagerSelfTest.java | 6 +- .../jdbc/CacheJdbcBlobStoreFactorySelfTest.java | 2 +- .../jdbc/CacheJdbcPojoStoreFactorySelfTest.java | 4 +- .../internal/IgniteDynamicCacheConfigTest.java | 2 +- .../java/org/apache/ignite/internal/cache.xml | 3 - .../apache/ignite/internal/filtered-cache.xml | 3 - .../apache/ignite/internal/invalid-cache.xml | 6 - .../GridTransformSpringInjectionSelfTest.java | 2 +- .../p2p/GridP2PUserVersionChangeSelfTest.java | 8 +- .../IgniteStartFromStreamConfigurationTest.java | 4 +- .../org/apache/ignite/spring/sprint-exclude.xml | 2 - .../GridSpringTransactionManagerSelfTest.java | 2 +- .../twitter/IgniteTwitterStreamerTest.java | 8 +- .../ignite/p2p/GridP2PDisabledSelfTest.java | 4 +- .../visor/commands/ack/VisorAckCommand.scala | 5 +- .../commands/cache/VisorCacheClearCommand.scala | 5 +- .../commands/cache/VisorCacheCommand.scala | 2 - .../commands/cache/VisorCacheResetCommand.scala | 4 +- .../commands/cache/VisorCacheStopCommand.scala | 4 +- .../config/VisorConfigurationCommand.scala | 2 +- .../scala/org/apache/ignite/visor/visor.scala | 5 +- .../cache/VisorCacheClearCommandSpec.scala | 24 +- .../commands/cache/VisorCacheCommandSpec.scala | 2 +- .../cache/VisorCacheResetCommandSpec.scala | 8 +- .../web-console/backend/app/browsersHandler.js | 7 +- modules/web-console/backend/app/mongo.js | 76 +- .../list-of-registered-users.column-defs.js | 26 +- .../list-of-registered-users.controller.js | 163 +- .../list-of-registered-users.tpl.pug | 25 +- .../frontend/app/data/event-groups.json | 14 - .../app/modules/agent/AgentManager.service.js | 23 +- .../frontend/app/modules/cluster/Cache.js | 4 - .../app/modules/cluster/CacheMetrics.js | 4 - .../modules/configuration/Version.service.js | 2 +- .../generator/ConfigurationGenerator.js | 14 +- .../generator/PlatformGenerator.js | 10 +- .../generator/defaults/Cache.service.js | 3 - .../generator/defaults/Cluster.service.js | 4 +- .../generator/defaults/IGFS.service.js | 1 - .../frontend/app/modules/demo/Demo.module.js | 4 +- .../frontend/app/modules/sql/sql.controller.js | 2 +- .../states/configuration/caches/memory.pug | 9 - .../states/configuration/caches/query.pug | 6 - .../states/configuration/clusters/discovery.pug | 8 +- .../modules/states/configuration/igfs/misc.pug | 2 - .../frontend/app/primitives/badge/index.scss | 1 + .../frontend/app/primitives/btn/index.scss | 52 +- .../frontend/app/primitives/dropdown/index.pug | 2 +- .../frontend/app/primitives/dropdown/index.scss | 26 +- .../frontend/app/primitives/panel/index.scss | 2 +- .../app/primitives/ui-grid-header/index.scss | 10 +- .../app/primitives/ui-grid-header/index.tpl.pug | 10 +- .../app/primitives/ui-grid-settings/index.scss | 58 +- .../frontend/app/primitives/ui-grid/index.scss | 149 +- .../frontend/gulpfile.babel.js/paths.js | 1 + .../frontend/gulpfile.babel.js/tasks/bundle.js | 2 +- .../webpack/environments/development.js | 4 +- .../frontend/public/images/icons/cross.svg | 1 + .../frontend/public/images/icons/export.svg | 1 + .../frontend/public/images/icons/gear.svg | 1 + .../stylesheets/_bootstrap-variables.scss | 4 +- .../views/templates/agent-download.tpl.pug | 6 +- modules/web-console/licenses/cc-by-3.0.txt | 319 +++ .../agent/handlers/DatabaseListener.java | 24 +- .../demo/service/DemoCachesLoadService.java | 1 - .../service/DemoRandomCacheLoadService.java | 1 - .../webapp2/META-INF/ignite-webapp-config.xml | 13 - .../config/ignite-base-load-config.xml | 31 + .../stream/zeromq/IgniteZeroMqStreamerTest.java | 12 +- .../tcp/ipfinder/zk/ZookeeperIpFinderTest.java | 5 +- parent/pom.xml | 12 +- pom.xml | 52 +- 1487 files changed, 38859 insertions(+), 31051 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/b0a53669/modules/core/src/main/java/org/apache/ignite/IgniteSystemProperties.java ---------------------------------------------------------------------- diff --cc modules/core/src/main/java/org/apache/ignite/IgniteSystemProperties.java index 8e52785,cab9772..3746c3f --- a/modules/core/src/main/java/org/apache/ignite/IgniteSystemProperties.java +++ b/modules/core/src/main/java/org/apache/ignite/IgniteSystemProperties.java @@@ -588,22 -588,9 +588,25 @@@ public final class IgniteSystemProperti */ public static final String IGNITE_INDEXING_DISCOVERY_HISTORY_SIZE = "IGNITE_INDEXING_DISCOVERY_HISTORY_SIZE"; + /** Cache start size for on-heap maps. Defaults to 4096. */ + public static final String IGNITE_CACHE_START_SIZE = "IGNITE_CACHE_START_SIZE"; + + /** + * Skip CRC calculation flag. + */ + public static final String IGNITE_PDS_SKIP_CRC = "IGNITE_PDS_SKIP_CRC"; + + /** + * WAL rebalance threshold. + */ + public static final String IGNITE_PDS_PARTITION_DESTROY_CHECKPOINT_DELAY = + "IGNITE_PDS_PARTITION_DESTROY_CHECKPOINT_DELAY"; + + /** + * WAL rebalance threshold. + */ + public static final String IGNITE_WAL_REBALANCE_THRESHOLD = "IGNITE_WAL_REBALANCE_THRESHOLD"; + /** Returns true for system properties only avoiding sending sensitive information. */ private static final IgnitePredicate<Map.Entry<String, String>> PROPS_FILTER = new IgnitePredicate<Map.Entry<String, String>>() { @Override public boolean apply(final Map.Entry<String, String> entry) {
