Merge branch 'master' into ignite-5789-1 # Conflicts: # modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java # modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/ClientReconnectAfterClusterRestartTest.java
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/fbf252ba Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/fbf252ba Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/fbf252ba Branch: refs/heads/ignite-5789-1 Commit: fbf252ba7aedc6c0e36ef50d9a37ef0311439209 Parents: 3daf812 88d5ff8 Author: dpavlov <[email protected]> Authored: Thu May 24 15:51:01 2018 +0300 Committer: dpavlov <[email protected]> Committed: Thu May 24 15:51:01 2018 +0300 ---------------------------------------------------------------------- MIGRATION_GUIDE.txt | 2 + assembly/release-base.xml | 5 + bin/control.bat | 2 +- bin/control.sh | 2 +- ...heContinuousQueryWithTransformerExample.java | 20 +- .../CholeskyDecompositionExample.java | 80 - .../EigenDecompositionExample.java | 69 - .../decompositions/LUDecompositionExample.java | 83 - .../decompositions/QRDecompositionExample.java | 82 - .../SingularValueDecompositionExample.java | 70 - .../ml/math/decompositions/package-info.java | 22 - .../ml/math/matrix/CacheMatrixExample.java | 102 - .../math/matrix/MatrixCustomStorageExample.java | 14 - .../examples/ml/math/matrix/MatrixExample.java | 14 - .../ml/math/matrix/OffHeapMatrixExample.java | 14 - .../matrix/SparseDistributedMatrixExample.java | 70 - .../ml/math/matrix/SparseMatrixExample.java | 15 - .../ml/math/vector/CacheVectorExample.java | 109 - .../LogisticRegressionSGDTrainerSample.java | 239 - .../LogisticRegressionSGDTrainerSample.java | 239 + .../logistic/binary/package-info.java | 22 + ...gressionMultiClassClassificationExample.java | 301 + .../logistic/multiclass/package-info.java | 22 + .../optimized/OptimizedMarshallerAopTest.java | 7 - modules/cassandra/store/pom.xml | 6 +- .../cassandra/session/CassandraSessionImpl.java | 284 +- .../session/WrappedPreparedStatement.java | 181 + .../store/cassandra/session/WrappedSession.java | 91 + .../cassandra/session/pool/IdleSession.java | 72 + .../cassandra/session/pool/SessionPool.java | 22 +- .../cassandra/session/pool/SessionWrapper.java | 74 - .../ignite/tests/CassandraConfigTest.java | 141 + .../ignite/tests/CassandraSessionImplTest.java | 8 +- .../internal/TaskEventSubjectIdSelfTest.java | 2 - .../ClientAbstractMultiThreadedSelfTest.java | 5 - .../client/ClientDefaultCacheSelfTest.java | 2 - .../ClientAbstractMultiNodeSelfTest.java | 7 - .../integration/ClientAbstractSelfTest.java | 5 - .../integration/ClientPreferDirectSelfTest.java | 7 - .../router/TcpRouterAbstractSelfTest.java | 2 - .../router/TcpRouterMultiNodeSelfTest.java | 2 - .../jdbc2/JdbcAbstractDmlStatementSelfTest.java | 5 - .../internal/jdbc2/JdbcBulkLoadSelfTest.java | 5 - .../jdbc2/JdbcComplexQuerySelfTest.java | 5 - .../internal/jdbc2/JdbcConnectionSelfTest.java | 5 - .../jdbc2/JdbcDistributedJoinsQueryTest.java | 5 - .../internal/jdbc2/JdbcEmptyCacheSelfTest.java | 5 - .../internal/jdbc2/JdbcLocalCachesSelfTest.java | 5 - .../internal/jdbc2/JdbcMetadataSelfTest.java | 5 - .../jdbc2/JdbcNoCacheStreamingSelfTest.java | 5 - .../internal/jdbc2/JdbcNoDefaultCacheTest.java | 5 - .../jdbc2/JdbcPreparedStatementSelfTest.java | 5 - .../internal/jdbc2/JdbcResultSetSelfTest.java | 5 - .../internal/jdbc2/JdbcStatementSelfTest.java | 5 - .../internal/jdbc2/JdbcStreamingSelfTest.java | 8 - .../jdbc2/JdbcStreamingToPublicCacheTest.java | 5 - .../rest/AbstractRestProcessorSelfTest.java | 5 - .../rest/ChangeStateCommandHandlerTest.java | 6 - .../JettyRestProcessorAbstractSelfTest.java | 25 +- .../rest/RestBinaryProtocolSelfTest.java | 5 - .../rest/RestMemcacheProtocolSelfTest.java | 5 - .../rest/TaskCommandHandlerSelfTest.java | 2 - .../tcp/redis/RedisCommonAbstractTest.java | 2 - .../jdbc/AbstractJdbcPojoQuerySelfTest.java | 2 - .../ignite/jdbc/JdbcComplexQuerySelfTest.java | 5 - .../ignite/jdbc/JdbcConnectionSelfTest.java | 5 - .../ignite/jdbc/JdbcEmptyCacheSelfTest.java | 5 - .../ignite/jdbc/JdbcErrorsAbstractSelfTest.java | 7 - .../ignite/jdbc/JdbcLocalCachesSelfTest.java | 5 - .../ignite/jdbc/JdbcMetadataSelfTest.java | 5 - .../ignite/jdbc/JdbcNoDefaultCacheTest.java | 5 - .../jdbc/JdbcPreparedStatementSelfTest.java | 5 - .../ignite/jdbc/JdbcResultSetSelfTest.java | 5 - .../ignite/jdbc/JdbcStatementSelfTest.java | 5 - .../jdbc/suite/IgniteJdbcDriverTestSuite.java | 6 +- .../JdbcThinAbstractDmlStatementSelfTest.java | 5 - .../thin/JdbcThinAutoCloseServerCursorTest.java | 5 - .../thin/JdbcThinComplexDmlDdlSelfTest.java | 5 - .../jdbc/thin/JdbcThinComplexQuerySelfTest.java | 5 - ...JdbcThinConnectionMultipleAddressesTest.java | 7 +- .../jdbc/thin/JdbcThinConnectionSelfTest.java | 5 - .../jdbc/thin/JdbcThinEmptyCacheSelfTest.java | 5 - .../jdbc/thin/JdbcThinMetadataSelfTest.java | 5 - .../JdbcThinMissingLongArrayResultsTest.java | 6 +- .../jdbc/thin/JdbcThinNoDefaultSchemaTest.java | 5 - .../thin/JdbcThinPreparedStatementSelfTest.java | 5 - .../jdbc/thin/JdbcThinResultSetSelfTest.java | 5 - .../jdbc/thin/JdbcThinSchemaCaseTest.java | 5 - .../thin/JdbcThinSelectAfterAlterTable.java | 5 - .../jdbc/thin/JdbcThinStatementSelfTest.java | 5 - .../thin/JdbcThinStreamingAbstractSelfTest.java | 505 ++ .../JdbcThinStreamingNotOrderedSelfTest.java | 38 + .../thin/JdbcThinStreamingOrderedSelfTest.java | 39 + .../jdbc/thin/JdbcThinStreamingSelfTest.java | 486 -- .../PdsWithTtlCompatibilityTest.java | 191 + .../FoldersReuseCompatibilityTest.java | 2 +- .../IgniteCompatibilityBasicTestSuite.java | 3 + .../org/apache/ignite/IgniteDataStreamer.java | 23 +- .../apache/ignite/IgniteSystemProperties.java | 15 + .../configuration/DataRegionConfiguration.java | 10 +- .../configuration/DataStorageConfiguration.java | 32 +- .../configuration/FileSystemConfiguration.java | 2 +- .../configuration/MemoryConfiguration.java | 10 +- .../MemoryPolicyConfiguration.java | 8 +- .../failure/StopNodeOrHaltFailureHandler.java | 18 + .../apache/ignite/internal/GridDiagnostic.java | 2 +- .../apache/ignite/internal/IgniteKernal.java | 38 +- .../internal/commandline/CommandHandler.java | 80 +- .../internal/jdbc/thin/JdbcThinConnection.java | 312 +- .../internal/jdbc/thin/JdbcThinTcpIo.java | 92 +- .../mem/file/MappedFileMemoryProvider.java | 8 + .../mem/unsafe/UnsafeMemoryProvider.java | 8 + .../ignite/internal/pagemem/PageIdUtils.java | 5 +- .../pagemem/impl/PageMemoryNoStoreImpl.java | 5 +- .../internal/pagemem/wal/record/WALRecord.java | 5 +- .../delta/MetaPageUpdateLastAllocatedIndex.java | 6 +- .../wal/record/delta/RotatedIdPartRecord.java | 66 + .../processors/cache/CacheGroupContext.java | 16 +- .../processors/cache/GridCacheMapEntry.java | 41 +- .../GridCachePartitionExchangeManager.java | 115 +- .../cache/IgniteCacheOffheapManager.java | 21 +- .../cache/IgniteCacheOffheapManagerImpl.java | 128 +- .../cache/WalStateNodeLeaveExchangeTask.java | 2 +- .../distributed/dht/GridDhtLocalPartition.java | 209 +- .../dht/GridDhtPartitionsStateValidator.java | 1 + .../dht/atomic/GridNearAtomicUpdateFuture.java | 6 +- .../GridDhtPartitionsExchangeFuture.java | 22 +- .../cache/persistence/DataStructure.java | 34 +- .../GridCacheDatabaseSharedManager.java | 401 +- .../persistence/GridCacheOffheapManager.java | 441 +- .../IgniteCacheDatabaseSharedManager.java | 2 +- .../cache/persistence/file/FilePageStore.java | 43 +- .../persistence/file/FilePageStoreManager.java | 12 + .../persistence/freelist/AbstractFreeList.java | 104 +- .../cache/persistence/freelist/PagesList.java | 60 +- .../UpgradePendingTreeToPerPartitionTask.java | 380 + .../cache/persistence/tree/BPlusTree.java | 29 +- .../cache/persistence/tree/io/PageIO.java | 46 +- .../tree/io/PagePartitionMetaIO.java | 35 +- .../tree/io/PagePartitionMetaIOV2.java | 90 + .../tree/reuse/LongListReuseBag.java | 46 + .../wal/AbstractWalRecordsIterator.java | 11 +- .../wal/FileWriteAheadLogManager.java | 92 +- .../wal/FsyncModeFileWriteAheadLogManager.java | 92 +- .../SingleSegmentLogicalRecordsIterator.java | 7 +- .../persistence/wal/record/RecordTypes.java | 1 + .../wal/serializer/RecordDataV1Serializer.java | 24 + .../wal/serializer/RecordDataV2Serializer.java | 2 +- .../wal/serializer/RecordV1Serializer.java | 61 + .../wal/serializer/SegmentHeader.java | 58 + .../continuous/CacheContinuousQueryManager.java | 3 +- .../cache/transactions/IgniteTxManager.java | 15 +- .../odbc/ClientListenerNioListener.java | 23 +- .../odbc/jdbc/JdbcBatchExecuteRequest.java | 27 + .../odbc/jdbc/JdbcBatchExecuteResult.java | 26 +- .../odbc/jdbc/JdbcConnectionContext.java | 34 +- .../jdbc/JdbcOrderedBatchExecuteRequest.java | 85 + .../jdbc/JdbcOrderedBatchExecuteResult.java | 75 + .../processors/odbc/jdbc/JdbcRequest.java | 8 + .../odbc/jdbc/JdbcRequestHandler.java | 119 +- .../odbc/jdbc/JdbcResponseSender.java | 31 + .../processors/odbc/jdbc/JdbcResult.java | 8 + .../utils/PlatformConfigurationUtils.java | 47 + .../processors/query/SqlClientContext.java | 147 +- .../processors/service/GridServiceProxy.java | 22 +- .../apache/ignite/internal/sql/SqlKeyword.java | 3 + .../sql/command/SqlSetStreamingCommand.java | 19 + .../apache/ignite/internal/util/GridDebug.java | 56 +- .../ignite/internal/util/GridLogThrottle.java | 28 +- .../ignite/internal/util/GridLongList.java | 2 +- .../internal/util/GridPartitionStateMap.java | 2 +- .../apache/ignite/internal/util/typedef/X.java | 44 +- .../verify/ValidateIndexesPartitionResult.java | 31 +- .../verify/VisorValidateIndexesJobResult.java | 38 +- .../apache/ignite/logger/java/JavaLogger.java | 2 +- .../org/apache/ignite/mxbean/IgniteMXBean.java | 8 + .../ignite/spi/IgniteSpiMBeanAdapter.java | 2 +- .../cache/IgniteWarmupClosureSelfTest.java | 5 - .../affinity/AffinityClientNodeSelfTest.java | 5 - .../AffinityDistributionLoggingTest.java | 2 - .../local/LocalAffinityFunctionTest.java | 5 - .../RendezvousAffinityFunctionSelfTest.java | 5 - ...ndezvousAffinityFunctionSimpleBenchmark.java | 5 - ...cheStoreSessionListenerAbstractSelfTest.java | 5 - .../StopNodeOrHaltFailureHandlerTest.java | 5 - .../ignite/igfs/IgfsEventsAbstractSelfTest.java | 5 - .../igfs/IgfsFragmentizerAbstractSelfTest.java | 5 - .../ignite/internal/ClusterGroupSelfTest.java | 6 - .../ignite/internal/ClusterMetricsSelfTest.java | 5 - .../ignite/internal/GridAffinityMappedTest.java | 7 - .../internal/GridAffinityNoCacheSelfTest.java | 7 - ...chePartitionExchangeManagerHistSizeTest.java | 2 - .../internal/GridJobServicesAddNodeTest.java | 5 - .../GridKernalConcurrentAccessStopSelfTest.java | 6 - .../internal/GridListenActorSelfTest.java | 5 - .../internal/GridMultipleJobsSelfTest.java | 8 - .../ignite/internal/GridNodeFilterSelfTest.java | 10 - .../GridProjectionForCachesSelfTest.java | 5 - .../internal/GridRuntimeExceptionSelfTest.java | 5 - .../apache/ignite/internal/GridSelfTest.java | 5 - .../GridTaskExecutionContextSelfTest.java | 5 - .../internal/GridTaskExecutionSelfTest.java | 5 - .../internal/GridTaskJobRejectSelfTest.java | 6 - .../IgniteClientReconnectAbstractTest.java | 4 - .../IgniteClientReconnectCacheTest.java | 41 + .../IgniteComputeEmptyClusterGroupTest.java | 5 - ...eConcurrentEntryProcessorAccessStopTest.java | 7 - .../IgniteSlowClientDetectionSelfTest.java | 7 - .../internal/MemoryLeaksOnRestartNodeTest.java | 4 - .../ignite/internal/TaskNodeRestartTest.java | 7 - .../BinaryArrayIdentityResolverSelfTest.java | 7 - .../BinaryObjectBuilderAdditionalSelfTest.java | 5 - ...naryObjectBuilderDefaultMappersSelfTest.java | 5 - .../BinarySerialiedFieldComparatorSelfTest.java | 7 - .../internal/binary/BinaryTreeSelfTest.java | 2 - .../binary/GridBinaryAffinityKeySelfTest.java | 5 - .../managers/IgniteDiagnosticMessagesTest.java | 3 - .../communication/IgniteIoTestMessagesTest.java | 7 - .../IgniteVariousConnectionNumberTest.java | 7 - .../GridDeploymentMessageCountSelfTest.java | 7 - .../OptimizedMarshallerPooledSelfTest.java | 2 - .../pagemem/impl/PageIdUtilsSelfTest.java | 3 +- .../GridCacheTxLoadFromStoreOnLockSelfTest.java | 5 - .../GridAffinityProcessorAbstractSelfTest.java | 5 - .../cache/CacheAffinityCallSelfTest.java | 5 - .../cache/CacheConnectionLeakStoreTxTest.java | 5 - .../cache/CacheDataRegionConfigurationTest.java | 4 +- .../cache/CacheDeferredDeleteQueueTest.java | 4 - .../CacheDeferredDeleteSanitySelfTest.java | 5 - ...cheDhtLocalPartitionAfterRemoveSelfTest.java | 5 - .../cache/CacheEnumOperationsAbstractTest.java | 7 - ...CacheExchangeMessageDuplicatedStateTest.java | 7 - .../cache/CacheGroupMetricsMBeanTest.java | 5 - .../cache/CacheGroupsMetricsRebalanceTest.java | 53 +- ...erceptorPartitionCounterLocalSanityTest.java | 7 - ...torPartitionCounterRandomOperationsTest.java | 7 - .../cache/CacheKeepBinaryTransactionTest.java | 7 - .../cache/CacheMetricsEntitiesCountTest.java | 5 - .../CacheMetricsForClusterGroupSelfTest.java | 5 - .../cache/CacheOffheapMapEntrySelfTest.java | 5 - ...cheOptimisticTransactionsWithFilterTest.java | 7 - .../CachePutEventListenerErrorSelfTest.java | 5 - .../processors/cache/CachePutIfAbsentTest.java | 7 - .../CacheSerializableTransactionsTest.java | 7 - ...eUsageMultinodeDynamicStartAbstractTest.java | 7 - .../CacheTxNotAllowReadFromBackupTest.java | 7 - .../cache/CacheValidatorMetricsTest.java | 5 - .../processors/cache/CrossCacheLockTest.java | 7 - .../cache/CrossCacheTxRandomOperationsTest.java | 7 - .../EntryVersionConsistencyReadThroughTest.java | 7 - ...ridCacheAbstractByteArrayValuesSelfTest.java | 5 - .../GridCacheAbstractLocalStoreSelfTest.java | 5 - .../GridCacheAbstractRemoveFailureTest.java | 4 - .../cache/GridCacheAbstractSelfTest.java | 2 - .../cache/GridCacheAffinityMapperSelfTest.java | 5 - .../cache/GridCacheAffinityRoutingSelfTest.java | 10 - .../cache/GridCacheClearSelfTest.java | 5 - ...ridCacheConfigurationValidationSelfTest.java | 7 - .../cache/GridCacheEntryMemorySizeSelfTest.java | 5 - .../GridCacheMarshallingNodeJoinSelfTest.java | 5 - .../cache/GridCacheNestedTxAbstractTest.java | 5 - .../cache/GridCachePartitionedGetSelfTest.java | 5 - .../cache/GridCachePutAllFailoverSelfTest.java | 2 - ...ProjectionForCachesOnDaemonNodeSelfTest.java | 5 - .../cache/IgniteCacheAbstractTest.java | 2 - ...IgniteCacheBinaryEntryProcessorSelfTest.java | 7 - .../IgniteCacheBinaryObjectsScanSelfTest.java | 2 - .../cache/IgniteCacheDynamicStopSelfTest.java | 7 - ...niteCacheEntryListenerExpiredEventsTest.java | 7 - .../IgniteCacheEntryProcessorCallTest.java | 7 - ...niteCacheExpireAndUpdateConsistencyTest.java | 7 - .../cache/IgniteCacheIncrementTxTest.java | 7 - ...gniteCacheInvokeReadThroughAbstractTest.java | 7 - .../cache/IgniteCacheNearLockValueSelfTest.java | 7 - .../cache/IgniteCacheNoSyncForGetTest.java | 7 - .../cache/IgniteCacheObjectPutSelfTest.java | 5 - .../cache/IgniteCachePutAllRestartTest.java | 2 - .../IgniteCachePutStackOverflowSelfTest.java | 5 - .../cache/IgniteCacheSerializationSelfTest.java | 7 - .../cache/IgniteCacheStartStopLoadTest.java | 5 - .../cache/IgniteCacheStoreCollectionTest.java | 7 - ...IgniteClientCacheInitializationFailTest.java | 5 - .../IgniteClusterActivateDeactivateTest.java | 4 +- .../cache/IgniteDynamicCacheMultinodeTest.java | 7 - .../cache/IgniteDynamicCacheStartSelfTest.java | 7 - ...niteDynamicCacheStartStopConcurrentTest.java | 7 - .../cache/IgniteInternalCacheTypesTest.java | 7 - .../cache/IgniteOutOfMemoryPropagationTest.java | 9 +- .../IgniteStartCacheInTransactionSelfTest.java | 5 - .../cache/IgniteSystemCacheOnClientTest.java | 7 - .../processors/cache/IgniteTxAbstractTest.java | 7 - .../cache/IgniteTxConfigCacheSelfTest.java | 5 - .../cache/MemoryPolicyConfigValidationTest.java | 20 +- ...AffinityCoordinatorDynamicStartStopTest.java | 2 +- ...heapCacheMetricsForClusterGroupSelfTest.java | 5 - .../cache/WalModeChangeAbstractSelfTest.java | 7 - .../CacheKeepBinaryWithInterceptorTest.java | 7 - ...naryObjectsAbstractDataStreamerSelfTest.java | 5 - ...aryObjectsAbstractMultiThreadedSelfTest.java | 5 - .../GridCacheBinaryObjectsAbstractSelfTest.java | 5 - .../GridCacheBinaryStoreAbstractSelfTest.java | 5 - .../GridCacheSequenceApiSelfAbstractTest.java | 17 +- .../IgniteAtomicsAbstractTest.java | 4 - .../IgniteClientDataStructuresAbstractTest.java | 5 - .../IgniteCollectionAbstractTest.java | 5 - .../IgniteDataStructureWithJobTest.java | 7 - .../distributed/CacheAsyncOperationsTest.java | 7 - .../distributed/CacheBaselineTopologyTest.java | 8 +- .../distributed/CacheExchangeMergeTest.java | 27 +- .../CacheGetFutureHangsSelfTest.java | 7 - .../CacheGetInsideLockChangingTopologyTest.java | 4 - .../CacheLateAffinityAssignmentTest.java | 9 +- ...CacheLoadingConcurrentGridStartSelfTest.java | 22 +- .../cache/distributed/CacheStartOnJoinTest.java | 6 +- .../CacheTryLockMultithreadedTest.java | 7 - ...tractDistributedByteArrayValuesSelfTest.java | 2 - .../GridCacheAbstractJobExecutionTest.java | 5 - .../GridCacheAbstractNodeRestartSelfTest.java | 2 - .../GridCacheAbstractPrimarySyncSelfTest.java | 5 - .../GridCacheBasicOpAbstractTest.java | 2 - .../distributed/GridCacheLockAbstractTest.java | 5 - .../distributed/GridCacheMixedModeSelfTest.java | 5 - .../GridCacheMultiNodeAbstractTest.java | 2 - .../GridCacheMultiNodeLockAbstractTest.java | 2 - .../GridCacheNodeFailureAbstractTest.java | 2 - ...chePartitionedReloadAllAbstractSelfTest.java | 4 - ...GridCachePreloadRestartAbstractSelfTest.java | 5 - ...yMetadataUpdateChangingTopologySelfTest.java | 5 - ...niteBinaryMetadataUpdateNodeRestartTest.java | 4 - .../IgniteCacheClientReconnectTest.java | 7 - .../IgniteCacheConnectionRecoveryTest.java | 7 - .../distributed/IgniteCacheGetRestartTest.java | 4 - .../distributed/IgniteCacheManyClientsTest.java | 7 - .../IgniteCacheMessageRecoveryAbstractTest.java | 5 - ...eCacheMessageRecoveryIdleConnectionTest.java | 7 - .../IgniteCacheNearRestartRollbackSelfTest.java | 2 - .../distributed/IgniteCachePrimarySyncTest.java | 7 - .../IgniteCacheReadFromBackupTest.java | 7 - .../IgniteCacheSingleGetMessageTest.java | 7 - .../IgniteCrossCacheTxStoreSelfTest.java | 2 - .../IgniteOptimisticTxSuspendResumeTest.java | 4 +- .../IgniteTxCachePrimarySyncTest.java | 7 - ...teSynchronizationModesMultithreadedTest.java | 4 - .../IgniteTxTimeoutAbstractTest.java | 2 - ...heAbstractTransformWriteThroughSelfTest.java | 2 - .../dht/GridCacheDhtEntrySelfTest.java | 5 - ...GridCacheDhtEvictionNearReadersSelfTest.java | 7 - .../dht/GridCacheDhtMappingSelfTest.java | 7 - ...idCachePartitionsStateValidatorSelfTest.java | 10 +- .../IgniteCacheCommitDelayTxRecoveryTest.java | 7 - .../IgniteCacheCrossCacheTxFailoverTest.java | 7 - .../dht/IgniteCacheMultiTxLockSelfTest.java | 7 - .../IgniteCachePutRetryAbstractSelfTest.java | 4 - .../dht/IgniteCrossCacheTxSelfTest.java | 5 - .../near/GridCacheNearMultiGetSelfTest.java | 5 - .../near/GridCacheNearMultiNodeSelfTest.java | 7 - .../near/GridCacheNearTxForceKeyTest.java | 7 - .../GridCachePartitionedAffinitySelfTest.java | 5 - ...ePartitionedBasicStoreMultiNodeSelfTest.java | 2 - ...ePartitionedMultiThreadedPutGetSelfTest.java | 5 - .../near/NearCacheMultithreadedUpdateTest.java | 7 - .../near/NoneRebalanceModeSelfTest.java | 5 - .../rebalancing/CacheManualRebalancingTest.java | 5 - .../GridCacheRebalancingOrderingTest.java | 7 - .../GridCacheRebalancingSyncCheckDataTest.java | 8 - .../cache/eviction/EvictionAbstractTest.java | 2 - .../EvictionPolicyFactoryAbstractTest.java | 2 - .../PageEvictionMultinodeMixedRegionsTest.java | 4 +- .../paged/PageEvictionMultinodeTest.java | 5 - ...ageEvictionPagesRecyclingAndReusingTest.java | 153 + .../SortedEvictionPolicyPerformanceTest.java | 5 - .../GridCacheLocalByteArrayValuesSelfTest.java | 2 - ...eBaselineAffinityTopologyActivationTest.java | 2 +- .../IgniteDataStorageMetricsSelfTest.java | 4 +- ...tePdsBinaryMetadataOnClusterRestartTest.java | 2 +- ...gnitePdsCacheAssignmentNodeRestartsTest.java | 4 +- .../IgnitePdsCacheRebalancingAbstractTest.java | 4 +- .../IgnitePdsContinuousRestartTest.java | 89 +- .../IgnitePdsContinuousRestartTest2.java | 281 - ...dsContinuousRestartTestWithExpiryPolicy.java | 67 + .../IgnitePdsCorruptedCacheDataTest.java | 2 - .../IgnitePdsCorruptedIndexTest.java | 341 + .../persistence/IgnitePdsDynamicCacheTest.java | 2 +- .../IgnitePdsExchangeDuringCheckpointTest.java | 4 +- .../IgnitePdsMultiNodePutGetRestartTest.java | 2 +- .../persistence/IgnitePdsPageSizesTest.java | 2 +- .../IgnitePdsPartitionFilesDestroyTest.java | 472 + .../IgnitePdsPartitionFilesTruncateTest.java | 153 - ...gnitePdsRecoveryAfterFileCorruptionTest.java | 2 +- .../IgnitePdsRemoveDuringRebalancingTest.java | 2 +- .../IgnitePersistentStoreCacheGroupsTest.java | 2 +- ...lWalModeChangeDuringRebalancingSelfTest.java | 66 + .../MemoryPolicyInitializationTest.java | 4 +- .../PersistenceDirectoryWarningLoggingTest.java | 85 + .../IgniteBaselineAbstractFullApiSelfTest.java | 9 +- ...gingBaselineDownCachePutAllFailoverTest.java | 8 +- ...gingBaselineDownCacheRemoveFailoverTest.java | 8 +- ...angingBaselineUpCachePutAllFailoverTest.java | 8 +- ...angingBaselineUpCacheRemoveFailoverTest.java | 8 +- ...teStableBaselineCachePutAllFailoverTest.java | 8 +- ...teStableBaselineCacheRemoveFailoverTest.java | 8 +- .../db/IgnitePdsCacheRestoreTest.java | 4 +- .../db/IgnitePdsMultiNodePutGetRestartTest.java | 2 +- ...PdsPageEvictionDuringPartitionClearTest.java | 2 +- .../db/IgnitePdsPageEvictionTest.java | 2 +- ...tePdsRebalancingOnNotStableTopologyTest.java | 2 +- .../db/IgnitePdsTransactionsHangTest.java | 10 +- .../db/IgnitePdsWholeClusterRestartTest.java | 2 +- .../persistence/db/IgnitePdsWithTtlTest.java | 197 + ...faultPageSizeBackwardsCompatibilityTest.java | 2 +- ...nitePdsCacheDestroyDuringCheckpointTest.java | 4 - .../db/file/IgnitePdsCacheIntegrationTest.java | 2 +- .../file/IgnitePdsDiskErrorsRecoveringTest.java | 2 +- .../file/IgnitePdsNoActualWalHistoryTest.java | 2 +- .../db/file/IgnitePdsPageReplacementTest.java | 4 - .../file/IgnitePdsThreadInterruptionTest.java | 2 - .../IgniteUidAsConsistentIdMigrationTest.java | 2 +- ...alFlushBackgroundWithMmapBufferSelfTest.java | 28 + .../db/wal/IgniteWalFlushDefaultSelfTest.java | 35 - .../db/wal/IgniteWalFlushFsyncSelfTest.java | 35 + ...alFlushFsyncWithDedicatedWorkerSelfTest.java | 39 + ...niteWalFlushFsyncWithMmapBufferSelfTest.java | 28 + ...teWalFlushLogOnlyWithMmapBufferSelfTest.java | 28 + ...lFlushMultiNodeFailoverAbstractSelfTest.java | 56 +- .../wal/IgniteWalHistoryReservationsTest.java | 2 +- .../db/wal/IgniteWalRecoveryPPCTest.java | 8 +- .../IgniteWalRecoverySeveralRestartsTest.java | 2 +- .../db/wal/IgniteWalRecoveryTest.java | 4 +- .../db/wal/IgniteWalSerializerVersionTest.java | 2 +- .../persistence/db/wal/WalCompactionTest.java | 2 +- .../db/wal/WalRecoveryTxLogicalRecordsTest.java | 2 +- .../db/wal/reader/IgniteWalReaderTest.java | 48 +- .../pagemem/FillFactorMetricTest.java | 5 +- .../pagemem/PageMemoryNoStoreLeakTest.java | 82 + .../pagemem/PagesWriteThrottleSmokeTest.java | 4 +- .../IgniteChangeGlobalStateAbstractTest.java | 2 +- .../IgniteStandByClusterTest.java | 2 +- .../extended/GridActivateExtensionTest.java | 4 +- ...gniteAbstractStandByClientReconnectTest.java | 2 +- .../GridCacheQueryTransformerSelfTest.java | 5 - .../ScanQueryOffheapExpiryPolicySelfTest.java | 7 - .../continuous/CacheContinuousBatchAckTest.java | 7 - ...eContinuousQueryAsyncFilterListenerTest.java | 7 - ...CacheContinuousQueryCounterAbstractTest.java | 5 - ...acheContinuousQueryExecuteInPrimaryTest.java | 5 - ...ontinuousQueryOperationFromCallbackTest.java | 7 - .../CacheContinuousQueryOperationP2PTest.java | 7 - .../CacheContinuousQueryOrderingEventTest.java | 7 - ...acheContinuousQueryRandomOperationsTest.java | 7 - ...inuousWithTransformerReplicatedSelfTest.java | 2 - ...eEntryProcessorExternalizableFailedTest.java | 7 - .../CacheEntryProcessorNonSerializableTest.java | 7 - .../CacheKeepBinaryIterationTest.java | 7 - ...ridCacheContinuousQueryAbstractSelfTest.java | 5 - .../GridCacheContinuousQueryConcurrentTest.java | 7 - ...idCacheWriteBehindStoreAbstractSelfTest.java | 2 - ...BehindStorePartitionedMultiNodeSelfTest.java | 2 - .../IgniteCacheWriteBehindNoUpdateSelfTest.java | 5 - .../cache/transactions/TxDeadlockCauseTest.java | 9 +- .../TxDeadlockDetectionNoHangsTest.java | 2 - .../transactions/TxDeadlockDetectionTest.java | 7 - .../TxDeadlockDetectionUnmasrhalErrorsTest.java | 7 - .../transactions/TxMultiCacheAsyncOpsTest.java | 7 - .../TxOptimisticDeadlockDetectionTest.java | 7 - .../TxOptimisticOnPartitionExchangeTest.java | 7 - ...simisticDeadlockDetectionCrossCacheTest.java | 7 - .../TxPessimisticDeadlockDetectionTest.java | 7 - .../TxRollbackAsyncWithPersistenceTest.java | 2 - ...ollbackOnTimeoutNoDeadlockDetectionTest.java | 2 - .../closure/GridClosureProcessorRemoteTest.java | 5 - .../closure/GridClosureProcessorSelfTest.java | 5 - .../closure/GridClosureSerializationTest.java | 7 - .../cluster/GridUpdateNotifierSelfTest.java | 2 - ...ComputeJobExecutionErrorToLogManualTest.java | 5 - .../database/IgniteDbDynamicCacheSelfTest.java | 2 +- .../IgniteDbPutGetWithCacheStoreTest.java | 2 +- .../database/IndexStorageSelfTest.java | 2 +- .../database/SwapPathConstructionSelfTest.java | 2 +- .../DataStreamerUpdateAfterLoadTest.java | 7 - .../igfs/IgfsAbstractBaseSelfTest.java | 2 +- .../processors/igfs/IgfsCacheSelfTest.java | 5 - .../igfs/IgfsDataManagerSelfTest.java | 5 - ...fsLocalSecondaryFileSystemProxySelfTest.java | 2 +- .../igfs/IgfsMetaManagerSelfTest.java | 5 - .../processors/igfs/IgfsMetricsSelfTest.java | 5 - .../processors/igfs/IgfsProcessorSelfTest.java | 5 - .../processors/igfs/IgfsSizeSelfTest.java | 2 +- .../processors/igfs/IgfsStreamsSelfTest.java | 5 - .../processors/igfs/IgfsTaskSelfTest.java | 5 - .../IgfsAbstractRecordResolverSelfTest.java | 5 - .../handlers/log/GridLogCommandHandlerTest.java | 2 - .../query/GridQueryCommandHandlerTest.java | 7 - .../service/ClosureServiceClientsNodesTest.java | 5 - ...ServiceDeploymentCompoundFutureSelfTest.java | 5 - ...rviceDeploymentExceptionPropagationTest.java | 7 - .../GridServiceProcessorAbstractSelfTest.java | 9 +- ...ServiceProcessorMultiNodeConfigSelfTest.java | 13 +- ...GridServiceProxyClientReconnectSelfTest.java | 62 +- ...gniteServiceConfigVariationsFullApiTest.java | 22 +- .../IgniteServiceDynamicCachesSelfTest.java | 5 - .../ServicePredicateAccessCacheTest.java | 7 - .../sql/SqlParserSetStreamingSelfTest.java | 39 +- .../offheap/GridOffHeapMapAbstractSelfTest.java | 2 +- ...idOffHeapPartitionedMapAbstractSelfTest.java | 2 +- .../org/apache/ignite/lang/GridXSelfTest.java | 13 + .../loadtests/GridCacheMultiNodeLoadTest.java | 2 - .../communication/GridIoManagerBenchmark0.java | 5 - .../direct/stealing/GridStealingLoadTest.java | 5 - .../GridP2PContinuousDeploymentSelfTest.java | 5 - .../GridSessionWaitAttributeSelfTest.java | 6 - ...redFsCheckpointSpiMultiThreadedSelfTest.java | 2 - ...CommunicationRecoveryAckClosureSelfTest.java | 26 +- .../tcp/TcpCommunicationSpiDropNodesTest.java | 2 - .../TcpCommunicationSpiFaultyClientTest.java | 2 - .../discovery/AuthenticationRestartTest.java | 2 - .../tcp/TcpDiscoveryConcurrentStartTest.java | 5 - .../stream/socket/SocketStreamerSelfTest.java | 5 - .../ignite/testframework/GridTestUtils.java | 11 +- .../testframework/junits/GridAbstractTest.java | 10 +- .../common/GridRollingRestartAbstractTest.java | 4 - .../junits/multijvm/IgniteProcessProxy.java | 23 +- .../IgniteCacheEvictionSelfTestSuite.java | 3 + .../ignite/testsuites/IgnitePdsTestSuite.java | 6 + .../ignite/testsuites/IgnitePdsTestSuite2.java | 29 +- .../ignite/util/GridCommandHandlerTest.java | 152 +- .../apache/ignite/util/GridLogThrottleTest.java | 128 +- .../util/GridTopologyHeapSizeSelfTest.java | 4 +- .../util/mbeans/GridMBeanBaselineTest.java | 112 + .../util/mbeans/GridMBeanDisableSelfTest.java | 2 - modules/flink/pom.xml | 12 + modules/flume/pom.xml | 6 + .../ignite/stream/flume/IgniteSinkTest.java | 5 - modules/gce/pom.xml | 7 + ...pDiscoveryGoogleStorageIpFinderSelfTest.java | 2 - modules/hadoop/pom.xml | 32 + .../hadoop/impl/HadoopAbstractSelfTest.java | 2 - .../hadoop/impl/HadoopCommandLineTest.java | 2 - .../hadoop/impl/HadoopJobTrackerSelfTest.java | 7 - .../hadoop/impl/HadoopPopularWordsTest.java | 2 +- .../impl/HadoopTaskExecutionSelfTest.java | 7 - .../client/HadoopClientProtocolSelfTest.java | 7 - .../impl/igfs/Hadoop1OverIgfsProxyTest.java | 2 +- .../hadoop/impl/igfs/IgfsEventsTestSuite.java | 2 - .../igfs/IgfsNearOnlyMultiNodeSelfTest.java | 8 +- ...niteHadoopFileSystemClientBasedOpenTest.java | 7 - .../HibernateL2CacheConfigurationSelfTest.java | 5 - .../hibernate/HibernateL2CacheMultiJvmTest.java | 7 - .../hibernate/HibernateL2CacheSelfTest.java | 5 - .../HibernateL2CacheStrategySelfTest.java | 5 - .../HibernateL2CacheTransactionalSelfTest.java | 2 - .../HibernateL2CacheConfigurationSelfTest.java | 5 - .../hibernate/HibernateL2CacheMultiJvmTest.java | 7 - .../hibernate/HibernateL2CacheSelfTest.java | 5 - .../HibernateL2CacheStrategySelfTest.java | 5 - .../HibernateL2CacheTransactionalSelfTest.java | 2 - .../processors/query/h2/IgniteH2Indexing.java | 2 +- .../query/h2/database/InlineIndexHelper.java | 1 - .../visor/verify/ValidateIndexesClosure.java | 264 +- .../visor/verify/VisorValidateIndexesTask.java | 6 +- .../CacheBinaryKeyConcurrentQueryTest.java | 7 - .../cache/CacheIteratorScanQueryTest.java | 5 - .../CacheOffheapBatchIndexingBaseTest.java | 5 - .../CacheOperationsWithExpirationTest.java | 7 - .../cache/CacheQueryBuildValueTest.java | 7 - .../CacheRandomOperationsMultithreadedTest.java | 7 - .../cache/CacheSqlQueryValueCopySelfTest.java | 7 - .../ClientReconnectAfterClusterRestartTest.java | 4 +- .../cache/GridCacheFullTextQuerySelfTest.java | 5 - .../cache/GridCacheOffHeapSelfTest.java | 2 - .../GridCacheOffheapIndexEntryEvictTest.java | 5 - .../cache/GridCacheOffheapIndexGetSelfTest.java | 5 - .../IgniteBinaryObjectFieldsQuerySelfTest.java | 2 - .../IgniteBinaryObjectQueryArgumentsTest.java | 7 - .../IgniteCacheAbstractFieldsQuerySelfTest.java | 2 - ...niteCacheAbstractInsertSqlQuerySelfTest.java | 5 - .../cache/IgniteCacheAbstractQuerySelfTest.java | 4 - .../IgniteCacheAbstractSqlDmlQuerySelfTest.java | 5 - .../IgniteCacheCollocatedQuerySelfTest.java | 5 - .../IgniteCacheCrossCacheJoinRandomTest.java | 2 - ...acheDistributedJoinCollocatedAndNotTest.java | 7 - ...acheDistributedJoinCustomAffinityMapper.java | 7 - .../IgniteCacheDistributedJoinNoIndexTest.java | 7 - ...ributedJoinPartitionedAndReplicatedTest.java | 7 - ...CacheDistributedJoinQueryConditionsTest.java | 7 - .../cache/IgniteCacheDistributedJoinTest.java | 1 - ...cheDuplicateEntityConfigurationSelfTest.java | 5 - .../IgniteCacheFieldsQueryNoDataSelfTest.java | 5 - ...PartitionedAndReplicatedCollocationTest.java | 7 - ...teCacheJoinPartitionedAndReplicatedTest.java | 7 - ...IgniteCacheJoinQueryWithAffinityKeyTest.java | 7 - .../cache/IgniteCacheLargeResultSelfTest.java | 5 - .../IgniteCacheObjectKeyIndexingSelfTest.java | 2 - .../cache/IgniteCacheOffheapIndexScanTest.java | 5 - ...hePartitionedQueryMultiThreadedSelfTest.java | 5 - ...IgniteCachePrimitiveFieldsQuerySelfTest.java | 5 - .../cache/IgniteCacheQueriesLoadTest1.java | 7 - .../IgniteCacheQueryH2IndexingLeakTest.java | 2 - .../IgniteCacheQueryMultiThreadedSelfTest.java | 5 - ...gniteCacheSqlQueryMultiThreadedSelfTest.java | 7 - ...CheckClusterStateBeforeExecuteQueryTest.java | 2 +- .../cache/IgniteErrorOnRebalanceTest.java | 2 +- ...leNodeWithIndexingPutGetPersistenceTest.java | 2 - ...stributedPartitionQueryAbstractSelfTest.java | 9 +- ...butedQueryStopOnCancelOrTimeoutSelfTest.java | 7 - ...cheQueryAbstractDistributedJoinSelfTest.java | 5 - .../IgniteCacheQueryNoRebalanceSelfTest.java | 7 - .../near/IgniteCacheQueryNodeFailTest.java | 7 - .../IgniteCacheQueryNodeRestartSelfTest2.java | 7 +- .../index/DuplicateKeyValueClassesSelfTest.java | 5 - .../cache/index/DynamicColumnsAbstractTest.java | 2 +- .../index/DynamicIndexAbstractSelfTest.java | 9 +- .../cache/index/H2ConnectionLeaksSelfTest.java | 5 - .../H2DynamicColumnsAbstractBasicSelfTest.java | 7 - .../index/H2DynamicIndexAbstractSelfTest.java | 7 - .../index/H2DynamicIndexingComplexTest.java | 7 - .../cache/index/H2DynamicTableSelfTest.java | 7 - .../index/OptimizedMarshallerIndexNameTest.java | 9 +- .../index/QueryEntityValidationSelfTest.java | 5 - ...eCacheLocalQueryCancelOrTimeoutSelfTest.java | 7 - ...eDbSingleNodeWithIndexingWalRestoreTest.java | 2 +- .../IgnitePersistentStoreSchemaLoadTest.java | 2 +- ...ckPartitionOnAffinityRunAtomicCacheTest.java | 6 +- ...neLockPartitionOnAffinityRunTxCacheTest.java | 6 +- ...ngBaselineCacheQueryNodeRestartSelfTest.java | 4 +- ...StableBaselineBinObjFieldsQuerySelfTest.java | 2 +- ...eBaselineCacheQueryNodeRestartsSelfTest.java | 4 +- .../query/IgniteSqlDefaultValueTest.java | 7 - .../query/IgniteSqlDistributedJoinSelfTest.java | 5 - .../query/IgniteSqlNotNullConstraintTest.java | 95 +- .../processors/query/IgniteSqlRoutingTest.java | 7 - .../query/IgniteSqlSegmentedIndexSelfTest.java | 5 - ...teSqlSkipReducerOnUpdateDmlFlagSelfTest.java | 8 - ...IgniteSqlSkipReducerOnUpdateDmlSelfTest.java | 4 - .../query/IgniteSqlSplitterSelfTest.java | 5 - .../query/h2/IgniteSqlBigIntegerKeyTest.java | 5 - .../h2/sql/AbstractH2CompareQueryTest.java | 4 - .../query/h2/sql/GridQueryParsingTest.java | 4 - .../IgniteCacheWithIndexingTestSuite.java | 3 + .../IgnitePdsWithIndexingCoreTestSuite.java | 5 + .../util/GridCommandHandlerIndexingTest.java | 203 +- .../cache/CacheJndiTmFactorySelfTest.java | 2 - .../GridJtaTransactionManagerSelfTest.java | 4 - .../kafka/connect/IgniteSinkConnectorTest.java | 5 - .../connect/IgniteSourceConnectorTest.java | 5 - .../java/org/apache/ignite/ml/math/Algebra.java | 590 -- .../java/org/apache/ignite/ml/math/Blas.java | 8 +- .../org/apache/ignite/ml/math/Constants.java | 59 - .../ignite/ml/math/IdentityValueMapper.java | 56 - .../org/apache/ignite/ml/math/MathUtils.java | 32 - .../java/org/apache/ignite/ml/math/Matrix.java | 15 - .../org/apache/ignite/ml/math/VectorUtils.java | 3 +- .../decompositions/CholeskyDecomposition.java | 309 - .../decompositions/DecompositionSupport.java | 105 - .../math/decompositions/EigenDecomposition.java | 936 -- .../ml/math/decompositions/LUDecomposition.java | 383 - .../ml/math/decompositions/QRDSolver.java | 197 - .../ml/math/decompositions/QRDecomposition.java | 212 - .../SingularValueDecomposition.java | 623 -- .../ml/math/decompositions/package-info.java | 22 - .../ignite/ml/math/distributed/CacheUtils.java | 734 -- .../ml/math/distributed/DistributedStorage.java | 35 - .../ml/math/distributed/MatrixKeyMapper.java | 33 - .../ignite/ml/math/distributed/ValueMapper.java | 37 - .../ml/math/distributed/VectorKeyMapper.java | 32 - .../distributed/keys/DataStructureCacheKey.java | 35 - .../math/distributed/keys/MatrixBlockKey.java | 38 - .../math/distributed/keys/RowColMatrixKey.java | 30 - .../math/distributed/keys/VectorBlockKey.java | 34 - .../distributed/keys/impl/MatrixBlockKey.java | 166 - .../distributed/keys/impl/SparseMatrixKey.java | 119 - .../distributed/keys/impl/VectorBlockKey.java | 152 - .../distributed/keys/impl/package-info.java | 22 - .../ml/math/distributed/keys/package-info.java | 22 - .../ml/math/distributed/package-info.java | 22 - .../ml/math/impls/matrix/AbstractMatrix.java | 24 - .../ml/math/impls/matrix/CacheMatrix.java | 158 - .../ml/math/impls/matrix/DiagonalMatrix.java | 101 - .../ml/math/impls/matrix/FunctionMatrix.java | 95 - .../ml/math/impls/matrix/MatrixBlockEntry.java | 50 - .../ml/math/impls/matrix/PivotedMatrixView.java | 241 - .../ml/math/impls/matrix/RandomMatrix.java | 97 - .../matrix/SparseBlockDistributedMatrix.java | 314 - .../impls/matrix/SparseDistributedMatrix.java | 290 - .../math/impls/matrix/TransposedMatrixView.java | 84 - .../storage/matrix/BlockMatrixStorage.java | 434 - .../storage/matrix/BlockVectorStorage.java | 368 - .../storage/matrix/CacheMatrixStorage.java | 196 - .../storage/matrix/DiagonalMatrixStorage.java | 158 - .../storage/matrix/FunctionMatrixStorage.java | 190 - .../storage/matrix/PivotedMatrixStorage.java | 266 - .../storage/matrix/RandomMatrixStorage.java | 187 - .../matrix/SparseDistributedMatrixStorage.java | 330 - .../storage/vector/CacheVectorStorage.java | 175 - .../storage/vector/ConstantVectorStorage.java | 134 - .../storage/vector/FunctionVectorStorage.java | 143 - .../storage/vector/PivotedVectorStorage.java | 176 - .../storage/vector/RandomVectorStorage.java | 152 - .../SingleElementVectorDelegateStorage.java | 145 - .../vector/SingleElementVectorStorage.java | 145 - .../vector/SparseDistributedVectorStorage.java | 281 - .../impls/vector/AbstractReadOnlyVector.java | 131 - .../ml/math/impls/vector/CacheVector.java | 140 - .../ml/math/impls/vector/ConstantVector.java | 84 - .../ml/math/impls/vector/FunctionVector.java | 112 - .../ml/math/impls/vector/PivotedVectorView.java | 163 - .../ml/math/impls/vector/RandomVector.java | 130 - .../math/impls/vector/SingleElementVector.java | 102 - .../impls/vector/SingleElementVectorView.java | 97 - .../vector/SparseBlockDistributedVector.java | 135 - .../impls/vector/SparseDistributedVector.java | 147 - .../ml/math/impls/vector/VectorBlockEntry.java | 47 - .../apache/ignite/ml/math/util/MatrixUtil.java | 17 +- .../ignite/ml/nn/ReplicatedVectorMatrix.java | 14 - .../LogRegressionMultiClassModel.java | 96 + .../LogRegressionMultiClassTrainer.java | 222 + .../logistic/multiclass/package-info.java | 22 + .../ignite/ml/structures/LabeledDataset.java | 4 - .../ignite/ml/structures/package-info.java | 2 +- .../ml/structures/partition/package-info.java | 22 + .../structures/preprocessing/package-info.java | 2 +- .../impl/cache/CacheBasedDatasetTest.java | 2 +- .../ml/math/MathImplDistributedTestSuite.java | 47 - .../ignite/ml/math/MathImplLocalTestSuite.java | 39 - .../ignite/ml/math/MathImplMainTestSuite.java | 1 - .../CholeskyDecompositionTest.java | 160 - .../decompositions/EigenDecompositionTest.java | 193 - .../decompositions/LUDecompositionTest.java | 252 - .../ml/math/decompositions/QRDSolverTest.java | 87 - .../decompositions/QRDecompositionTest.java | 141 - .../SingularValueDecompositionTest.java | 122 - .../ml/math/impls/matrix/CacheMatrixTest.java | 371 - .../math/impls/matrix/DiagonalMatrixTest.java | 209 - .../matrix/FunctionMatrixConstructorTest.java | 113 - .../math/impls/matrix/MatrixAttributeTest.java | 14 +- .../matrix/MatrixImplementationFixtures.java | 135 +- .../impls/matrix/MatrixImplementationsTest.java | 196 +- .../impls/matrix/MatrixKeyMapperForTests.java | 74 - .../PivotedMatrixViewConstructorTest.java | 129 - .../matrix/RandomMatrixConstructorTest.java | 71 - .../SparseDistributedBlockMatrixTest.java | 408 - .../matrix/SparseDistributedMatrixTest.java | 316 - .../impls/matrix/TransposedMatrixViewTest.java | 87 - .../SparseDistributedMatrixStorageTest.java | 126 - .../SparseDistributedVectorStorageTest.java | 123 - .../ml/math/impls/vector/CacheVectorTest.java | 430 - .../vector/ConstantVectorConstructorTest.java | 52 - .../vector/FunctionVectorConstructorTest.java | 121 - .../PivotedVectorViewConstructorTest.java | 211 - .../vector/RandomVectorConstructorTest.java | 145 - .../SingleElementVectorConstructorTest.java | 159 - .../SingleElementVectorViewConstructorTest.java | 137 - .../SparseBlockDistributedVectorTest.java | 186 - .../vector/SparseDistributedVectorTest.java | 191 - .../math/impls/vector/VectorAttributesTest.java | 25 +- .../vector/VectorImplementationsFixtures.java | 203 - .../impls/vector/VectorImplementationsTest.java | 30 +- .../math/impls/vector/VectorIterableTest.java | 376 - .../math/impls/vector/VectorToMatrixTest.java | 50 +- .../ml/regressions/RegressionsTestSuite.java | 6 +- .../linear/LinearRegressionModelTest.java | 17 + .../logistic/LogRegMultiClassTrainerTest.java | 98 + .../Apache.Ignite.Core.Tests.csproj | 3 + .../ApiParity/IgniteConfigurationParityTest.cs | 3 +- .../Cache/Store/CacheStoreTest.cs | 44 +- .../Config/full-config.xml | 3 +- .../Config/ignite-halthandler-dotnet-cfg.xml | 54 + .../Config/ignite-stophandler-dotnet-cfg.xml | 54 + .../FailureHandlerTest.cs | 133 + .../IgniteConfigurationSerializerTest.cs | 15 +- .../TestUtils.Windows.cs | 2 + .../Apache.Ignite.Core.csproj | 5 +- .../Failure/IFailureHandler.cs | 33 + .../Failure/NoOpFailureHandler.cs | 28 + .../Failure/StopNodeFailureHandler.cs | 28 + .../Failure/StopNodeOrHaltFailureHandler.cs | 97 + .../Apache.Ignite.Core/IgniteConfiguration.cs | 86 +- .../IgniteConfigurationSection.xsd | 21 +- .../schedule/GridScheduleSelfTest.java | 7 - modules/spark-2.10/pom.xml | 10 + modules/spark/pom.xml | 20 + .../spark/JavaStandaloneIgniteRDDSelfTest.java | 6 - .../IgniteSpringDataCrudSelfTest.java | 2 - .../IgniteSpringDataQueriesSelfTest.java | 2 - .../IgniteSpringDataCrudSelfTest.java | 2 - .../IgniteSpringDataQueriesSelfTest.java | 3 +- .../GridSpringCacheManagerMultiJvmSelfTest.java | 5 - .../spring/GridSpringCacheManagerSelfTest.java | 5 - .../ignite/cache/spring/SpringCacheTest.java | 2 - .../resource/GridLoggerInjectionSelfTest.java | 7 - .../resource/GridServiceInjectionSelfTest.java | 7 - .../GridSpringResourceInjectionSelfTest.java | 5 - .../GridSpringTransactionManagerSelfTest.java | 5 - modules/sqlline/bin/sqlline.bat | 8 +- .../util/nodestart/StartNodeCallableImpl.java | 4 +- .../testcafe/fixtures/auth/forgot-password.js | 3 +- .../fixtures/auth/signup-validation-local.js | 52 + .../e2e/testcafe/fixtures/auth/signup.js | 15 +- .../e2e/testcafe/page-models/pageSignin.js | 32 + modules/web-console/frontend/app/app.js | 10 +- .../app/components/bs-select-menu/controller.js | 5 +- .../app/components/bs-select-menu/index.js | 2 + .../app/components/bs-select-menu/index.spec.js | 67 + .../app/components/bs-select-menu/style.scss | 18 +- .../app/components/bs-select-menu/template.pug | 3 +- .../transcludeToBody.directive.js | 50 + .../components/cluster-selector/template.pug | 4 +- .../frontend/app/components/form-field/index.js | 23 + .../form-field/showValidationError.directive.js | 47 + .../list-editable-transclude/directive.js | 2 +- .../page-configure/components/pcValidation.js | 22 - .../page-forgot-password/controller.js | 22 +- .../page-forgot-password/template.pug | 3 +- .../app/components/page-landing/template.pug | 20 +- .../components/queries-notebook/controller.js | 2 +- .../queries-notebook/template.tpl.pug | 6 +- .../app/components/page-signin/controller.js | 24 +- .../app/components/page-signin/template.pug | 5 +- .../app/components/page-signup/controller.js | 21 +- .../app/components/page-signup/template.pug | 1 - .../app/components/panel-collapsible/style.scss | 3 +- .../components/password-visibility/style.scss | 4 + .../ui-grid-column-resizer/directive.js | 29 + .../components/ui-grid-column-resizer/index.js | 24 + .../controllers/reset-password.controller.js | 50 - .../helpers/jade/form/form-field-feedback.pug | 2 +- .../helpers/jade/form/form-field-password.pug | 2 +- .../app/helpers/jade/form/form-field-text.pug | 2 +- .../app/modules/branding/header-logo.pug | 2 +- .../app/modules/branding/powered-by-apache.pug | 2 +- .../frontend/app/modules/user/Auth.service.js | 10 +- .../app/primitives/form-field/dropdown.pug | 1 + .../app/primitives/form-field/index.scss | 28 + .../app/primitives/ui-grid-header/index.scss | 4 + .../frontend/app/primitives/ui-grid/index.scss | 4 + .../frontend/app/services/FormUtils.service.js | 6 +- .../app/services/LegacyUtils.service.js | 2 +- .../frontend/app/services/Messages.service.js | 8 +- modules/web-console/frontend/app/vendor.js | 1 - modules/web-console/frontend/package-lock.json | 8166 ++++++++++-------- modules/web-console/frontend/package.json | 3 +- .../frontend/public/images/[email protected] | Bin 8558 -> 0 bytes .../frontend/views/templates/confirm.tpl.pug | 4 +- .../frontend/webpack/webpack.common.js | 7 +- .../frontend/webpack/webpack.dev.babel.js | 5 +- .../config/ignite-localhost-config.xml | 2 - .../benchmark-jdbc-thin-streaming.properties | 132 + .../apache/ignite/yardstick/ml/DataChanger.java | 65 - .../IgniteCholeskyDecompositionBenchmark.java | 69 - .../IgniteEigenDecompositionBenchmark.java | 69 - .../IgniteLUDecompositionBenchmark.java | 75 - ...niteSingularValueDecompositionBenchmark.java | 59 - .../ml/decomposition/package-info.java | 22 - .../math/IgniteAbstractMatrixMulBenchmark.java | 120 - ...niteDenseLocalOffHeapMatrixMulBenchmark.java | 32 - ...gniteDenseLocalOnHeapMatrixMulBenchmark.java | 32 - ...parseBlockDistributedMatrixMulBenchmark.java | 32 - ...iteSparseDistributedMatrixMul2Benchmark.java | 74 - ...niteSparseDistributedMatrixMulBenchmark.java | 49 - .../IgniteSparseLocalMatrixMulBenchmark.java | 32 - .../ignite/yardstick/ml/math/package-info.java | 22 - .../ignite/yardstick/ml/package-info.java | 22 - .../ignite/yardstick/upload/StreamerParams.java | 7 +- .../upload/UploadBenchmarkArguments.java | 19 +- .../yardstick/upload/model/QueryFactory.java | 2 + modules/yarn/pom.xml | 20 + .../stream/zeromq/IgniteZeroMqStreamer.java | 43 +- .../stream/zeromq/IgniteZeroMqStreamerTest.java | 29 +- .../zk/internal/ZkDiscoveryEventsData.java | 11 + .../zk/internal/ZookeeperDiscoveryImpl.java | 2 +- .../ignite/spi/discovery/zk/package-info.java | 21 + .../ZookeeperDiscoverySpiAbstractTestSuite.java | 7 +- .../zk/internal/ZookeeperClientTest.java | 3 +- .../zk/internal/ZookeeperDiscoverySpiTest.java | 40 +- packaging/package.sh | 9 +- packaging/rpm/apache-ignite.spec | 11 + parent/pom.xml | 7 +- pom.xml | 2 +- 877 files changed, 15252 insertions(+), 27114 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/fbf252ba/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java ---------------------------------------------------------------------- diff --cc modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java index 3e0b1de,fe0ce2b..4cda72a --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java @@@ -43,8 -43,8 +43,9 @@@ import org.apache.ignite.IgniteSystemPr import org.apache.ignite.cache.CacheMode; import org.apache.ignite.cache.CacheRebalanceMode; import org.apache.ignite.cluster.ClusterNode; +import org.apache.ignite.configuration.CacheConfiguration; import org.apache.ignite.configuration.IgniteConfiguration; + import org.apache.ignite.configuration.CacheConfiguration; import org.apache.ignite.configuration.NearCacheConfiguration; import org.apache.ignite.events.DiscoveryEvent; import org.apache.ignite.internal.IgniteClientDisconnectedCheckedException; http://git-wip-us.apache.org/repos/asf/ignite/blob/fbf252ba/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/ClientReconnectAfterClusterRestartTest.java ---------------------------------------------------------------------- diff --cc modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/ClientReconnectAfterClusterRestartTest.java index 8c0cb1a,9012161..85bad0f --- a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/ClientReconnectAfterClusterRestartTest.java +++ b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/ClientReconnectAfterClusterRestartTest.java @@@ -117,7 -116,9 +116,8 @@@ public class ClientReconnectAfterCluste public void testReconnectClient() throws Exception { try { startGrid(SERVER_ID); + Ignite client = startGrid(CLIENT_ID); - checkTopology(2); IgniteCache<Long, BinaryObject> cache = client.getOrCreateCache(CACHE_PARAMS).withKeepBinary();
