Merge branch 'master' into ignite-10639 # Conflicts: # modules/core/src/main/java/org/apache/ignite/internal/README.md # modules/core/src/main/java/org/apache/ignite/internal/processors/README.md # modules/core/src/main/java/org/apache/ignite/internal/processors/cache/README.md # modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/README.md
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/ffad2ac6 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/ffad2ac6 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/ffad2ac6 Branch: refs/heads/ignite-10639 Commit: ffad2ac6ae1f0b2815296956e10b2657a3bb135a Parents: 246de02 ad9d561 Author: Dmitriy Pavlov <[email protected]> Authored: Wed Dec 19 15:19:21 2018 +0300 Committer: Dmitriy Pavlov <[email protected]> Committed: Wed Dec 19 15:19:21 2018 +0300 ---------------------------------------------------------------------- CONTRIBUTING.md | 70 + .../encryption/example-encrypted-store.xml | 2 + examples/pom.xml | 6 + .../TensorFlowDistributedInferenceExample.java | 2 +- .../TensorFlowLocalInferenceExample.java | 2 +- .../TensorFlowThreadedInferenceExample.java | 2 +- .../ml/knn/ANNClassificationExample.java | 3 +- .../ml/knn/KNNClassificationExample.java | 3 +- .../OneVsRestClassificationExample.java | 163 ++ .../examples/ml/multiclass/package-info.java | 22 + .../DiscreteNaiveBayesTrainerExample.java | 115 ++ .../GaussianNaiveBayesTrainerExample.java | 3 +- ...ggedLogisticRegressionSGDTrainerExample.java | 6 +- .../LogisticRegressionSGDTrainerExample.java | 5 +- .../ml/svm/SVMBinaryClassificationExample.java | 3 +- ...ecisionTreeClassificationTrainerExample.java | 3 +- .../RandomForestClassificationExample.java | 3 +- .../ml/tutorial/Step_9_Go_to_LogReg.java | 4 +- .../examples/ml/tutorial/TitanicUtils.java | 3 +- .../examples/ml/util/MLExamplesCommonArgs.java | 2 +- .../ml/xgboost/XGBoostModelParserExample.java | 99 ++ .../examples/ml/xgboost/package-info.java | 22 + .../resources/datasets/agaricus-test-data.txt | 1611 ++++++++++++++++++ .../datasets/agaricus-test-expected-results.txt | 1611 ++++++++++++++++++ .../resources/ml/mnist_tf_model/saved_model.pb | Bin 37185 -> 0 bytes .../variables/variables.data-00000-of-00001 | Bin 13098544 -> 0 bytes .../ml/mnist_tf_model/variables/variables.index | Bin 410 -> 0 bytes .../models/mnist_tf_model/saved_model.pb | Bin 0 -> 37185 bytes .../variables/variables.data-00000-of-00001 | Bin 0 -> 13098544 bytes .../mnist_tf_model/variables/variables.index | Bin 0 -> 410 bytes .../resources/models/xgboost/agaricus-model.txt | 714 ++++++++ .../IgniteExamplesJ8SelfTestSuite.java | 81 - .../testsuites/IgniteExamplesSelfTestSuite.java | 2 +- idea/disabled_plugins.txt | 113 ++ idea/ignite_inspections_teamcity.xml | 13 + .../apache/ignite/gridify/AbstractAopTest.java | 44 + .../apache/ignite/gridify/BasicAopSelfTest.java | 7 +- .../GridifySetToXXXNonSpringAopSelfTest.java | 8 +- .../GridifySetToXXXSpringAopSelfTest.java | 8 +- .../gridify/hierarchy/GridifyHierarchyTest.java | 7 +- .../optimized/OptimizedMarshallerAopTest.java | 7 +- .../apache/ignite/p2p/P2PGridifySelfTest.java | 14 +- .../testsuites/IgniteAopSelfTestSuite.java | 18 +- .../singlesplit/SingleSplitsLoadTest.java | 5 + .../gridify/GridifySingleSplitLoadTest.java | 5 + .../gridify/ExternalNonSpringAopSelfTest.java | 36 + .../s3/S3CheckpointManagerSelfTest.java | 8 +- .../s3/S3CheckpointSpiConfigSelfTest.java | 7 +- .../checkpoint/s3/S3CheckpointSpiSelfTest.java | 9 +- ...pointSpiStartStopBucketEndpointSelfTest.java | 12 +- ...ckpointSpiStartStopSSEAlgorithmSelfTest.java | 11 +- .../s3/S3CheckpointSpiStartStopSelfTest.java | 7 +- .../s3/S3SessionCheckpointSelfTest.java | 7 +- .../elb/TcpDiscoveryElbIpFinderSelfTest.java | 7 +- .../TcpDiscoveryS3IpFinderAbstractSelfTest.java | 5 + ...3IpFinderAwsCredentialsProviderSelfTest.java | 7 +- ...scoveryS3IpFinderAwsCredentialsSelfTest.java | 7 +- ...scoveryS3IpFinderBucketEndpointSelfTest.java | 5 + ...TcpDiscoveryS3IpFinderKeyPrefixSelfTest.java | 5 + ...DiscoveryS3IpFinderSSEAlgorithmSelfTest.java | 7 +- .../s3/client/DummyObjectListingTest.java | 5 + .../ipfinder/s3/client/DummyS3ClientTest.java | 8 + .../ignite/testsuites/IgniteElbTestSuite.java | 6 +- .../ignite/testsuites/IgniteS3TestSuite.java | 32 +- .../stream/camel/IgniteCamelStreamerTest.java | 10 + .../camel/IgniteCamelStreamerTestSuite.java | 11 +- .../store/cassandra/common/CassandraHelper.java | 4 + .../ignite/tests/CassandraConfigTest.java | 5 + .../internal/TaskEventSubjectIdSelfTest.java | 9 + .../ClientAbstractMultiThreadedSelfTest.java | 7 +- .../client/ClientDefaultCacheSelfTest.java | 5 + .../client/ClientReconnectionSelfTest.java | 12 +- .../client/ClientSslParametersTest.java | 338 ++++ .../ClientTcpSslAuthenticationSelfTest.java | 10 +- ...skExecutionAfterTopologyRestartSelfTest.java | 7 +- .../client/impl/ClientCacheFlagsCodecTest.java | 6 + .../client/impl/ClientComputeImplSelfTest.java | 18 +- .../client/impl/ClientDataImplSelfTest.java | 23 +- .../impl/ClientFutureAdapterSelfTest.java | 8 +- .../ClientPropertiesConfigurationSelfTest.java | 8 +- .../ClientAbstractConnectivitySelfTest.java | 12 +- .../ClientAbstractMultiNodeSelfTest.java | 7 + .../integration/ClientAbstractSelfTest.java | 11 + .../integration/ClientPreferDirectSelfTest.java | 8 +- .../client/router/ClientFailedInitSelfTest.java | 10 +- .../client/router/RouterFactorySelfTest.java | 7 +- .../router/TcpRouterAbstractSelfTest.java | 7 +- .../client/suite/IgniteClientTestSuite.java | 107 +- .../client/util/ClientByteUtilsTest.java | 10 +- .../util/ClientConsistentHashSelfTest.java | 10 +- .../client/util/ClientJavaHasherSelfTest.java | 7 +- .../ignite/internal/jdbc2/JdbcBlobTest.java | 15 +- .../internal/jdbc2/JdbcBulkLoadSelfTest.java | 5 + .../jdbc2/JdbcComplexQuerySelfTest.java | 9 + .../jdbc2/JdbcConnectionReopenTest.java | 5 + .../internal/jdbc2/JdbcConnectionSelfTest.java | 15 + .../jdbc2/JdbcDeleteStatementSelfTest.java | 7 + .../jdbc2/JdbcDistributedJoinsQueryTest.java | 9 + .../jdbc2/JdbcDynamicIndexAbstractSelfTest.java | 11 + .../internal/jdbc2/JdbcEmptyCacheSelfTest.java | 6 + .../internal/jdbc2/JdbcErrorsSelfTest.java | 6 + .../jdbc2/JdbcInsertStatementSelfTest.java | 12 + .../internal/jdbc2/JdbcLocalCachesSelfTest.java | 7 + .../jdbc2/JdbcMergeStatementSelfTest.java | 7 + .../internal/jdbc2/JdbcMetadataSelfTest.java | 15 + .../jdbc2/JdbcNoCacheStreamingSelfTest.java | 6 + .../internal/jdbc2/JdbcNoDefaultCacheTest.java | 6 + .../jdbc2/JdbcPreparedStatementSelfTest.java | 20 + .../internal/jdbc2/JdbcResultSetSelfTest.java | 27 + .../internal/jdbc2/JdbcSpringSelfTest.java | 6 + .../jdbc2/JdbcStatementBatchingSelfTest.java | 8 + .../internal/jdbc2/JdbcStatementSelfTest.java | 10 + .../internal/jdbc2/JdbcStreamingSelfTest.java | 8 + .../jdbc2/JdbcStreamingToPublicCacheTest.java | 5 + .../jdbc2/JdbcUpdateStatementSelfTest.java | 7 + .../rest/ChangeStateCommandHandlerTest.java | 5 + .../rest/ClientMemcachedProtocolSelfTest.java | 23 + .../JettyRestProcessorAbstractSelfTest.java | 64 + ...RestProcessorAuthenticationAbstractTest.java | 6 + ...rocessorAuthenticationWithTokenSelfTest.java | 5 + .../JettyRestProcessorBaselineSelfTest.java | 221 +++ .../JettyRestProcessorGetAllAsArrayTest.java | 5 + .../rest/JettyRestProcessorSignedSelfTest.java | 5 + .../rest/RestBinaryProtocolSelfTest.java | 21 +- .../rest/RestMemcacheProtocolSelfTest.java | 19 +- .../rest/RestProcessorMultiStartSelfTest.java | 6 + .../rest/RestProcessorStartSelfTest.java | 7 +- .../rest/TaskCommandHandlerSelfTest.java | 7 +- .../rest/TcpRestUnmarshalVulnerabilityTest.java | 12 +- .../protocols/tcp/TcpRestParserSelfTest.java | 12 +- .../tcp/redis/RedisProtocolConnectSelfTest.java | 7 + .../tcp/redis/RedisProtocolServerSelfTest.java | 7 + ...tocolStringAtomicDatastructuresSelfTest.java | 5 + .../tcp/redis/RedisProtocolStringSelfTest.java | 19 + .../ignite/jdbc/JdbcComplexQuerySelfTest.java | 11 +- .../ignite/jdbc/JdbcConnectionSelfTest.java | 14 +- .../ignite/jdbc/JdbcEmptyCacheSelfTest.java | 8 +- .../ignite/jdbc/JdbcErrorsAbstractSelfTest.java | 36 + .../ignite/jdbc/JdbcLocalCachesSelfTest.java | 8 +- .../ignite/jdbc/JdbcMetadataSelfTest.java | 9 + .../ignite/jdbc/JdbcNoDefaultCacheTest.java | 6 + .../jdbc/JdbcPojoLegacyQuerySelfTest.java | 5 + .../ignite/jdbc/JdbcPojoQuerySelfTest.java | 6 + .../jdbc/JdbcPreparedStatementSelfTest.java | 21 +- .../ignite/jdbc/JdbcResultSetSelfTest.java | 23 +- .../ignite/jdbc/JdbcStatementSelfTest.java | 9 +- .../jdbc/JdbcVersionMismatchSelfTest.java | 5 + .../suite/IgniteJdbcDriverMvccTestSuite.java | 17 +- .../jdbc/suite/IgniteJdbcDriverTestSuite.java | 199 +-- .../JdbcThinAuthenticateConnectionSelfTest.java | 11 +- .../thin/JdbcThinAutoCloseServerCursorTest.java | 8 + .../ignite/jdbc/thin/JdbcThinBatchSelfTest.java | 25 + .../thin/JdbcThinBulkLoadAbstractSelfTest.java | 35 + ...bcThinComplexDmlDdlCustomSchemaSelfTest.java | 8 +- .../thin/JdbcThinComplexDmlDdlSelfTest.java | 7 +- .../jdbc/thin/JdbcThinComplexQuerySelfTest.java | 11 +- ...JdbcThinConnectionMultipleAddressesTest.java | 19 +- .../JdbcThinConnectionMvccEnabledSelfTest.java | 13 +- .../jdbc/thin/JdbcThinConnectionSSLTest.java | 17 +- .../jdbc/thin/JdbcThinConnectionSelfTest.java | 58 + .../jdbc/thin/JdbcThinDataSourceSelfTest.java | 12 +- .../thin/JdbcThinDeleteStatementSelfTest.java | 6 + .../JdbcThinDynamicIndexAbstractSelfTest.java | 11 + .../jdbc/thin/JdbcThinEmptyCacheSelfTest.java | 8 +- .../jdbc/thin/JdbcThinErrorsSelfTest.java | 9 + .../thin/JdbcThinInsertStatementSelfTest.java | 9 + .../jdbc/thin/JdbcThinLocalQueriesSelfTest.java | 5 + .../thin/JdbcThinMergeStatementSelfTest.java | 6 + .../JdbcThinMetadataPrimaryKeysSelfTest.java | 8 + .../jdbc/thin/JdbcThinMetadataSelfTest.java | 24 +- .../JdbcThinMissingLongArrayResultsTest.java | 5 + .../jdbc/thin/JdbcThinNoDefaultSchemaTest.java | 9 + .../thin/JdbcThinPreparedStatementSelfTest.java | 23 +- .../jdbc/thin/JdbcThinResultSetSelfTest.java | 26 +- .../jdbc/thin/JdbcThinSchemaCaseTest.java | 5 + .../thin/JdbcThinSelectAfterAlterTable.java | 8 +- .../jdbc/thin/JdbcThinStatementSelfTest.java | 38 +- .../thin/JdbcThinStreamingAbstractSelfTest.java | 17 +- .../ignite/jdbc/thin/JdbcThinTcpIoTest.java | 6 + ...ThinTransactionsAbstractComplexSelfTest.java | 34 + .../jdbc/thin/JdbcThinTransactionsSelfTest.java | 22 + ...ThinTransactionsWithMvccEnabledSelfTest.java | 21 + .../thin/JdbcThinUpdateStatementSelfTest.java | 6 + ...ctionFinishOnDeactivatedClusterSelfTest.java | 6 + .../client/ClientMarshallerBenchmarkTest.java | 7 +- .../loadtests/client/ClientTcpSslLoadTest.java | 7 +- .../TcpDiscoveryCloudIpFinderSelfTest.java | 19 +- .../ignite/testsuites/IgniteCloudTestSuite.java | 10 +- .../PdsWithTtlCompatibilityTest.java | 5 + .../FoldersReuseCompatibilityTest.java | 6 + .../IgnitePKIndexesMigrationToUnwrapPkTest.java | 6 + ...tingToWalV2SerializerWithCompactionTest.java | 5 + .../PersistenceBasicCompatibilityTest.java | 10 + .../junits/IgniteCompatibilityNodeRunner.java | 7 +- .../IgniteCompatibilityBasicTestSuite.java | 12 +- .../compress/CompressionConfigurationTest.java | 109 ++ .../compress/CompressionProcessorTest.java | 64 + .../DiskPageCompressionIntegrationTest.java | 12 + .../compress/FileSystemUtilsTest.java | 5 + .../IgnitePdsCompressionTestSuite.java | 13 +- .../IgnitePdsCompressionTestSuite2.java | 2 +- .../apache/ignite/IgniteJdbcThinDataSource.java | 1 - .../java/org/apache/ignite/IgniteQueue.java | 8 + .../org/apache/ignite/cache/CacheManager.java | 1 - .../ignite/cache/affinity/AffinityKey.java | 1 - .../cache/eviction/fifo/FifoEvictionPolicy.java | 1 - .../cache/eviction/lru/LruEvictionPolicy.java | 1 - .../eviction/sorted/SortedEvictionPolicy.java | 4 - .../ignite/compute/ComputeJobAdapter.java | 1 - .../configuration/CacheConfiguration.java | 4 - .../org/apache/ignite/events/CacheEvent.java | 1 - .../local/LocalIgfsSecondaryFileSystem.java | 1 - .../ignite/internal/AsyncSupportAdapter.java | 2 - .../ignite/internal/GridJobContextImpl.java | 1 - .../ignite/internal/GridKernalContext.java | 6 + .../ignite/internal/GridKernalContextImpl.java | 25 +- .../ignite/internal/GridTaskSessionImpl.java | 3 - .../ignite/internal/IgniteComponentType.java | 2 - .../ignite/internal/IgniteComputeImpl.java | 3 - .../ignite/internal/IgniteEventsImpl.java | 1 - .../apache/ignite/internal/IgniteKernal.java | 13 +- .../ignite/internal/IgniteServicesImpl.java | 1 - .../org/apache/ignite/internal/IgnitionEx.java | 1 - .../ignite/internal/MarshallerContextImpl.java | 8 +- .../java/org/apache/ignite/internal/README.md | 5 +- .../ignite/internal/binary/BinaryEnumCache.java | 1 - .../internal/binary/BinaryEnumObjectImpl.java | 1 - .../ignite/internal/binary/BinaryFieldImpl.java | 1 - .../internal/binary/BinaryObjectExImpl.java | 1 - .../internal/binary/BinaryObjectImpl.java | 7 - .../binary/BinaryObjectOffheapImpl.java | 6 - .../internal/binary/BinaryReaderExImpl.java | 3 - .../internal/binary/BinaryReaderHandles.java | 1 - .../ignite/internal/binary/BinaryTreeMap.java | 1 - .../ignite/internal/binary/BinaryUtils.java | 3 - .../internal/binary/BinaryWriterExImpl.java | 3 - .../internal/binary/BinaryWriterHandles.java | 1 - .../internal/binary/GridBinaryMarshaller.java | 3 - .../binary/builder/BinaryObjectBuilderImpl.java | 1 - .../client/impl/GridClientDataImpl.java | 1 - .../client/impl/GridClientNodeImpl.java | 1 - .../marshaller/jdk/GridClientJdkMarshaller.java | 1 - .../client/ssl/GridSslBasicContextFactory.java | 88 +- .../internal/client/thin/ClientBinary.java | 1 - .../internal/client/thin/ClientUtils.java | 1 - .../internal/client/thin/TcpClientCache.java | 1 - .../client/util/GridConcurrentHashSet.java | 2 - .../ignite/internal/commandline/Arguments.java | 38 +- .../internal/commandline/CommandHandler.java | 299 ++-- .../direct/state/DirectMessageState.java | 2 - .../stream/v1/DirectByteBufferStreamImplV1.java | 6 - .../stream/v2/DirectByteBufferStreamImplV2.java | 7 - .../igfs/common/IgfsControlResponse.java | 1 - .../ignite/internal/jdbc/JdbcResultSet.java | 1 - .../internal/jdbc/thin/JdbcThinConnection.java | 2 - .../jdbc/thin/JdbcThinDatabaseMetadata.java | 1 - .../jdbc/thin/JdbcThinParameterMetadata.java | 1 - .../jdbc/thin/JdbcThinPreparedStatement.java | 1 - .../internal/jdbc/thin/JdbcThinResultSet.java | 2 - .../internal/jdbc/thin/JdbcThinStatement.java | 1 - .../ignite/internal/jdbc2/JdbcConnection.java | 1 - .../internal/jdbc2/JdbcDatabaseMetadata.java | 1 - .../ignite/internal/jdbc2/JdbcResultSet.java | 2 - .../internal/jdbc2/JdbcResultSetMetadata.java | 1 - .../ignite/internal/jdbc2/JdbcStatement.java | 1 - .../managers/communication/GridIoManager.java | 16 +- .../managers/deployment/GridDeployment.java | 3 - .../deployment/GridDeploymentLocalStore.java | 1 - .../eventstorage/GridEventStorageManager.java | 4 - .../optimized/OptimizedMarshaller.java | 2 - .../optimized/OptimizedObjectInputStream.java | 4 - .../ignite/internal/pagemem/PageSupport.java | 14 + .../pagemem/impl/PageMemoryNoStoreImpl.java | 19 +- .../pagemem/wal/IgniteWriteAheadLogManager.java | 16 + .../internal/pagemem/wal/WALIterator.java | 6 +- .../internal/pagemem/wal/record/DataRecord.java | 5 +- .../pagemem/wal/record/MvccTxRecord.java | 8 +- .../internal/pagemem/wal/record/WALRecord.java | 167 +- .../delta/MetaPageUpdateNextSnapshotId.java | 10 +- .../apache/ignite/internal/processors/README.md | 6 +- .../affinity/GridAffinityProcessor.java | 1 - .../IgniteAuthenticationProcessor.java | 2 - .../processors/cache/CacheEntryImpl.java | 1 - .../processors/cache/CacheEntryImpl0.java | 1 - .../cache/CacheEvictableEntryImpl.java | 2 - .../processors/cache/CacheGroupContext.java | 54 +- .../processors/cache/CacheInvokeEntry.java | 1 - .../processors/cache/CacheInvokeResult.java | 1 - .../processors/cache/CacheLazyEntry.java | 2 - .../processors/cache/CacheObjectContext.java | 35 +- .../processors/cache/CacheObjectImpl.java | 1 - .../processors/cache/CacheObjectUtils.java | 1 - .../CachePartialUpdateCheckedException.java | 1 - .../processors/cache/ClusterCachesInfo.java | 10 +- .../processors/cache/GridCacheAdapter.java | 7 +- .../cache/GridCacheAffinityManager.java | 6 +- .../processors/cache/GridCacheContext.java | 54 +- .../processors/cache/GridCacheContextInfo.java | 89 +- .../cache/GridCacheEvictionManager.java | 1 - .../processors/cache/GridCacheIoManager.java | 72 +- .../processors/cache/GridCacheMapEntry.java | 18 +- .../processors/cache/GridCacheMvccManager.java | 29 +- .../GridCachePartitionExchangeManager.java | 2 +- .../processors/cache/GridCacheProcessor.java | 55 +- .../processors/cache/GridCacheProxyImpl.java | 2 - .../processors/cache/GridCacheReturn.java | 3 - .../processors/cache/GridCacheUtilityKey.java | 1 - .../processors/cache/GridCacheUtils.java | 6 - .../cache/IgniteCacheOffheapManagerImpl.java | 150 +- .../processors/cache/IgniteCacheProxy.java | 2 - .../processors/cache/IgniteCacheProxyImpl.java | 3 - .../processors/cache/KeyCacheObjectImpl.java | 1 - .../ignite/internal/processors/cache/README.md | 9 +- .../cache/affinity/GridCacheAffinityProxy.java | 1 - .../cache/binary/CacheObjectBinaryContext.java | 62 - .../binary/CacheObjectBinaryProcessor.java | 149 -- .../binary/CacheObjectBinaryProcessorImpl.java | 310 +++- .../cache/binary/IgniteBinaryImpl.java | 5 +- .../CacheDataStructuresManager.java | 4 - .../dht/CacheDistributedGetFutureAdapter.java | 1 - .../distributed/dht/GridDhtCacheAdapter.java | 2 +- .../distributed/dht/GridDhtCacheEntry.java | 4 +- .../distributed/dht/GridDhtLockFuture.java | 2 - .../dht/GridDhtTxAbstractEnlistFuture.java | 2 - .../distributed/dht/GridDhtTxFinishFuture.java | 3 - .../cache/distributed/dht/GridDhtTxLocal.java | 2 - .../distributed/dht/GridDhtTxPrepareFuture.java | 1 - .../dht/GridDhtTxQueryEnlistResponse.java | 2 +- .../dht/NearTxQueryEnlistResultHandler.java | 1 - .../distributed/dht/NearTxResultHandler.java | 1 - .../dht/atomic/GridDhtAtomicCache.java | 55 +- .../atomic/GridNearAtomicFullUpdateRequest.java | 2 - .../GridNearAtomicSingleUpdateFuture.java | 1 - .../dht/atomic/GridNearAtomicUpdateFuture.java | 5 - .../dht/colocated/GridDhtColocatedCache.java | 1 - .../colocated/GridDhtColocatedLockFuture.java | 13 +- .../dht/preloader/GridDhtForceKeysFuture.java | 2 - .../dht/preloader/GridDhtPartitionSupplier.java | 1 - .../GridDhtPartitionsSingleMessage.java | 1 - .../topology/GridClientPartitionTopology.java | 2 - .../topology/GridDhtPartitionTopologyImpl.java | 2 - .../distributed/near/GridNearAtomicCache.java | 4 - .../distributed/near/GridNearGetFuture.java | 1 - .../distributed/near/GridNearLockFuture.java | 13 +- .../near/GridNearTxAbstractEnlistFuture.java | 13 +- .../near/GridNearTxFinishFuture.java | 2 - .../cache/distributed/near/GridNearTxLocal.java | 3 - .../near/TxTopologyVersionFuture.java | 13 +- .../local/atomic/GridLocalAtomicCache.java | 8 - .../cache/mvcc/MvccProcessorImpl.java | 2 - .../cache/persistence/CacheDataRowAdapter.java | 7 +- .../cache/persistence/DataStructure.java | 45 +- .../GridCacheDatabaseSharedManager.java | 322 ++-- .../persistence/GridCacheOffheapManager.java | 29 +- .../processors/cache/persistence/README.md | 2 +- .../processors/cache/persistence/RowStore.java | 24 +- .../persistence/freelist/AbstractFreeList.java | 51 +- .../persistence/freelist/CacheFreeListImpl.java | 5 +- .../cache/persistence/freelist/FreeList.java | 10 +- .../cache/persistence/freelist/PagesList.java | 100 +- .../metastorage/MetastorageRowStore.java | 7 +- .../cache/persistence/pagemem/PageMemoryEx.java | 6 +- .../persistence/pagemem/PageMemoryImpl.java | 25 +- .../cache/persistence/tree/BPlusTree.java | 112 +- .../cache/persistence/tree/io/PageIO.java | 54 +- .../persistence/tree/reuse/ReuseListImpl.java | 5 +- .../persistence/tree/util/PageHandler.java | 43 +- .../wal/AbstractWalRecordsIterator.java | 11 + .../wal/FileWriteAheadLogManager.java | 25 +- .../wal/reader/IgniteWalIteratorFactory.java | 26 +- .../wal/reader/StandaloneGridKernalContext.java | 5 + .../reader/StandaloneWalRecordsIterator.java | 16 +- .../serializer/RecordSerializerFactoryImpl.java | 7 +- .../wal/serializer/RecordV1Serializer.java | 3 +- .../wal/serializer/RecordV2Serializer.java | 3 +- .../query/GridCacheDistributedQueryFuture.java | 3 - .../query/GridCacheDistributedQueryManager.java | 4 - .../cache/query/GridCacheQueryAdapter.java | 30 +- .../query/GridCacheQueryFutureAdapter.java | 3 - .../cache/query/GridCacheQueryManager.java | 2 +- .../cache/query/GridCacheQueryResponse.java | 1 - .../query/GridCacheQueryResponseEntry.java | 1 - .../CacheContinuousQueryEventBuffer.java | 1 - .../continuous/CacheContinuousQueryHandler.java | 1 - .../CacheContinuousQueryHandlerV3.java | 2 - .../continuous/CacheContinuousQueryManager.java | 2 - .../cache/store/GridCacheWriteBehindStore.java | 1 - .../cache/transactions/IgniteTxAdapter.java | 2 +- .../transactions/IgniteTxLocalAdapter.java | 1 - .../cache/transactions/IgniteTxManager.java | 7 - .../cache/transactions/TxDeadlockDetection.java | 1 - .../processors/cache/tree/CacheDataTree.java | 6 + .../cache/verify/IdleVerifyResultV2.java | 34 +- .../verify/VerifyBackupPartitionsDumpTask.java | 28 + .../verify/VerifyBackupPartitionsTaskV2.java | 31 +- .../GridCacheLazyPlainVersionedEntry.java | 1 - .../cacheobject/IgniteCacheObjectProcessor.java | 119 +- .../IgniteCacheObjectProcessorImpl.java | 346 ---- .../cacheobject/UserKeyCacheObjectImpl.java | 2 +- .../processors/cluster/ClusterProcessor.java | 1 - .../continuous/GridContinuousMessage.java | 1 - .../continuous/GridContinuousProcessor.java | 3 - .../processors/continuous/StartRequestData.java | 1 - .../datastreamer/DataStreamerImpl.java | 1 - .../datastructures/DataStructuresProcessor.java | 4 - .../GridCacheAtomicReferenceValue.java | 1 - .../GridCacheAtomicStampedValue.java | 1 - .../GridCacheCountDownLatchImpl.java | 1 - .../datastructures/GridCacheQueueAdapter.java | 34 +- .../datastructures/GridCacheQueueProxy.java | 12 + .../igfs/IgfsAbstractOutputStream.java | 1 - .../processors/igfs/IgfsDataManager.java | 1 - .../internal/processors/igfs/IgfsImpl.java | 4 - .../processors/igfs/IgfsInputStreamImpl.java | 1 - ...ClientListenerAbstractConnectionContext.java | 6 + .../odbc/jdbc/JdbcConnectionContext.java | 2 + .../odbc/odbc/OdbcConnectionContext.java | 2 + .../client/ClientConnectionContext.java | 2 + .../platform/client/ClientResourceRegistry.java | 1 - .../dotnet/PlatformDotNetCacheStore.java | 1 - .../PlatformDotNetConfigurationClosure.java | 1 - .../platform/events/PlatformEvents.java | 10 +- .../platform/utils/PlatformUtils.java | 1 - .../processors/plugin/CachePluginManager.java | 3 +- .../plugin/IgnitePluginProcessor.java | 2 - .../query/GridQueryCacheObjectsIterator.java | 1 - .../processors/query/GridQueryProcessor.java | 18 +- .../query/GridQueryTypeDescriptor.java | 5 + .../processors/query/QueryKeyValueIterator.java | 1 - .../query/QueryTypeDescriptorImpl.java | 26 +- .../internal/processors/query/QueryUtils.java | 35 +- .../query/property/QueryBinaryProperty.java | 1 - .../processors/rest/GridRestCommand.java | 12 + .../processors/rest/GridRestProcessor.java | 9 + .../message/GridClientTaskResultBean.java | 1 - .../cluster/GridBaselineCommandHandler.java | 205 +++ .../cluster/GridBaselineCommandResponse.java | 161 ++ .../rest/request/GridRestBaselineRequest.java | 65 + .../service/GridServiceProcessor.java | 6 - .../processors/service/GridServiceProxy.java | 1 - .../processors/service/ServiceContextImpl.java | 1 - .../service/ServiceDescriptorImpl.java | 1 - .../processors/task/GridTaskProcessor.java | 3 - .../processors/task/GridTaskWorker.java | 3 - .../ignite/internal/stat/IndexPageType.java | 33 + .../internal/stat/IoStatisticsHolder.java | 66 + .../internal/stat/IoStatisticsHolderCache.java | 121 ++ .../internal/stat/IoStatisticsHolderIndex.java | 168 ++ .../internal/stat/IoStatisticsHolderKey.java | 91 + .../internal/stat/IoStatisticsHolderNoOp.java | 70 + .../internal/stat/IoStatisticsHolderQuery.java | 128 ++ .../internal/stat/IoStatisticsManager.java | 204 +++ .../IoStatisticsMetricsLocalMXBeanImpl.java | 146 ++ .../internal/stat/IoStatisticsQueryHelper.java | 98 ++ .../ignite/internal/stat/IoStatisticsType.java | 36 + .../apache/ignite/internal/util/GridArrays.java | 1 - .../internal/util/GridBoundedLinkedHashMap.java | 1 - .../internal/util/GridBoundedLinkedHashSet.java | 1 - .../util/GridConcurrentSkipListSet.java | 2 +- .../ignite/internal/util/GridLeanMap.java | 2 +- .../ignite/internal/util/GridLeanSet.java | 1 - .../ignite/internal/util/GridListSet.java | 3 - .../ignite/internal/util/GridSetWrapper.java | 2 - .../ignite/internal/util/IgniteUtils.java | 12 - .../util/StripedCompositeReadWriteLock.java | 1 - .../util/future/GridCompoundFuture.java | 3 - .../util/future/GridFinishedFuture.java | 2 - .../internal/util/future/GridFutureAdapter.java | 2 - .../internal/util/future/IgniteFutureImpl.java | 1 - .../ignite/internal/util/lang/GridFunc.java | 11 - .../util/lang/GridMetadataAwareAdapter.java | 7 - .../ignite/internal/util/lang/GridTuple.java | 1 - .../ignite/internal/util/lang/GridTuple3.java | 1 - .../ignite/internal/util/lang/GridTuple4.java | 1 - .../ignite/internal/util/lang/GridTuple5.java | 1 - .../ignite/internal/util/lang/GridTuple6.java | 1 - .../util/lang/gridfunc/PredicateMapView.java | 4 - .../util/lang/gridfunc/TransformMapView.java | 4 - .../util/lang/gridfunc/TransformMapView2.java | 4 - .../ignite/internal/util/nio/GridNioServer.java | 5 - .../apache/ignite/internal/util/typedef/X.java | 3 - .../org/apache/ignite/lang/IgniteBiTuple.java | 1 - .../apache/ignite/logger/java/JavaLogger.java | 1 - .../ignite/marshaller/jdk/JdkMarshaller.java | 1 - .../mxbean/IoStatisticsMetricsMXBean.java | 172 ++ .../ignite/spi/discovery/tcp/ClientImpl.java | 1 - .../ignite/spi/discovery/tcp/ServerImpl.java | 9 +- .../spi/discovery/tcp/TcpDiscoverySpi.java | 6 +- .../tcp/internal/TcpDiscoveryNode.java | 1 - .../TcpDiscoveryMulticastIpFinder.java | 1 - .../apache/ignite/ssl/SSLContextWrapper.java | 13 +- .../apache/ignite/ssl/SslContextFactory.java | 16 +- .../org/jsr166/ConcurrentLinkedHashMap.java | 12 +- .../java/org/apache/ignite/GridTestIoUtils.java | 3 - .../org/apache/ignite/GridTestJobContext.java | 1 - .../org/apache/ignite/GridTestTaskSession.java | 1 - .../ignite/cache/ResetLostPartitionTest.java | 6 +- ...ndezvousAffinityFunctionSimpleBenchmark.java | 1 - .../apache/ignite/client/SslParametersTest.java | 144 +- .../ignite/internal/ClusterGroupSelfTest.java | 1 - ...ventStorageRuntimeConfigurationSelfTest.java | 1 - .../GridMultipleVersionsDeploymentSelfTest.java | 2 - .../apache/ignite/internal/GridSelfTest.java | 1 - ...entConnectAfterCommunicationFailureTest.java | 4 + .../IgniteClientReconnectApiExceptionTest.java | 2 - ...gniteExplicitImplicitDeploymentSelfTest.java | 4 - .../binary/BinaryMarshallerSelfTest.java | 2 +- .../BinaryObjectTypeCompatibilityTest.java | 1 - ...ByteBufferStreamImplV2ByteOrderSelfTest.java | 1 - .../GridDeploymentMessageCountSelfTest.java | 53 +- .../GridAffinityProcessorAbstractSelfTest.java | 1 - .../cache/CacheConcurrentReadThroughTest.java | 1 - ...erceptorPartitionCounterLocalSanityTest.java | 2 +- ...torPartitionCounterRandomOperationsTest.java | 5 +- .../cache/CacheMetricsManageTest.java | 1 - .../cache/GridCacheAbstractFullApiSelfTest.java | 12 +- .../cache/GridCacheAbstractMetricsSelfTest.java | 1 - .../GridCacheConcurrentTxMultiNodeLoadTest.java | 2 +- .../cache/GridCacheDeploymentSelfTest.java | 2 - .../GridCacheInterceptorAbstractSelfTest.java | 6 - .../processors/cache/GridCacheMvccSelfTest.java | 1 - .../cache/GridCachePutAllFailoverSelfTest.java | 1 - .../cache/GridCacheSwapPreloadSelfTest.java | 253 --- .../IgniteCacheEntryListenerAbstractTest.java | 1 - .../cache/IgniteCacheInvokeAbstractTest.java | 1 - .../cache/IgniteCacheMvccTxInvokeTest.java | 6 +- ...IgniteClientCacheInitializationFailTest.java | 2 +- .../IgniteClusterActivateDeactivateTest.java | 9 +- ...erActivateDeactivateTestWithPersistence.java | 14 +- .../cache/IgnitePdsDataRegionMetricsTxTest.java | 56 + .../IgniteTxExceptionAbstractSelfTest.java | 1 - .../cache/WithKeepBinaryCacheFullApiTest.java | 2 - .../GridCacheQueueApiSelfAbstractTest.java | 197 ++- .../distributed/CacheExchangeMergeTest.java | 2 +- .../CacheLateAffinityAssignmentTest.java | 6 +- .../IgniteCacheAtomicNodeRestartTest.java | 7 - .../IgniteCachePartitionLossPolicySelfTest.java | 24 +- .../IgniteTxCachePrimarySyncTest.java | 1 - ...GridCacheDhtEvictionNearReadersSelfTest.java | 1 - ...gniteCachePutRetryTransactionalSelfTest.java | 1 - .../near/GridCacheNearMultiNodeSelfTest.java | 2 +- ...idCacheNearOnlyMultiNodeFullApiSelfTest.java | 1 - .../near/GridCacheNearTxMultiNodeSelfTest.java | 1 - ...achePartitionedMultiNodeCounterSelfTest.java | 2 +- ...balanceOnCachesStoppingOrDestroyingTest.java | 14 +- .../cache/eviction/EvictionAbstractTest.java | 2 - .../EvictionPolicyFactoryAbstractTest.java | 4 - .../GridCacheLocalTxMultiThreadedSelfTest.java | 1 - ...plicatedNearOnlyMultiJvmFullApiSelfTest.java | 8 - .../cache/mvcc/CacheMvccClusterRestartTest.java | 2 - .../cache/mvcc/CacheMvccTransactionsTest.java | 2 - ...PdsCacheStartStopWithFreqCheckpointTest.java | 2 + .../IgnitePdsContinuousRestartTest.java | 47 +- ...dsContinuousRestartTestWithExpiryPolicy.java | 8 + .../IgnitePdsPartitionFilesDestroyTest.java | 19 +- .../IgnitePdsPartitionsStateRecoveryTest.java | 21 +- ...gnitePdsRecoveryAfterFileCorruptionTest.java | 3 + ...teRebalanceScheduleResendPartitionsTest.java | 9 +- ...hangeDuringRebalanceOnNonNodeAssignTest.java | 175 -- ...lWalModeChangeDuringRebalancingSelfTest.java | 29 +- ...hangeDuringRebalanceOnNonNodeAssignTest.java | 211 +++ ...lientAffinityAssignmentWithBaselineTest.java | 9 +- .../db/IgniteLogicalRecoveryTest.java | 67 +- .../db/IgnitePdsDataRegionMetricsTest.java | 18 +- ...PdsPageEvictionDuringPartitionClearTest.java | 4 + .../db/IgnitePdsPartitionPreloadTest.java | 182 ++ ...tePdsRebalancingOnNotStableTopologyTest.java | 13 +- .../db/IgnitePdsTransactionsHangTest.java | 14 +- .../db/IgnitePdsWholeClusterRestartTest.java | 14 +- .../persistence/db/IgnitePdsWithTtlTest.java | 3 + ...SlowHistoricalRebalanceSmallHistoryTest.java | 9 +- .../db/file/IgnitePdsCheckpointSimpleTest.java | 2 +- ...ckpointSimulationWithRealCpDisabledTest.java | 87 +- .../IgniteNodeStoppedDuringDisableWALTest.java | 7 +- ...lFlushMultiNodeFailoverAbstractSelfTest.java | 6 +- .../wal/IgniteWalHistoryReservationsTest.java | 14 + .../wal/IgniteWalIteratorSwitchSegmentTest.java | 4 +- .../db/wal/WalDeletionArchiveAbstractTest.java | 20 +- .../db/wal/reader/IgniteWalReaderTest.java | 169 +- .../persistence/pagemem/NoOpWALManager.java | 7 + .../IgniteChangeGlobalStateTest.java | 2 +- .../wal/AbstractWalDeltaConsistencyTest.java | 17 + .../wal/CpTriggeredWalDeltaConsistencyTest.java | 24 +- .../wal/ExplicitWalDeltaConsistencyTest.java | 33 +- .../wal/SysPropWalDeltaConsistencyTest.java | 24 +- .../PageMemoryTrackerPluginProvider.java | 2 - .../continuous/CacheContinuousBatchAckTest.java | 1 - ...eContinuousQueryAsyncFilterListenerTest.java | 4 +- ...CacheContinuousQueryCounterAbstractTest.java | 1 - .../CacheContinuousQueryEventBufferTest.java | 1 - ...usQueryFactoryFilterRandomOperationTest.java | 2 +- .../CacheContinuousQueryLostPartitionTest.java | 1 - .../CacheContinuousQueryOrderingEventTest.java | 3 +- ...acheContinuousQueryRandomOperationsTest.java | 2 +- ...eEntryProcessorExternalizableFailedTest.java | 15 +- .../CacheEntryProcessorNonSerializableTest.java | 7 + .../AbstractDeadlockDetectionTest.java | 1 - ...IntegrityWithPrimaryIndexCorruptionTest.java | 5 +- .../cache/transactions/TxDeadlockCauseTest.java | 1 - .../TxDeadlockDetectionUnmasrhalErrorsTest.java | 1 - ...simisticDeadlockDetectionCrossCacheTest.java | 1 - .../closure/GridClosureProcessorSelfTest.java | 1 - .../database/CacheFreeListImplSelfTest.java | 13 +- .../database/IgniteDbPutGetAbstractTest.java | 6 +- .../IgniteDbPutGetWithCacheStoreTest.java | 8 + .../igfs/IgfsAbstractBaseSelfTest.java | 1 - .../IoStatisticsCachePersistenceSelfTest.java | 30 + .../stat/IoStatisticsCacheSelfTest.java | 262 +++ .../stat/IoStatisticsManagerSelfTest.java | 154 ++ ...tatisticsMetricsLocalMXBeanImplSelfTest.java | 224 +++ .../IpcSharedMemoryCrashDetectionSelfTest.java | 2 +- .../apache/ignite/lang/IgniteUuidSelfTest.java | 1 - .../loadtests/GridLoadTestStatistics.java | 1 - .../loadtests/GridSingleExecutionTest.java | 1 - .../cache/GridCacheAbstractLoadTest.java | 2 - .../GridSingleSplitsRedeployLoadTest.java | 1 - .../ignite/loadtests/dsi/GridDsiClient.java | 2 +- .../ignite/loadtests/dsi/GridDsiPerfJob.java | 1 - .../loadtests/hashmap/GridCacheTestContext.java | 3 + .../marshaller/GridMarshallerAbstractTest.java | 1 - .../ignite/messaging/GridMessagingSelfTest.java | 1 - .../p2p/GridAbstractMultinodeRedeployTest.java | 1 - .../p2p/GridP2PDoubleDeploymentSelfTest.java | 1 - .../p2p/GridP2PRemoteClassLoadersSelfTest.java | 1 - .../ignite/p2p/GridP2PTimeoutSelfTest.java | 1 - .../ignite/p2p/GridP2PUndeploySelfTest.java | 2 - .../collision/GridTestCollisionTaskSession.java | 1 - .../GridPriorityQueueCollisionSpiSelfTest.java | 3 +- ...dTcpCommunicationSpiRecoveryAckSelfTest.java | 2 - ...GridTcpCommunicationSpiRecoverySelfTest.java | 1 - ...IgniteTcpCommunicationConnectOnInitTest.java | 172 ++ ...CommunicationRecoveryAckClosureSelfTest.java | 2 - .../tcp/TcpClientDiscoverySpiSelfTest.java | 1 - .../tcp/TcpDiscoveryIpFinderCleanerTest.java | 168 ++ .../TcpDiscoveryPendingMessageDeliveryTest.java | 55 + .../always/GridAlwaysFailoverSpiSelfTest.java | 1 - .../GridJobStealingFailoverSpiSelfTest.java | 1 - .../ignite/startup/GridVmNodesStarter.java | 1 - .../testframework/GridSpiTestContext.java | 2 - .../ignite/testframework/GridTestNode.java | 2 +- .../ignite/testframework/GridTestUtils.java | 1 - .../testframework/MvccFeatureChecker.java | 7 +- .../ConfigVariationsTestSuiteBuilder.java | 2 - .../configvariations/Parameters.java | 5 - .../testframework/junits/GridAbstractTest.java | 44 +- ...IgniteCacheConfigVariationsAbstractTest.java | 2 - .../junits/IgniteTestResources.java | 1 - .../junits/cache/TestCacheSession.java | 2 - .../cache/TestThreadLocalCacheSession.java | 2 - .../junits/common/GridCommonAbstractTest.java | 14 +- .../multijvm/IgniteCacheProcessProxy.java | 1 - .../junits/multijvm/IgniteProcessProxy.java | 6 +- .../junits/spi/GridSpiAbstractTest.java | 3 - ...eCacheDataStructuresBinarySelfTestSuite.java | 51 + .../IgniteCacheDataStructuresSelfTestSuite.java | 4 +- .../testsuites/IgniteCacheMvccTestSuite1.java | 2 - .../ignite/testsuites/IgniteCacheTestSuite.java | 4 - .../testsuites/IgnitePdsMvccTestSuite.java | 90 + .../testsuites/IgnitePdsMvccTestSuite2.java | 97 ++ .../testsuites/IgnitePdsMvccTestSuite3.java | 43 + .../testsuites/IgnitePdsMvccTestSuite4.java | 53 + .../ignite/testsuites/IgnitePdsTestSuite.java | 103 +- .../ignite/testsuites/IgnitePdsTestSuite2.java | 127 +- .../ignite/testsuites/IgnitePdsTestSuite3.java | 26 +- .../ignite/testsuites/IgnitePdsTestSuite4.java | 48 +- .../IgniteSpiCommunicationSelfTestSuite.java | 2 + .../IgniteSpiDiscoverySelfTestSuite.java | 2 + .../ignite/util/GridCommandHandlerSslTest.java | 104 +- .../ignite/util/GridCommandHandlerTest.java | 214 ++- ...lWalModeChangeDuringRebalancingSelfTest.java | 6 + .../persistence/file/IgniteFileIOTest.java | 8 + .../IgniteNativeIoWithNoPersistenceTest.java | 5 + .../testsuites/IgnitePdsNativeIoTestSuite.java | 9 +- .../testsuites/IgnitePdsNativeIoTestSuite2.java | 16 +- .../IgnitePdsReplacementNativeIoTest.java | 5 + .../sink/flink/FlinkIgniteSinkSelfTest.java | 8 +- .../flink/FlinkIgniteSinkSelfTestSuite.java | 7 +- .../ignite/stream/flume/IgniteSinkTest.java | 5 + .../stream/flume/IgniteSinkTestSuite.java | 6 +- .../ignite/testsuites/IgniteGCETestSuite.java | 8 +- .../query/h2/H2IndexingAbstractGeoSelfTest.java | 15 +- .../testsuites/GeoSpatialIndexingTestSuite.java | 10 +- .../hadoop/impl/HadoopCommandLineTest.java | 8 +- .../hadoop/impl/HadoopFileSystemsTest.java | 7 +- .../hadoop/impl/HadoopGroupingTest.java | 10 +- .../hadoop/impl/HadoopJobTrackerSelfTest.java | 8 +- .../impl/HadoopMapReduceEmbeddedSelfTest.java | 8 +- .../HadoopMapReduceErrorResilienceTest.java | 12 +- .../hadoop/impl/HadoopMapReduceTest.java | 7 +- .../impl/HadoopNoHadoopMapReduceTest.java | 5 + .../HadoopSerializationWrapperSelfTest.java | 8 +- .../hadoop/impl/HadoopSnappyTest.java | 5 + .../hadoop/impl/HadoopSortingTest.java | 7 +- .../hadoop/impl/HadoopSplitWrapperSelfTest.java | 7 +- .../impl/HadoopTaskExecutionSelfTest.java | 11 +- .../impl/HadoopTasksVersionsAbstractTest.java | 8 + .../hadoop/impl/HadoopTeraSortTest.java | 6 + .../hadoop/impl/HadoopTxConfigCacheTest.java | 9 +- .../hadoop/impl/HadoopUserLibsSelfTest.java | 10 + .../hadoop/impl/HadoopV2JobSelfTest.java | 7 +- .../hadoop/impl/HadoopValidationSelfTest.java | 7 +- .../HadoopWeightedMapReducePlannerTest.java | 7 + ...opClientProtocolMultipleServersSelfTest.java | 9 +- .../client/HadoopClientProtocolSelfTest.java | 7 +- ...KerberosHadoopFileSystemFactorySelfTest.java | 8 +- .../impl/igfs/Hadoop1OverIgfsProxyTest.java | 7 +- .../igfs/HadoopFIleSystemFactorySelfTest.java | 5 + .../HadoopIgfs20FileSystemAbstractSelfTest.java | 62 + .../igfs/HadoopIgfsDualAbstractSelfTest.java | 7 +- ...oopSecondaryFileSystemConfigurationTest.java | 8 +- .../hadoop/impl/igfs/IgfsEventsTestSuite.java | 21 +- .../igfs/IgfsNearOnlyMultiNodeSelfTest.java | 5 + .../IgniteHadoopFileSystemAbstractSelfTest.java | 78 +- ...opFileSystemClientBasedAbstractSelfTest.java | 8 +- ...niteHadoopFileSystemClientBasedOpenTest.java | 7 + .../IgniteHadoopFileSystemClientSelfTest.java | 5 + ...IgniteHadoopFileSystemHandshakeSelfTest.java | 8 +- .../IgniteHadoopFileSystemIpcCacheSelfTest.java | 7 +- .../IgniteHadoopFileSystemLoggerSelfTest.java | 10 +- ...niteHadoopFileSystemLoggerStateSelfTest.java | 14 +- ...teHadoopFileSystemShmemAbstractSelfTest.java | 7 +- ...emShmemExternalToClientAbstractSelfTest.java | 7 +- .../HadoopConcurrentHashMultimapSelftest.java | 8 +- .../collections/HadoopHashMapSelfTest.java | 7 +- .../collections/HadoopSkipListSelfTest.java | 8 +- .../streams/HadoopDataStreamSelfTest.java | 9 +- .../taskexecutor/HadoopExecutorServiceTest.java | 7 +- .../HadoopExternalTaskExecutionSelfTest.java | 8 +- .../HadoopExternalCommunicationSelfTest.java | 8 +- .../impl/util/BasicUserNameMapperSelfTest.java | 7 + .../util/ChainedUserNameMapperSelfTest.java | 7 + .../util/KerberosUserNameMapperSelfTest.java | 8 + .../testsuites/IgniteHadoopTestSuite.java | 135 +- .../IgniteIgfsLinuxAndMacOSTestSuite.java | 25 +- .../HibernateL2CacheConfigurationSelfTest.java | 8 +- .../hibernate/HibernateL2CacheMultiJvmTest.java | 5 + .../hibernate/HibernateL2CacheSelfTest.java | 14 +- .../HibernateL2CacheStrategySelfTest.java | 7 +- .../CacheHibernateStoreFactorySelfTest.java | 11 +- .../testsuites/IgniteHibernateTestSuite.java | 22 +- .../HibernateL2CacheConfigurationSelfTest.java | 8 +- .../hibernate/HibernateL2CacheMultiJvmTest.java | 5 + .../hibernate/HibernateL2CacheSelfTest.java | 14 +- .../HibernateL2CacheStrategySelfTest.java | 7 +- .../CacheHibernateBlobStoreSelfTest.java | 8 + .../CacheHibernateStoreFactorySelfTest.java | 11 +- .../testsuites/IgniteHibernate5TestSuite.java | 24 +- .../query/h2/DmlStatementsProcessor.java | 2 +- .../processors/query/h2/H2RowCacheRegistry.java | 2 +- .../processors/query/h2/H2TableDescriptor.java | 6 +- .../internal/processors/query/h2/H2Utils.java | 4 +- .../processors/query/h2/IgniteH2Indexing.java | 4 +- .../query/h2/affinity/PartitionExtractor.java | 36 +- .../processors/query/h2/database/H2Tree.java | 15 +- .../query/h2/database/H2TreeIndex.java | 29 +- .../query/h2/dml/UpdatePlanBuilder.java | 2 +- .../query/h2/opt/GridH2CollocationModel.java | 10 +- .../query/h2/opt/GridH2IndexBase.java | 6 +- .../query/h2/opt/GridH2RowDescriptor.java | 11 +- .../processors/query/h2/opt/GridH2Table.java | 74 +- .../h2/twostep/GridReduceQueryExecutor.java | 8 +- .../query/h2/twostep/ReducePartitionMapper.java | 11 +- ...ityKeyNameAndValueFieldNameConflictTest.java | 16 +- .../processors/cache/BigEntryQueryTest.java | 5 + ...MetadataConcurrentUpdateWithIndexesTest.java | 5 + .../cache/BinarySerializationQuerySelfTest.java | 9 + .../cache/BinaryTypeMismatchLoggingTest.java | 15 +- ...CacheAbstractQueryDetailMetricsSelfTest.java | 20 + .../CacheAbstractQueryMetricsSelfTest.java | 19 + .../CacheBinaryKeyConcurrentQueryTest.java | 5 + .../cache/CacheConfigurationP2PTest.java | 7 +- .../cache/CacheIndexStreamerTest.java | 6 + .../cache/CacheIteratorScanQueryTest.java | 6 + .../CacheOffheapBatchIndexingMultiTypeTest.java | 8 +- ...CacheOffheapBatchIndexingSingleTypeTest.java | 9 +- .../CacheOperationsWithExpirationTest.java | 6 + .../cache/CacheQueryBuildValueTest.java | 5 + .../cache/CacheQueryEvictDataLostTest.java | 5 + .../cache/CacheQueryFilterExpiredTest.java | 5 + .../cache/CacheQueryNewClientSelfTest.java | 6 + .../CacheRandomOperationsMultithreadedTest.java | 8 + ...CacheScanPartitionQueryFallbackSelfTest.java | 13 +- .../cache/CacheSqlQueryValueCopySelfTest.java | 12 + .../ClientReconnectAfterClusterRestartTest.java | 5 + .../cache/ClusterReadOnlyModeSqlTest.java | 5 + .../cache/DdlTransactionSelfTest.java | 10 + .../cache/GridCacheCrossCacheQuerySelfTest.java | 7 + .../cache/GridCacheFullTextQuerySelfTest.java | 11 +- ...GridCacheLazyQueryPartitionsReleaseTest.java | 6 + .../cache/GridCacheOffHeapSelfTest.java | 7 +- .../GridCacheOffheapIndexEntryEvictTest.java | 8 +- .../cache/GridCacheOffheapIndexGetSelfTest.java | 9 +- .../GridCacheQueryIndexDisabledSelfTest.java | 12 + .../GridCacheQuerySerializationSelfTest.java | 7 +- .../cache/GridCacheQuerySimpleBenchmark.java | 7 +- .../cache/GridIndexingWithNoopSwapSelfTest.java | 7 +- .../IgniteBinaryObjectFieldsQuerySelfTest.java | 12 + .../IgniteBinaryObjectQueryArgumentsTest.java | 13 + ...eBinaryWrappedObjectFieldsQuerySelfTest.java | 2 +- .../IgniteCacheAbstractFieldsQuerySelfTest.java | 26 + .../IgniteCacheCollocatedQuerySelfTest.java | 6 + .../IgniteCacheConfigVariationsQueryTest.java | 10 + ...acheConfigurationPrimitiveTypesSelfTest.java | 7 +- .../IgniteCacheCrossCacheJoinRandomTest.java | 8 + .../IgniteCacheDeleteSqlQuerySelfTest.java | 7 + ...acheDistributedJoinCollocatedAndNotTest.java | 7 + ...acheDistributedJoinCustomAffinityMapper.java | 5 + .../IgniteCacheDistributedJoinNoIndexTest.java | 5 + ...ributedJoinPartitionedAndReplicatedTest.java | 7 + ...CacheDistributedJoinQueryConditionsTest.java | 9 + .../cache/IgniteCacheDistributedJoinTest.java | 5 + ...cheDuplicateEntityConfigurationSelfTest.java | 6 + .../IgniteCacheFieldsQueryNoDataSelfTest.java | 7 +- ...teCacheFullTextQueryNodeJoiningSelfTest.java | 7 +- .../cache/IgniteCacheGroupsSqlTest.java | 11 + .../IgniteCacheInsertSqlQuerySelfTest.java | 15 + ...PartitionedAndReplicatedCollocationTest.java | 5 + ...teCacheJoinPartitionedAndReplicatedTest.java | 6 + ...IgniteCacheJoinQueryWithAffinityKeyTest.java | 10 + .../cache/IgniteCacheLargeResultSelfTest.java | 7 +- ...PartitionOnAffinityRunAtomicCacheOpTest.java | 7 + ...niteCacheLockPartitionOnAffinityRunTest.java | 13 + ...titionOnAffinityRunWithCollisionSpiTest.java | 6 + .../cache/IgniteCacheMergeSqlQuerySelfTest.java | 11 + .../IgniteCacheMultipleIndexedTypesTest.java | 5 + .../cache/IgniteCacheNoClassQuerySelfTest.java | 5 + .../IgniteCacheObjectKeyIndexingSelfTest.java | 9 +- .../cache/IgniteCacheOffheapEvictQueryTest.java | 5 + .../cache/IgniteCacheOffheapIndexScanTest.java | 7 +- ...niteCacheP2pUnmarshallingQueryErrorTest.java | 6 + ...hePartitionedQueryMultiThreadedSelfTest.java | 7 +- ...IgniteCachePrimitiveFieldsQuerySelfTest.java | 7 +- .../cache/IgniteCacheQueriesLoadTest1.java | 5 + .../IgniteCacheQueryH2IndexingLeakTest.java | 8 +- .../cache/IgniteCacheQueryIndexSelfTest.java | 8 +- .../cache/IgniteCacheQueryLoadSelfTest.java | 12 +- .../IgniteCacheQueryMultiThreadedSelfTest.java | 12 + .../cache/IgniteCacheSqlQueryErrorSelfTest.java | 13 + ...gniteCacheSqlQueryMultiThreadedSelfTest.java | 8 +- .../IgniteCacheStarvationOnRebalanceTest.java | 7 +- .../IgniteCacheUpdateSqlQuerySelfTest.java | 10 + ...CheckClusterStateBeforeExecuteQueryTest.java | 5 + ...ClientReconnectCacheQueriesFailoverTest.java | 6 + .../cache/IgniteClientReconnectQueriesTest.java | 11 +- .../cache/IgniteCrossCachesJoinsQueryTest.java | 10 + .../cache/IgniteDynamicSqlRestoreTest.java | 13 + .../cache/IgniteErrorOnRebalanceTest.java | 5 + .../cache/IncorrectQueryEntityTest.java | 5 + .../cache/QueryEntityCaseMismatchTest.java | 5 + .../QueryJoinWithDifferentNodeFiltersTest.java | 7 +- .../cache/SqlFieldsQuerySelfTest.java | 7 + .../cache/StartCachesInParallelTest.java | 9 +- .../authentication/SqlUserCommandSelfTest.java | 11 + .../CacheBlockOnCreateDestoryIndexTest.java | 36 + .../distributed/CacheBlockOnSqlQueryTest.java | 14 + ...lientQueryReplicatedNodeRestartSelfTest.java | 7 +- ...utedPartitionQueryConfigurationSelfTest.java | 7 +- ...butedPartitionQueryNodeRestartsSelfTest.java | 7 +- ...eCacheDistributedPartitionQuerySelfTest.java | 13 +- ...niteCacheDistributedQueryCancelSelfTest.java | 6 + ...butedQueryStopOnCancelOrTimeoutSelfTest.java | 19 + ...niteCachePartitionedFieldsQuerySelfTest.java | 8 +- .../IgniteCachePartitionedQuerySelfTest.java | 2 +- .../IgniteCacheQueryNoRebalanceSelfTest.java | 5 + .../near/IgniteCacheQueryNodeFailTest.java | 6 + ...QueryNodeRestartDistributedJoinSelfTest.java | 8 +- .../IgniteCacheQueryNodeRestartSelfTest.java | 7 +- .../IgniteCacheQueryNodeRestartSelfTest2.java | 5 + ...nCancelOrTimeoutDistributedJoinSelfTest.java | 12 + .../near/IgniteSqlQueryWithBaselineTest.java | 9 +- ...ldsQueryJoinNoPrimaryPartitionsSelfTest.java | 7 +- ...gniteCacheReplicatedFieldsQuerySelfTest.java | 7 +- .../cache/index/BasicIndexMultinodeTest.java | 28 + .../processors/cache/index/BasicIndexTest.java | 357 ++-- .../index/ComplexPrimaryKeyUnwrapSelfTest.java | 9 + .../ComplexSecondaryKeyUnwrapSelfTest.java | 6 + .../index/DuplicateKeyValueClassesSelfTest.java | 6 + ...ynamicColumnsAbstractConcurrentSelfTest.java | 20 + .../DynamicIndexAbstractBasicSelfTest.java | 73 + .../DynamicIndexAbstractConcurrentSelfTest.java | 18 +- .../cache/index/H2ConnectionLeaksSelfTest.java | 6 + .../H2DynamicColumnsAbstractBasicSelfTest.java | 32 + .../index/H2DynamicIndexAbstractSelfTest.java | 11 + .../H2DynamicIndexingComplexAbstractTest.java | 5 + .../cache/index/H2DynamicTableSelfTest.java | 66 + .../cache/index/H2RowCachePageEvictionTest.java | 8 + .../cache/index/H2RowCacheSelfTest.java | 12 + .../cache/index/IgniteDecimalSelfTest.java | 9 + .../index/IoStatisticsBasicIndexSelfTest.java | 500 ++++++ .../cache/index/LongIndexNameTest.java | 5 + .../index/MvccEmptyTransactionSelfTest.java | 5 + .../index/OptimizedMarshallerIndexNameTest.java | 5 + .../index/QueryEntityValidationSelfTest.java | 7 + .../cache/index/SchemaExchangeSelfTest.java | 16 + ...sactionCommandsWithMvccDisabledSelfTest.java | 7 + ...sactionsCommandsWithMvccEnabledSelfTest.java | 10 + .../cache/index/SqlTransactionsSelfTest.java | 11 + .../IgniteCacheLocalFieldsQuerySelfTest.java | 7 +- ...eCacheLocalQueryCancelOrTimeoutSelfTest.java | 9 +- .../local/IgniteCacheLocalQuerySelfTest.java | 7 + ...acheMvccAbstractContinuousQuerySelfTest.java | 16 +- ...eMvccAbstractSqlCoordinatorFailoverTest.java | 18 + .../mvcc/CacheMvccBackupsAbstractTest.java | 17 + .../mvcc/CacheMvccBasicContinuousQueryTest.java | 10 + .../cache/mvcc/CacheMvccBulkLoadTest.java | 7 + ...ContinuousWithTransformerClientSelfTest.java | 5 + ...nuousWithTransformerPartitionedSelfTest.java | 5 + ...inuousWithTransformerReplicatedSelfTest.java | 5 + .../cache/mvcc/CacheMvccDmlSimpleTest.java | 8 + ...MvccPartitionedSelectForUpdateQueryTest.java | 8 +- ...ccPartitionedSqlCoordinatorFailoverTest.java | 22 + ...cPartitionedSqlTxQueriesWithReducerTest.java | 7 +- .../CacheMvccReplicatedSqlTxQueriesTest.java | 9 +- ...cheMvccSelectForUpdateQueryAbstractTest.java | 13 + .../cache/mvcc/CacheMvccSizeTest.java | 11 + ...CacheMvccSqlConfigurationValidationTest.java | 7 + .../cache/mvcc/CacheMvccSqlLockTimeoutTest.java | 10 + .../mvcc/CacheMvccSqlQueriesAbstractTest.java | 31 + .../mvcc/CacheMvccSqlTxQueriesAbstractTest.java | 60 +- ...MvccSqlTxQueriesWithReducerAbstractTest.java | 20 + .../mvcc/CacheMvccSqlUpdateCountersTest.java | 9 + .../mvcc/CacheMvccStreamingInsertTest.java | 6 + .../cache/mvcc/CacheMvccTxNodeMappingTest.java | 6 + .../cache/mvcc/CacheMvccTxRecoveryTest.java | 15 + .../mvcc/MvccRepeatableReadBulkOpsTest.java | 16 + .../mvcc/MvccRepeatableReadOperationsTest.java | 9 +- .../db/wal/IgniteWalRecoveryTest.java | 35 +- .../transaction/DmlInsideTransactionTest.java | 8 + .../cache/ttl/CacheTtlAbstractSelfTest.java | 13 +- ...onnectorConfigurationValidationSelfTest.java | 21 + .../client/IgniteDataStreamerTest.java | 5 + ...gniteDbSingleNodeWithIndexingPutGetTest.java | 6 + ...eDbSingleNodeWithIndexingWalRestoreTest.java | 6 + ...oreQueryWithMultipleClassesPerCacheTest.java | 7 +- .../IgnitePersistentStoreSchemaLoadTest.java | 7 + .../IgniteTwoRegionsRebuildIndexTest.java | 5 + ...iteCacheGroupsSqlSegmentedIndexSelfTest.java | 5 + .../query/IgniteCachelessQueriesSelfTest.java | 24 + .../query/IgniteQueryDedicatedPoolTest.java | 7 + .../query/IgniteSqlDefaultValueTest.java | 9 + .../query/IgniteSqlDistributedJoinSelfTest.java | 5 + .../IgniteSqlEntryCacheModeAgnosticTest.java | 5 + .../IgniteSqlGroupConcatCollocatedTest.java | 7 + .../IgniteSqlGroupConcatNotCollocatedTest.java | 7 + .../query/IgniteSqlKeyValueFieldsTest.java | 795 ++++----- .../query/IgniteSqlNotNullConstraintTest.java | 46 + .../query/IgniteSqlParameterizedQueryTest.java | 5 + .../query/IgniteSqlQueryParallelismTest.java | 8 +- .../processors/query/IgniteSqlRoutingTest.java | 18 + .../query/IgniteSqlSchemaIndexingTest.java | 17 +- .../query/IgniteSqlSegmentedIndexSelfTest.java | 10 + ...teSqlSkipReducerOnUpdateDmlFlagSelfTest.java | 24 + ...IgniteSqlSkipReducerOnUpdateDmlSelfTest.java | 13 + .../query/IgniteSqlSplitterSelfTest.java | 48 + .../processors/query/LazyQuerySelfTest.java | 8 + .../MultipleStatementsSqlQuerySelfTest.java | 8 + .../processors/query/RunningQueriesTest.java | 5 + .../query/SqlIllegalSchemaSelfTest.java | 12 + .../query/SqlNestedQuerySelfTest.java | 5 + .../query/SqlPushDownFunctionTest.java | 5 + .../processors/query/SqlSchemaSelfTest.java | 12 + .../query/SqlSystemViewsSelfTest.java | 12 +- .../query/h2/GridIndexRebuildSelfTest.java | 5 + ...GridIndexRebuildWithMvccEnabledSelfTest.java | 5 + .../h2/GridIndexingSpiAbstractSelfTest.java | 5 + ...H2ResultSetIteratorNullifyOnEndSelfTest.java | 8 + .../query/h2/H2StatementCacheSelfTest.java | 9 +- .../query/h2/IgniteSqlBigIntegerKeyTest.java | 7 + .../query/h2/IgniteSqlQueryMinMaxTest.java | 13 + .../query/h2/PreparedStatementExSelfTest.java | 8 +- .../query/h2/ThreadLocalObjectPoolSelfTest.java | 9 + .../h2/database/InlineIndexHelperTest.java | 30 + .../query/h2/sql/BaseH2CompareQueryTest.java | 21 +- .../query/h2/sql/ExplainSelfTest.java | 10 + .../query/h2/sql/GridQueryParsingTest.java | 17 + .../query/h2/sql/H2CompareBigQueryTest.java | 5 + .../AndOperationExtractPartitionSelfTest.java | 2 +- .../h2/twostep/CacheQueryMemoryLeakTest.java | 5 + .../twostep/CreateTableWithDateKeySelfTest.java | 7 + ...sappearedCacheCauseRetryMessageSelfTest.java | 11 +- ...appearedCacheWasNotFoundMessageSelfTest.java | 17 +- .../InOperationExtractPartitionSelfTest.java | 13 +- .../query/h2/twostep/JoinSqlTestHelper.java | 72 +- .../NonCollocatedRetryMessageSelfTest.java | 9 +- .../h2/twostep/RetryCauseMessageSelfTest.java | 15 +- .../h2/twostep/TableViewSubquerySelfTest.java | 5 + ...ePartitionedAtomicColumnConstraintsTest.java | 31 + ...ionedTransactionalColumnConstraintsTest.java | 4 +- ...ansactionalSnapshotColumnConstraintTest.java | 22 + ...ansactionalSnapshotColumnConstraintTest.java | 22 + .../sql/IgniteSQLColumnConstraintsTest.java | 19 +- ...gniteTransactionSQLColumnConstraintTest.java | 6 + ...onnectorConfigurationValidationSelfTest.java | 11 + .../tcp/GridOrderedMessageCancelSelfTest.java | 8 +- .../org/apache/ignite/sqltests/BaseSqlTest.java | 23 + .../ignite/sqltests/PartitionedSqlTest.java | 10 + .../ignite/sqltests/ReplicatedSqlTest.java | 19 + .../IgniteBinaryCacheQueryTestSuite.java | 32 +- .../IgniteBinaryCacheQueryTestSuite2.java | 84 +- .../IgniteCacheAffinityRunTestSuite.java | 18 +- ...ockExchangeOnSqlReadOperationsTestSuite.java | 5 +- .../testsuites/IgniteCacheMvccSqlTestSuite.java | 101 +- .../IgniteCacheQuerySelfTestSuite3.java | 66 +- .../IgniteCacheQuerySelfTestSuite4.java | 24 +- .../IgniteCacheQuerySelfTestSuite5.java | 40 +- .../IgniteCacheQuerySelfTestSuite6.java | 40 +- ...acheWithIndexingAndPersistenceTestSuite.java | 8 +- .../IgniteCacheWithIndexingTestSuite.java | 52 +- ...IgniteDbMemoryLeakWithIndexingTestSuite.java | 8 +- .../IgnitePdsWithIndexingCoreTestSuite.java | 56 +- .../IgnitePdsWithIndexingTestSuite.java | 20 +- .../util/GridCommandHandlerIndexingTest.java | 11 +- ...ityWithJsr310Java8DateTimeApiFieldsTest.java | 12 + ...yJsr310Java8DateTimeApiSupportTestSuite.java | 3 +- .../apache/ignite/logger/jcl/JclLoggerTest.java | 7 +- .../ignite/testsuites/IgniteJclTestSuite.java | 8 +- .../stream/jms11/IgniteJmsStreamerTest.java | 26 +- .../cache/CacheJndiTmFactorySelfTest.java | 6 + ...CacheJtaConfigurationValidationSelfTest.java | 5 + ...CacheJtaFactoryConfigValidationSelfTest.java | 7 + .../cache/GridJtaLifecycleAwareSelfTest.java | 8 + .../GridJtaTransactionManagerSelfTest.java | 6 + ...titionedCacheJtaLookupClassNameSelfTest.java | 2 +- .../ignite/testsuites/IgniteJtaTestSuite.java | 18 +- .../kafka/IgniteKafkaStreamerSelfTestSuite.java | 10 +- .../kafka/KafkaIgniteStreamerSelfTest.java | 5 + .../kafka/connect/IgniteSinkConnectorTest.java | 6 + .../connect/IgniteSourceConnectorTest.java | 6 + modules/kubernetes/pom.xml | 6 + .../TcpDiscoveryKubernetesIpFinderSelfTest.java | 7 +- .../testsuites/IgniteKubernetesTestSuite.java | 8 +- .../logger/log4j/GridLog4jConfigUpdateTest.java | 8 + .../log4j/GridLog4jCorrectFileNameTest.java | 24 +- .../logger/log4j/GridLog4jInitializedTest.java | 7 +- .../logger/log4j/GridLog4jLoggingFileTest.java | 17 +- .../logger/log4j/GridLog4jLoggingPathTest.java | 17 +- .../logger/log4j/GridLog4jLoggingUrlTest.java | 17 +- .../log4j/GridLog4jNotInitializedTest.java | 7 +- .../logger/log4j2/Log4j2ConfigUpdateTest.java | 7 + .../logger/log4j2/Log4j2LoggerMarkerTest.java | 24 +- .../logger/log4j2/Log4j2LoggerSelfTest.java | 26 +- .../log4j2/Log4j2LoggerVerboseModeSelfTest.java | 11 +- .../testsuites/IgniteLog4j2TestSuite.java | 14 +- .../org/apache/ignite/IgniteMesosTestSuite.java | 8 +- .../main/java/org/apache/ignite/ml/Model.java | 11 + .../stacking/SimpleStackedDatasetTrainer.java | 125 ++ .../stacking/StackedDatasetTrainer.java | 412 +++++ .../ml/composition/stacking/StackedModel.java | 106 ++ .../stacking/StackedVectorDatasetTrainer.java | 151 ++ .../ml/composition/stacking/package-info.java | 22 + .../ignite/ml/dataset/UpstreamTransformer.java | 2 +- .../dataset/impl/cache/util/ComputeUtils.java | 2 +- .../IgniteDistributedInfModelBuilder.java | 7 +- .../KNNClassificationTrainer.java | 2 +- .../exceptions/preprocessing/package-info.java | 22 + .../ml/math/functions/IgniteFunction.java | 15 +- .../primitives/matrix/impl/DenseMatrix.java | 2 +- .../ml/math/primitives/vector/VectorUtils.java | 72 +- .../vector/storage/DenseVectorStorage.java | 2 +- .../ignite/ml/multiclass/OneVsRestTrainer.java | 2 +- .../ignite/ml/multiclass/package-info.java | 22 + .../discrete/DiscreteNaiveBayesModel.java | 127 ++ .../discrete/DiscreteNaiveBayesSumsHolder.java | 54 + .../discrete/DiscreteNaiveBayesTrainer.java | 233 +++ .../ml/naivebayes/discrete/package-info.java | 22 + .../linear/LinearRegressionLSQRTrainer.java | 2 +- .../logistic/LogisticRegressionSGDTrainer.java | 11 +- .../scoring/evaluator/package-info.java | 22 + .../ml/trainers/AdaptableDatasetModel.java | 98 ++ .../ml/trainers/AdaptableDatasetTrainer.java | 120 ++ .../ignite/ml/trainers/DatasetTrainer.java | 33 + .../org/apache/ignite/ml/tree/DecisionTree.java | 2 +- .../ignite/ml/util/MLSandboxDatasets.java | 5 +- .../english_vs_scottish_binary_dataset.csv | 14 + .../org/apache/ignite/ml/IgniteMLTestSuite.java | 57 +- .../java/org/apache/ignite/ml/TestUtils.java | 38 +- .../apache/ignite/ml/common/TrainerTest.java | 29 + .../ignite/ml/composition/BaggingTest.java | 217 +++ .../ml/composition/CompositionTestSuite.java | 4 +- .../ignite/ml/composition/StackingTest.java | 172 ++ .../ignite/ml/dataset/DatasetTestSuite.java | 40 +- .../impl/cache/util/ComputeUtilsTest.java | 4 +- .../ignite/ml/inference/InferenceTestSuite.java | 28 +- .../IgniteDistributedInfModelBuilderTest.java | 3 +- .../ml/multiclass/OneVsRestTrainerTest.java | 4 +- .../discrete/DiscreteNaiveBayesModelTest.java | 45 + .../discrete/DiscreteNaiveBayesTest.java | 67 + .../discrete/DiscreteNaiveBayesTrainerTest.java | 185 ++ .../org/apache/ignite/ml/nn/MLPTestSuite.java | 27 +- .../ignite/ml/nn/MLPTrainerIntegrationTest.java | 2 +- .../MLPTrainerMnistIntegrationTest.java | 4 +- .../ml/nn/performance/MLPTrainerMnistTest.java | 2 +- .../apache/ignite/ml/pipeline/PipelineTest.java | 2 +- .../LogisticRegressionSGDTrainerTest.java | 4 +- .../ignite/ml/selection/SelectionTestSuite.java | 41 +- .../apache/ignite/ml/trainers/BaggingTest.java | 235 --- ...reeClassificationTrainerIntegrationTest.java | 2 +- ...ionTreeRegressionTrainerIntegrationTest.java | 2 +- .../ignite/ml/tree/DecisionTreeTestSuite.java | 40 +- .../DecisionTreeMNISTIntegrationTest.java | 2 +- modules/ml/xgboost-model-parser/pom.xml | 55 + .../ignite/ml/xgboost/MapBasedXGObject.java | 61 + .../apache/ignite/ml/xgboost/XGLeafNode.java | 38 + .../org/apache/ignite/ml/xgboost/XGModel.java | 53 + .../org/apache/ignite/ml/xgboost/XGNode.java | 29 + .../org/apache/ignite/ml/xgboost/XGObject.java | 33 + .../apache/ignite/ml/xgboost/XGSplitNode.java | 74 + .../apache/ignite/ml/xgboost/package-info.java | 22 + .../xgboost/parser/XGBoostModelBaseVisitor.java | 78 + .../ml/xgboost/parser/XGBoostModelLexer.java | 210 +++ .../ml/xgboost/parser/XGBoostModelListener.java | 98 ++ .../ml/xgboost/parser/XGBoostModelParser.java | 966 +++++++++++ .../ml/xgboost/parser/XGBoostModelVisitor.java | 71 + .../ignite/ml/xgboost/parser/XGModelParser.java | 87 + .../ignite/ml/xgboost/parser/package-info.java | 22 + .../xgboost/parser/visitor/XGModelVisitor.java | 43 + .../xgboost/parser/visitor/XGTreeVisitor.java | 82 + .../ml/xgboost/parser/visitor/package-info.java | 22 + .../ml/xgboost/IgniteMLXGBoostTestSuite.java | 31 + .../xgboost/parser/XGBoostModelParserTest.java | 85 + .../test/resources/datasets/agaricus-model.txt | 714 ++++++++ .../resources/datasets/agaricus-test-data.txt | 1611 ++++++++++++++++++ .../datasets/agaricus-test-expected-results.txt | 1611 ++++++++++++++++++ .../stream/mqtt/IgniteMqttStreamerTest.java | 23 +- .../Apache.Ignite.Core.Tests.csproj | 1 + .../Query/CacheQueriesWithRestartServerTest.cs | 160 ++ .../Apache.Ignite.Core.Tests/ReconnectTest.cs | 70 +- .../Impl/Binary/BinaryFullTypeDescriptor.cs | 11 + .../Impl/Binary/Marshaller.cs | 36 +- .../Binary/Structure/BinaryStructureTracker.cs | 3 +- .../Common/CopyOnWriteConcurrentDictionary.cs | 18 +- .../Impl/Common/DelegateConverter.cs | 1 + .../Impl/Datastream/DataStreamerImpl.cs | 1 + .../dotnet/Apache.Ignite.Core/Impl/Ignite.cs | 2 + .../http/jetty/GridJettyRestHandler.java | 16 + .../protocols/http/jetty/GridRestSuite.java | 3 +- .../http/jetty/RestSetupSimpleTest.java | 5 + .../stream/rocketmq/RocketMQStreamerTest.java | 5 + .../rocketmq/RocketMQStreamerTestSuite.java | 6 +- .../schedule/GridScheduleSelfTest.java | 13 +- .../testsuites/IgniteSchedulerTestSuite.java | 8 +- .../logger/slf4j/Slf4jLoggerMarkerTest.java | 5 + .../ignite/testsuites/IgniteSlf4jTestSuite.java | 3 +- .../spark/JavaEmbeddedIgniteRDDSelfTest.java | 10 +- .../spark/JavaStandaloneIgniteRDDSelfTest.java | 11 +- .../ignite/testsuites/IgniteRDDTestSuite.java | 8 +- .../IgniteSpringDataCrudSelfTest.java | 10 + .../IgniteSpringDataQueriesSelfTest.java | 23 + .../testsuites/IgniteSpringData2TestSuite.java | 8 +- .../IgniteSpringDataCrudSelfTest.java | 10 + .../IgniteSpringDataQueriesSelfTest.java | 24 + .../testsuites/IgniteSpringDataTestSuite.java | 8 +- .../GridSpringCacheManagerAbstractTest.java | 19 + .../GridSpringCacheManagerMultiJvmSelfTest.java | 5 + .../SpringCacheManagerContextInjectionTest.java | 6 + .../ignite/cache/spring/SpringCacheTest.java | 12 + .../jdbc/CacheJdbcBlobStoreFactorySelfTest.java | 9 +- .../jdbc/CacheJdbcPojoStoreFactorySelfTest.java | 9 +- .../SpringEncryptedCacheRestartTest.java | 9 + .../ignite/internal/GridFactorySelfTest.java | 25 + .../GridSpringBeanSerializationSelfTest.java | 5 + .../internal/IgniteDynamicCacheConfigTest.java | 10 + .../ignite/internal/IgniteSpringBeanTest.java | 6 + .../resource/GridLoggerInjectionSelfTest.java | 9 +- .../resource/GridResourceProcessorSelfTest.java | 12 +- .../resource/GridServiceInjectionSelfTest.java | 16 +- .../GridSpringResourceInjectionSelfTest.java | 18 + .../GridTransformSpringInjectionSelfTest.java | 5 + .../p2p/GridP2PUserVersionChangeSelfTest.java | 11 +- .../IgniteExcludeInConfigurationTest.java | 8 +- .../IgniteStartFromStreamConfigurationTest.java | 7 +- .../GridServiceInjectionSpringResourceTest.java | 5 + ...teSpringBeanSpringResourceInjectionTest.java | 6 + .../testsuites/IgniteResourceSelfTestSuite.java | 14 +- .../testsuites/IgniteSpringTestSuite.java | 55 +- ...ridSpringTransactionManagerAbstractTest.java | 9 + ...gTransactionManagerContextInjectionTest.java | 8 +- .../internal/IgniteNodeStartUtilsSelfTest.java | 7 +- ...gniteProjectionStartStopRestartSelfTest.java | 22 +- .../IgniteStartStopRestartTestSuite.java | 8 +- .../storm/IgniteStormStreamerSelfTestSuite.java | 7 +- .../storm/StormIgniteStreamerSelfTest.java | 5 + .../twitter/IgniteTwitterStreamerTest.java | 8 +- .../twitter/IgniteTwitterStreamerTestSuite.java | 6 +- .../GridTaskUriDeploymentDeadlockSelfTest.java | 7 +- .../ignite/p2p/GridP2PDisabledSelfTest.java | 8 + ...loymentClassLoaderMultiThreadedSelfTest.java | 7 +- .../GridUriDeploymentClassLoaderSelfTest.java | 8 +- ...riDeploymentClassloaderRegisterSelfTest.java | 8 +- .../uri/GridUriDeploymentConfigSelfTest.java | 7 +- .../GridUriDeploymentFileProcessorSelfTest.java | 8 + .../uri/GridUriDeploymentMd5CheckSelfTest.java | 6 + ...loymentMultiScannersErrorThrottlingTest.java | 5 + .../GridUriDeploymentMultiScannersSelfTest.java | 7 +- .../uri/GridUriDeploymentSimpleSelfTest.java | 12 +- .../file/GridFileDeploymentSelfTest.java | 11 + .../GridFileDeploymentUndeploySelfTest.java | 7 +- .../http/GridHttpDeploymentSelfTest.java | 6 + .../testsuites/IgniteToolsSelfTestSuite.java | 8 +- .../IgniteUriDeploymentTestSuite.java | 34 +- .../apache/ignite/tools/GridToolsSelfTest.java | 13 +- .../e2e/testcafe/components/topNavigation.js | 6 +- .../e2e/testcafe/components/userMenu.js | 2 +- modules/web-console/frontend/app/app.config.js | 7 + modules/web-console/frontend/app/app.js | 8 +- .../connected-clusters-badge/style.scss | 34 +- .../connected-clusters-badge/template.pug | 5 +- .../components/list/controller.js | 2 +- .../cluster-edit-form/templates/ssl.pug | 2 +- .../page-configure/icons/configuration.icon.svg | 13 + .../app/components/page-configure/index.js | 193 --- .../app/components/page-configure/index.ts | 194 +++ .../page-forgot-password/controller.js | 8 +- .../app/components/page-forgot-password/run.js | 11 +- .../components/page-forgot-password/style.scss | 38 +- .../page-forgot-password/template.pug | 53 +- .../app/components/page-landing/index.js | 11 +- .../app/components/page-landing/public.pug | 21 + .../app/components/page-landing/style.scss | 12 + .../app/components/page-landing/template.pug | 8 - .../page-password-changed/controller.js | 26 - .../page-password-changed/controller.ts | 32 + .../components/page-password-changed/index.js | 10 +- .../components/page-password-changed/style.scss | 13 +- .../page-password-changed/template.pug | 9 +- .../page-password-reset/controller.js | 11 +- .../app/components/page-password-reset/index.js | 10 +- .../components/page-password-reset/style.scss | 15 +- .../components/page-password-reset/template.pug | 102 +- .../app/components/page-queries/index.js | 100 -- .../app/components/page-queries/index.ts | 110 ++ .../app/components/page-signin/controller.ts | 7 +- .../frontend/app/components/page-signin/run.ts | 10 +- .../app/components/page-signin/style.scss | 33 +- .../app/components/page-signin/template.pug | 73 +- .../app/components/page-signup/controller.ts | 11 +- .../frontend/app/components/page-signup/run.js | 11 +- .../app/components/page-signup/style.scss | 26 +- .../app/components/page-signup/template.pug | 36 +- .../permanent-notifications/component.ts | 25 + .../permanent-notifications/controller.ts | 28 + .../components/permanent-notifications/index.ts | 21 + .../permanent-notifications/style.scss | 54 + .../permanent-notifications/template.pug | 23 + .../app/components/timed-redirection/style.scss | 1 + .../components/web-console-footer/component.js | 4 +- .../web-console-footer-links/component.js | 23 - .../web-console-footer-links/style.scss | 31 - .../web-console-footer-links/template.pug | 17 - .../components/web-console-footer/controller.ts | 27 + .../app/components/web-console-footer/index.js | 11 +- .../components/web-console-footer/style.scss | 93 +- .../components/web-console-footer/template.pug | 20 +- .../components/web-console-header/component.js | 53 - .../components/web-console-header/component.ts | 43 + .../components/demo-mode-button/component.ts | 24 + .../components/demo-mode-button/controller.ts | 46 + .../components/demo-mode-button/template.pug | 20 + .../components/user-menu/component.ts | 25 + .../components/user-menu/controller.ts | 53 + .../components/user-menu/style.scss | 28 + .../components/user-menu/template.pug | 26 + .../web-console-header-content/component.ts | 25 + .../web-console-header-content/controller.ts | 45 + .../web-console-header-content/style.scss | 44 + .../web-console-header-content/template.pug | 24 + .../web-console-header-extension/component.js | 22 - .../web-console-header-extension/template.pug | 15 - .../app/components/web-console-header/index.js | 8 +- .../components/web-console-header/style.scss | 168 +- .../components/web-console-header/template.pug | 32 +- .../components/web-console-sidebar/component.ts | 25 + .../web-console-sidebar/controller.ts | 30 + .../app/components/web-console-sidebar/index.ts | 25 + .../components/web-console-sidebar/style.scss | 44 + .../components/web-console-sidebar/template.pug | 22 + .../web-console-sidebar-navigation/component.ts | 28 + .../controller.ts | 24 + .../web-console-sidebar-navigation/style.scss | 109 ++ .../web-console-sidebar-navigation/template.pug | 35 + .../web-console-sidebar-overflow/component.ts | 26 + .../web-console-sidebar-overflow/controller.ts | 50 + .../web-console-sidebar-overflow/style.scss | 52 + .../web-console-sidebar-overflow/template.pug | 18 + .../app/modules/branding/branding.module.js | 10 +- .../app/modules/branding/branding.service.js | 4 - .../app/modules/branding/footer.directive.js | 39 - .../modules/branding/header-logo.directive.js | 39 - .../app/modules/branding/header-logo.pug | 18 - .../modules/branding/header-title.directive.js | 44 - .../branding/powered-by-apache.directive.js | 39 - .../app/modules/branding/powered-by-apache.pug | 18 - .../frontend/app/modules/demo/Demo.module.js | 28 - .../app/modules/navbar/Navbar.provider.js | 30 - .../app/modules/navbar/navbar.directive.js | 32 - .../app/modules/navbar/navbar.module.js | 9 +- .../app/modules/navbar/userbar.directive.js | 59 - .../web-console/frontend/app/services/store.ts | 75 + .../frontend/app/store/actions/ui.ts | 36 + .../frontend/app/store/actions/user.ts | 24 + .../frontend/app/store/effects/ui.ts | 32 + modules/web-console/frontend/app/store/index.ts | 48 + .../web-console/frontend/app/store/ofType.ts | 26 + .../frontend/app/store/reducers/ui.ts | 50 + .../frontend/app/store/reduxDebug.ts | 45 + .../frontend/app/store/selectors/ui.ts | 29 + modules/web-console/frontend/app/types/index.ts | 30 + .../public/images/icons/cluster.icon.svg | 10 + .../images/icons/connectedClusters.icon.svg | 1 - .../public/images/icons/downloadAgent.icon.svg | 16 + .../frontend/public/images/icons/index.js | 5 +- .../frontend/public/images/icons/menu.icon.svg | 7 + .../frontend/public/images/icons/sql.icon.svg | 3 + .../frontend/public/stylesheets/style.scss | 74 +- modules/web-console/frontend/test/ci/Dockerfile | 6 +- modules/web-console/frontend/views/base.pug | 11 +- .../frontend/views/includes/header-left.pug | 42 - .../frontend/views/includes/header-right.pug | 35 - modules/web-console/frontend/views/public.pug | 20 + .../IgniteWebSessionSelfTestSuite.java | 18 +- .../internal/websession/WebSessionSelfTest.java | 16 +- modules/yardstick/DEVNOTES.txt | 2 +- modules/yardstick/config/ignite-base-config.xml | 3 + .../cache/IgniteSqlQueryFullScanBenchmark.java | 97 ++ .../apache/ignite/yardstick/cache/Loader.java | 4 +- .../yardstick/cache/model/PersonNoIndex.java | 215 +++ .../org/apache/ignite/IgniteYarnTestSuite.java | 8 +- .../yarn/IgniteApplicationMasterSelfTest.java | 28 +- .../stream/zeromq/IgniteZeroMqStreamerTest.java | 8 + .../zeromq/IgniteZeroMqStreamerTestSuite.java | 6 +- .../tcp/ipfinder/zk/ZookeeperIpFinderTest.java | 12 + ...CacheEntryListenerWithZkDiscoAtomicTest.java | 5 + .../zk/ZookeeperDiscoverySpiTestSuite1.java | 12 +- .../zk/ZookeeperDiscoverySpiTestSuite2.java | 13 +- .../zk/ZookeeperDiscoverySpiTestSuite3.java | 19 +- .../zk/ZookeeperDiscoverySpiTestSuite4.java | 15 +- ...ZookeeperDiscoverySuitePreprocessorTest.java | 5 + .../zk/internal/ZookeeperClientTest.java | 22 + ...ZookeeperDiscoverySpiSaslFailedAuthTest.java | 5 + ...eeperDiscoverySpiSaslSuccessfulAuthTest.java | 6 + .../zk/internal/ZookeeperDiscoverySpiTest.java | 112 ++ parent/pom.xml | 4 +- pom.xml | 1 + 1343 files changed, 31985 insertions(+), 6779 deletions(-) ----------------------------------------------------------------------
