Repository: ignite Updated Branches: refs/heads/ignite-7251 b42a5c8e1 -> 5b2d5c56a
Merge remote-tracking branch 'origin/master' Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/ffe0f710 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/ffe0f710 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/ffe0f710 Branch: refs/heads/ignite-7251 Commit: ffe0f7108df4cdc50f308151420f20cf993965ec Parents: 0a4f818 c1b2c6b Author: Denis Magda <dma...@gridgain.com> Authored: Wed Sep 12 14:58:55 2018 -0400 Committer: Denis Magda <dma...@gridgain.com> Committed: Wed Sep 12 14:58:55 2018 -0400 ---------------------------------------------------------------------- examples/DEVNOTES.txt | 11 + .../clustering/KMeansClusterizationExample.java | 7 +- .../AlgorithmSpecificDatasetExample.java | 5 +- .../ml/dataset/LocalDatasetExample.java | 69 - .../change/OptimizeMakeChangeGAExample.java | 14 +- .../OptimizeMakeChangeTerminateCriteria.java | 42 +- .../genetic/helloworld/HelloWorldGAExample.java | 13 +- .../helloworld/HelloWorldTerminateCriteria.java | 34 +- .../ml/genetic/knapsack/KnapsackGAExample.java | 12 +- .../knapsack/KnapsackTerminateCriteria.java | 47 +- .../ml/genetic/movie/MovieGAExample.java | 6 +- .../genetic/movie/MovieTerminateCriteria.java | 42 +- .../ml/knn/ANNClassificationExample.java | 3 +- .../ml/knn/KNNClassificationExample.java | 3 +- .../examples/ml/knn/KNNRegressionExample.java | 3 +- .../examples/ml/nn/MLPTrainerExample.java | 3 +- .../ml/preprocessing/MaxAbsScalerExample.java | 84 + .../ml/preprocessing/MinMaxScalerExample.java | 8 +- .../LinearRegressionLSQRTrainerExample.java | 3 +- ...ssionLSQRTrainerWithMinMaxScalerExample.java | 3 +- .../LinearRegressionSGDTrainerExample.java | 5 +- .../LogisticRegressionSGDTrainerExample.java | 6 +- .../ml/selection/cv/CrossValidationExample.java | 6 +- .../GDBOnTreesClassificationTrainerExample.java | 11 +- .../GDBOnTreesRegressionTrainerExample.java | 5 +- .../RandomForestClassificationExample.java | 413 +- .../RandomForestRegressionExample.java | 1066 ++--- .../jmh/sequence/JmhSequenceBenchmark.java | 215 + .../benchmarks/jmh/tree/BPlusTreeBenchmark.java | 2 +- .../internal/jdbc2/JdbcStreamingSelfTest.java | 3 +- .../JettyRestProcessorAbstractSelfTest.java | 2 +- .../suite/IgniteJdbcDriverMvccTestSuite.java | 47 + .../jdbc/suite/IgniteJdbcDriverTestSuite.java | 15 +- .../jdbc/thin/JdbcThinAbstractSelfTest.java | 4 +- .../JdbcThinConnectionMvccEnabledSelfTest.java | 378 ++ .../jdbc/thin/JdbcThinConnectionSelfTest.java | 188 +- .../jdbc/thin/JdbcThinMetadataSelfTest.java | 49 +- .../thin/JdbcThinStreamingAbstractSelfTest.java | 19 +- .../JdbcThinStreamingNotOrderedSelfTest.java | 2 +- .../thin/JdbcThinStreamingOrderedSelfTest.java | 2 +- ...ThinTransactionsAbstractComplexSelfTest.java | 1058 +++++ ...sactionsClientAutoCommitComplexSelfTest.java | 33 + ...ctionsClientNoAutoCommitComplexSelfTest.java | 33 + .../jdbc/thin/JdbcThinTransactionsSelfTest.java | 447 +++ ...sactionsServerAutoCommitComplexSelfTest.java | 33 + ...ctionsServerNoAutoCommitComplexSelfTest.java | 33 + ...ThinTransactionsWithMvccEnabledSelfTest.java | 447 +++ modules/clients/src/test/keystore/ca/node01.jks | Bin 3719 -> 3719 bytes modules/clients/src/test/keystore/ca/node02.jks | Bin 4598 -> 4599 bytes modules/clients/src/test/keystore/ca/node03.jks | Bin 3754 -> 3753 bytes .../clients/src/test/keystore/ca/oneindex.txt | 2 +- .../clients/src/test/keystore/ca/twoindex.txt | 4 +- .../TcpDiscoveryCloudIpFinderSelfTest.java | 2 + .../ignite/codegen/MessageCodeGenerator.java | 4 +- .../main/java/org/apache/ignite/IgniteLock.java | 4 +- .../apache/ignite/IgniteSystemProperties.java | 14 + .../ignite/binary/BinaryBasicIdMapper.java | 4 +- .../org/apache/ignite/cache/QueryEntity.java | 91 +- .../cache/eviction/fifo/FifoEvictionPolicy.java | 2 +- .../ignite/cache/query/ContinuousQuery.java | 6 +- .../query/ContinuousQueryWithTransformer.java | 8 +- .../configuration/CacheConfiguration.java | 1 + .../configuration/DataStorageConfiguration.java | 42 + .../configuration/IgniteConfiguration.java | 84 +- .../configuration/TransactionConfiguration.java | 20 + .../apache/ignite/internal/GridComponent.java | 5 +- .../ignite/internal/GridKernalContext.java | 6 + .../ignite/internal/GridKernalContextImpl.java | 14 +- .../org/apache/ignite/internal/GridTopic.java | 10 +- .../apache/ignite/internal/IgniteKernal.java | 28 +- .../ignite/internal/IgniteNodeAttributes.java | 6 +- .../org/apache/ignite/internal/IgnitionEx.java | 8 +- .../ignite/internal/TransactionsMXBeanImpl.java | 20 +- .../internal/binary/BinaryObjectExImpl.java | 2 +- .../internal/binary/BinaryReaderExImpl.java | 2 +- .../ignite/internal/binary/BinaryTypeImpl.java | 2 +- .../internal/binary/BinaryWriterExImpl.java | 4 +- .../binary/builder/BinaryBuilderReader.java | 2 +- .../streams/BinaryOffheapOutputStream.java | 2 +- .../client/impl/GridClientNodeImpl.java | 2 +- .../client/ssl/GridSslBasicContextFactory.java | 2 +- .../internal/client/thin/ClientChannel.java | 5 + .../internal/client/thin/ClientUtils.java | 62 +- .../internal/client/thin/ReliableChannel.java | 7 + .../internal/client/thin/TcpClientCache.java | 7 +- .../internal/client/thin/TcpClientChannel.java | 18 +- .../internal/client/thin/TcpIgniteClient.java | 17 +- .../internal/cluster/ClusterGroupAdapter.java | 2 +- .../internal/cluster/IgniteClusterImpl.java | 2 +- .../internal/commandline/CommandHandler.java | 24 +- .../internal/direct/DirectMessageReader.java | 4 +- .../internal/direct/DirectMessageWriter.java | 2 +- .../stream/v1/DirectByteBufferStreamImplV1.java | 2 +- .../jdbc/thin/ConnectionProperties.java | 10 + .../jdbc/thin/ConnectionPropertiesImpl.java | 37 +- .../internal/jdbc/thin/JdbcThinConnection.java | 33 +- .../jdbc/thin/JdbcThinDatabaseMetadata.java | 11 +- .../internal/jdbc/thin/JdbcThinStatement.java | 7 +- .../internal/jdbc/thin/JdbcThinTcpIo.java | 32 +- .../managers/communication/GridIoManager.java | 16 + .../communication/GridIoMessageFactory.java | 140 + .../internal/managers/discovery/DiscoCache.java | 17 +- .../discovery/GridDiscoveryManager.java | 24 +- .../eventstorage/GridEventStorageManager.java | 2 +- .../failover/GridFailoverContextImpl.java | 2 +- .../optimized/OptimizedClassDescriptor.java | 87 +- .../pagemem/impl/PageMemoryNoStoreImpl.java | 10 +- .../pagemem/store/IgnitePageStoreManager.java | 13 + .../pagemem/wal/IgniteWriteAheadLogManager.java | 5 + .../internal/pagemem/wal/record/WALRecord.java | 11 +- .../delta/DataPageMvccMarkUpdatedRecord.java | 103 + .../DataPageMvccUpdateNewTxStateHintRecord.java | 79 + .../DataPageMvccUpdateTxStateHintRecord.java | 79 + .../processors/affinity/AffinityAssignment.java | 15 +- .../affinity/GridAffinityAssignment.java | 40 +- .../affinity/GridAffinityAssignmentCache.java | 21 +- .../affinity/GridAffinityProcessor.java | 2 +- .../processors/affinity/GridAffinityUtils.java | 2 +- .../affinity/HistoryAffinityAssignment.java | 11 +- .../cache/CacheAffinitySharedManager.java | 33 +- .../processors/cache/CacheEntryImpl.java | 2 +- .../processors/cache/CacheEntryImpl0.java | 2 +- .../processors/cache/CacheEntryImplEx.java | 4 +- .../cache/CacheEntryInfoCollection.java | 12 + .../processors/cache/CacheGroupContext.java | 34 + .../cache/CacheGroupMetricsMXBeanImpl.java | 12 +- .../cache/CacheInvokeDirectResult.java | 21 +- .../processors/cache/CacheLazyEntry.java | 2 +- .../processors/cache/CacheObjectAdapter.java | 2 +- .../cache/CacheObjectByteArrayImpl.java | 2 +- .../processors/cache/CacheOperationContext.java | 2 +- .../processors/cache/ClusterCachesInfo.java | 17 +- .../processors/cache/ExchangeContext.java | 43 +- .../cache/GatewayProtectedCacheProxy.java | 3 + .../processors/cache/GridCacheAdapter.java | 99 +- .../cache/GridCacheAffinityManager.java | 5 + .../processors/cache/GridCacheContext.java | 7 + .../processors/cache/GridCacheEntryEx.java | 135 +- .../processors/cache/GridCacheEntryInfo.java | 6 +- .../processors/cache/GridCacheIoManager.java | 4 +- .../processors/cache/GridCacheMapEntry.java | 1203 +++++- .../cache/GridCacheMvccEntryInfo.java | 257 ++ .../processors/cache/GridCacheOperation.java | 2 +- .../GridCachePartitionExchangeManager.java | 76 +- .../processors/cache/GridCacheProcessor.java | 100 +- .../processors/cache/GridCacheProxyImpl.java | 24 - .../processors/cache/GridCacheReturn.java | 17 +- .../cache/GridCacheSharedContext.java | 11 +- .../cache/GridCacheUpdateTxResult.java | 98 +- .../processors/cache/GridCacheUtilityKey.java | 2 +- .../processors/cache/GridCacheUtils.java | 113 +- .../cache/IgniteCacheOffheapManager.java | 489 ++- .../cache/IgniteCacheOffheapManagerImpl.java | 1724 +++++++- .../processors/cache/IgniteCacheProxyImpl.java | 10 +- .../processors/cache/IgniteInternalCache.java | 14 - .../processors/cache/IncompleteCacheObject.java | 2 +- .../processors/cache/KeyCacheObject.java | 2 +- .../binary/CacheObjectBinaryProcessor.java | 2 +- .../binary/CacheObjectBinaryProcessorImpl.java | 9 +- .../cache/binary/IgniteBinaryImpl.java | 2 +- .../distributed/GridCacheTxFinishSync.java | 2 +- .../distributed/GridCacheTxRecoveryFuture.java | 11 + .../distributed/GridDistributedTxMapping.java | 17 + .../GridDistributedTxPrepareRequest.java | 22 + .../GridDistributedTxRemoteAdapter.java | 72 +- .../distributed/dht/CompoundLockFuture.java | 112 + .../cache/distributed/dht/DhtLockFuture.java | 30 + .../cache/distributed/dht/ExceptionAware.java | 30 + .../dht/GridClientPartitionTopology.java | 7 + .../distributed/dht/GridDhtCacheAdapter.java | 62 +- .../distributed/dht/GridDhtCacheEntry.java | 10 +- .../cache/distributed/dht/GridDhtGetFuture.java | 15 +- .../distributed/dht/GridDhtGetSingleFuture.java | 15 +- .../distributed/dht/GridDhtLocalPartition.java | 23 + .../distributed/dht/GridDhtLockFuture.java | 17 +- .../dht/GridDhtPartitionTopology.java | 4 + .../dht/GridDhtPartitionTopologyImpl.java | 11 + .../dht/GridDhtPartitionsStateValidator.java | 11 +- .../dht/GridDhtTransactionalCacheAdapter.java | 467 ++- .../dht/GridDhtTxAbstractEnlistFuture.java | 1139 ++++++ .../distributed/dht/GridDhtTxFinishFuture.java | 111 +- .../distributed/dht/GridDhtTxFinishRequest.java | 67 +- .../cache/distributed/dht/GridDhtTxLocal.java | 11 +- .../distributed/dht/GridDhtTxLocalAdapter.java | 96 +- .../distributed/dht/GridDhtTxPrepareFuture.java | 106 +- .../dht/GridDhtTxPrepareRequest.java | 31 +- .../dht/GridDhtTxQueryEnlistFuture.java | 140 + .../dht/GridDhtTxQueryEnlistRequest.java | 404 ++ .../dht/GridDhtTxQueryEnlistResponse.java | 205 + .../dht/GridDhtTxQueryFirstEnlistRequest.java | 370 ++ .../dht/GridDhtTxQueryResultsEnlistFuture.java | 130 + .../cache/distributed/dht/GridDhtTxRemote.java | 134 +- .../dht/GridPartitionedGetFuture.java | 90 +- .../dht/GridPartitionedSingleGetFuture.java | 22 +- .../dht/NearTxQueryEnlistResultHandler.java | 169 + .../dht/PartitionUpdateCounters.java | 123 + .../dht/atomic/GridDhtAtomicCache.java | 25 +- .../GridNearAtomicSingleUpdateFuture.java | 2 +- .../dht/atomic/GridNearAtomicUpdateFuture.java | 2 +- .../dht/colocated/GridDhtColocatedCache.java | 30 +- .../colocated/GridDhtColocatedLockFuture.java | 423 +- .../CachePartitionPartialCountersMap.java | 2 +- .../dht/preloader/GridDhtForceKeysFuture.java | 43 +- .../dht/preloader/GridDhtPartitionDemander.java | 45 +- .../dht/preloader/GridDhtPartitionSupplier.java | 113 +- .../GridDhtPartitionSupplyMessage.java | 6 +- .../GridDhtPartitionSupplyMessageV2.java | 153 + .../GridDhtPartitionsExchangeFuture.java | 58 +- .../GridDhtPartitionsSingleMessage.java | 44 +- .../dht/preloader/GridDhtPreloader.java | 43 +- .../near/AckCoordinatorOnRollback.java | 54 + .../distributed/near/GridNearCacheAdapter.java | 10 - .../distributed/near/GridNearGetFuture.java | 20 +- .../distributed/near/GridNearGetRequest.java | 33 +- .../distributed/near/GridNearLockMapping.java | 2 +- ...arOptimisticSerializableTxPrepareFuture.java | 94 +- .../near/GridNearOptimisticTxPrepareFuture.java | 89 +- ...ridNearOptimisticTxPrepareFutureAdapter.java | 178 +- .../GridNearPessimisticTxPrepareFuture.java | 195 +- .../near/GridNearSingleGetRequest.java | 33 +- .../near/GridNearTxAbstractEnlistFuture.java | 499 +++ .../near/GridNearTxFastFinishFuture.java | 13 +- .../near/GridNearTxFinishAndAckFuture.java | 144 + .../near/GridNearTxFinishFuture.java | 84 +- .../near/GridNearTxFinishRequest.java | 30 +- .../cache/distributed/near/GridNearTxLocal.java | 407 +- .../near/GridNearTxPrepareFutureAdapter.java | 12 +- .../near/GridNearTxPrepareRequest.java | 17 + .../near/GridNearTxPrepareResponse.java | 34 +- .../near/GridNearTxQueryEnlistFuture.java | 382 ++ .../near/GridNearTxQueryEnlistRequest.java | 616 +++ .../near/GridNearTxQueryEnlistResponse.java | 298 ++ .../GridNearTxQueryResultsEnlistFuture.java | 670 ++++ .../GridNearTxQueryResultsEnlistRequest.java | 578 +++ .../GridNearTxQueryResultsEnlistResponse.java | 202 + .../distributed/near/GridNearTxRemote.java | 9 +- .../near/GridNearTxSelectForUpdateFuture.java | 462 +++ .../distributed/near/IgniteTxMappingsImpl.java | 2 +- .../near/IgniteTxMappingsSingleImpl.java | 2 +- .../distributed/near/NearTxFinishFuture.java | 21 +- .../near/TxTopologyVersionFuture.java | 155 + .../processors/cache/dr/GridCacheDrManager.java | 31 + .../cache/dr/GridOsCacheDrManager.java | 13 + .../local/atomic/GridLocalAtomicCache.java | 15 +- .../processors/cache/mvcc/MvccCoordinator.java | 104 + .../cache/mvcc/MvccDiscoveryData.java | 52 + .../cache/mvcc/MvccEmptyLongList.java | 53 + .../processors/cache/mvcc/MvccFuture.java | 66 + .../processors/cache/mvcc/MvccLongList.java | 29 + .../mvcc/MvccPreviousCoordinatorQueries.java | 222 ++ .../processors/cache/mvcc/MvccProcessor.java | 250 ++ .../cache/mvcc/MvccProcessorImpl.java | 2200 +++++++++++ .../processors/cache/mvcc/MvccQueryTracker.java | 102 + .../cache/mvcc/MvccQueryTrackerImpl.java | 348 ++ .../processors/cache/mvcc/MvccSnapshot.java | 48 + .../cache/mvcc/MvccSnapshotFuture.java | 43 + .../mvcc/MvccSnapshotResponseListener.java | 35 + .../cache/mvcc/MvccSnapshotWithoutTxs.java | 204 + .../cache/mvcc/MvccUpdateVersionAware.java | 76 + .../processors/cache/mvcc/MvccUtils.java | 879 +++++ .../processors/cache/mvcc/MvccVersion.java | 48 + .../processors/cache/mvcc/MvccVersionAware.java | 76 + .../processors/cache/mvcc/MvccVersionImpl.java | 193 + .../cache/mvcc/NoOpMvccProcessor.java | 215 + .../cache/mvcc/StaticMvccQueryTracker.java | 96 + .../processors/cache/mvcc/VacuumMetrics.java | 102 + .../cache/mvcc/VacuumMetricsReducer.java | 49 + .../processors/cache/mvcc/VacuumTask.java | 63 + .../cache/mvcc/msg/MvccAckRequestQueryCntr.java | 130 + .../cache/mvcc/msg/MvccAckRequestQueryId.java | 130 + .../cache/mvcc/msg/MvccAckRequestTx.java | 210 + .../mvcc/msg/MvccAckRequestTxAndQueryCntr.java | 123 + .../mvcc/msg/MvccAckRequestTxAndQueryId.java | 122 + .../mvcc/msg/MvccActiveQueriesMessage.java | 132 + .../cache/mvcc/msg/MvccFutureResponse.java | 130 + .../processors/cache/mvcc/msg/MvccMessage.java | 35 + .../mvcc/msg/MvccQuerySnapshotRequest.java | 130 + .../cache/mvcc/msg/MvccSnapshotResponse.java | 320 ++ .../cache/mvcc/msg/MvccTxSnapshotRequest.java | 128 + .../cache/mvcc/msg/MvccWaitTxsRequest.java | 159 + .../processors/cache/mvcc/txlog/TxKey.java | 76 + .../processors/cache/mvcc/txlog/TxLog.java | 584 +++ .../processors/cache/mvcc/txlog/TxLogIO.java | 73 + .../cache/mvcc/txlog/TxLogInnerIO.java | 105 + .../cache/mvcc/txlog/TxLogLeafIO.java | 105 + .../processors/cache/mvcc/txlog/TxLogTree.java | 62 + .../processors/cache/mvcc/txlog/TxRow.java | 44 + .../processors/cache/mvcc/txlog/TxState.java | 37 + .../cache/persistence/AllocatedPageTracker.java | 5 +- .../cache/persistence/CacheDataRow.java | 7 +- .../cache/persistence/CacheDataRowAdapter.java | 114 +- .../cache/persistence/CacheSearchRow.java | 3 +- .../persistence/DataRegionMetricsImpl.java | 20 +- .../persistence/DatabaseLifecycleListener.java | 54 + .../GridCacheDatabaseSharedManager.java | 73 +- .../persistence/GridCacheOffheapManager.java | 327 +- .../IgniteCacheDatabaseSharedManager.java | 66 +- .../cache/persistence/IndexStorageImpl.java | 2 +- .../processors/cache/persistence/RowStore.java | 28 +- .../processors/cache/persistence/Storable.java | 14 + .../checkpoint/CheckpointHistory.java | 102 +- .../cache/persistence/file/FilePageStore.java | 29 +- .../persistence/file/FilePageStoreManager.java | 35 +- .../persistence/freelist/AbstractFreeList.java | 20 +- .../cache/persistence/freelist/FreeList.java | 12 + .../metastorage/MetastorageDataRow.java | 13 +- .../metastorage/MetastorageTree.java | 2 +- .../persistence/pagemem/PageMemoryImpl.java | 7 +- .../cache/persistence/tree/BPlusTree.java | 1221 ++++-- .../persistence/tree/io/AbstractDataPageIO.java | 35 +- .../cache/persistence/tree/io/DataPageIO.java | 484 ++- .../cache/persistence/tree/io/IOVersions.java | 7 + .../cache/persistence/tree/io/PageIO.java | 133 +- .../persistence/tree/io/SimpleDataPageIO.java | 6 - .../wal/AbstractWalRecordsIterator.java | 139 +- .../cache/persistence/wal/FileDescriptor.java | 137 + .../wal/FileWriteAheadLogManager.java | 230 +- .../wal/FsyncModeFileWriteAheadLogManager.java | 234 +- .../SingleSegmentLogicalRecordsIterator.java | 4 +- .../wal/reader/IgniteWalIteratorFactory.java | 2 +- .../wal/reader/StandaloneGridKernalContext.java | 6 + .../reader/StandaloneWalRecordsIterator.java | 35 +- .../persistence/wal/record/RecordTypes.java | 3 + .../wal/serializer/RecordDataV1Serializer.java | 82 + .../query/GridCacheDistributedQueryManager.java | 14 +- .../cache/query/GridCacheQueryAdapter.java | 174 +- .../cache/query/GridCacheQueryManager.java | 30 +- .../cache/query/GridCacheQueryRequest.java | 31 +- .../query/GridCacheQueryResponseEntry.java | 5 +- .../cache/query/IgniteQueryErrorCode.java | 28 + .../cache/query/QueryEntityTypeDescriptor.java | 39 +- .../cache/query/SqlFieldsQueryEx.java | 39 + .../continuous/CacheContinuousQueryHandler.java | 2 +- .../continuous/CacheContinuousQueryManager.java | 49 +- .../ratemetrics/HitRateMetricsSandbox.java | 2 +- .../store/GridCacheStoreManagerAdapter.java | 2 +- .../cache/transactions/IgniteInternalTx.java | 24 +- .../transactions/IgniteTransactionsImpl.java | 4 +- .../cache/transactions/IgniteTxAdapter.java | 204 +- .../cache/transactions/IgniteTxHandler.java | 106 +- .../IgniteTxImplicitSingleStateImpl.java | 18 +- .../transactions/IgniteTxLocalAdapter.java | 277 +- .../cache/transactions/IgniteTxLocalEx.java | 8 + .../cache/transactions/IgniteTxLocalState.java | 16 + .../transactions/IgniteTxLocalStateAdapter.java | 26 + .../cache/transactions/IgniteTxManager.java | 13 + .../IgniteTxRemoteSingleStateImpl.java | 7 +- .../IgniteTxRemoteStateAdapter.java | 21 +- .../transactions/IgniteTxRemoteStateImpl.java | 12 +- .../cache/transactions/IgniteTxState.java | 16 +- .../cache/transactions/IgniteTxStateImpl.java | 28 +- .../cache/transactions/TxCounters.java | 82 + .../cache/tree/AbstractDataInnerIO.java | 112 +- .../cache/tree/AbstractDataLeafIO.java | 125 +- .../cache/tree/CacheDataRowStore.java | 35 +- .../processors/cache/tree/CacheDataTree.java | 82 +- .../cache/tree/CacheIdAwareDataInnerIO.java | 8 +- .../cache/tree/CacheIdAwareDataLeafIO.java | 8 +- .../processors/cache/tree/DataInnerIO.java | 11 - .../processors/cache/tree/DataLeafIO.java | 11 - .../internal/processors/cache/tree/DataRow.java | 28 +- .../cache/tree/PendingEntriesTree.java | 2 +- .../processors/cache/tree/PendingRow.java | 3 +- .../processors/cache/tree/RowLinkIO.java | 67 +- .../processors/cache/tree/SearchRow.java | 31 + .../mvcc/data/MvccCacheIdAwareDataInnerIO.java | 68 + .../mvcc/data/MvccCacheIdAwareDataLeafIO.java | 89 + .../cache/tree/mvcc/data/MvccDataInnerIO.java | 71 + .../cache/tree/mvcc/data/MvccDataLeafIO.java | 89 + .../cache/tree/mvcc/data/MvccDataRow.java | 263 ++ .../cache/tree/mvcc/data/MvccUpdateDataRow.java | 485 +++ .../tree/mvcc/data/MvccUpdateDataRowNative.java | 240 ++ .../cache/tree/mvcc/data/MvccUpdateResult.java | 43 + .../cache/tree/mvcc/data/ResultType.java | 34 + .../mvcc/search/MvccFirstRowTreeClosure.java | 76 + .../mvcc/search/MvccLinkAwareSearchRow.java | 48 + .../tree/mvcc/search/MvccMaxSearchRow.java | 55 + .../tree/mvcc/search/MvccMinSearchRow.java | 55 + .../cache/tree/mvcc/search/MvccSearchRow.java | 70 + .../tree/mvcc/search/MvccSnapshotSearchRow.java | 113 + .../cache/tree/mvcc/search/MvccTreeClosure.java | 29 + .../cluster/GridClusterStateProcessor.java | 2 + .../datastreamer/DataStreamerImpl.java | 4 +- .../datastructures/DataStructuresProcessor.java | 5 +- .../datastructures/GridCacheQueueAdapter.java | 4 +- .../datastructures/GridSetQueryPredicate.java | 4 +- .../processors/hadoop/HadoopFileBlock.java | 2 +- .../internal/processors/hadoop/HadoopJobEx.java | 2 +- .../processors/igfs/IgfsDirectoryInfo.java | 28 +- .../internal/processors/igfs/IgfsFileInfo.java | 24 +- .../processors/igfs/IgfsFileWorkerBatch.java | 2 +- .../igfs/data/IgfsDataPutProcessor.java | 2 +- .../internal/processors/odbc/SqlStateCode.java | 3 + .../odbc/jdbc/JdbcBatchExecuteRequest.java | 55 +- .../odbc/jdbc/JdbcBatchExecuteResult.java | 11 +- .../odbc/jdbc/JdbcBulkLoadAckResult.java | 11 +- .../odbc/jdbc/JdbcBulkLoadBatchRequest.java | 11 +- .../processors/odbc/jdbc/JdbcColumnMeta.java | 7 +- .../processors/odbc/jdbc/JdbcColumnMetaV2.java | 11 +- .../processors/odbc/jdbc/JdbcColumnMetaV3.java | 11 +- .../processors/odbc/jdbc/JdbcColumnMetaV4.java | 11 +- .../odbc/jdbc/JdbcConnectionContext.java | 55 +- .../processors/odbc/jdbc/JdbcIndexMeta.java | 7 +- .../processors/odbc/jdbc/JdbcMessageParser.java | 13 +- .../odbc/jdbc/JdbcMetaColumnsRequest.java | 11 +- .../odbc/jdbc/JdbcMetaColumnsResult.java | 15 +- .../odbc/jdbc/JdbcMetaIndexesRequest.java | 11 +- .../odbc/jdbc/JdbcMetaIndexesResult.java | 15 +- .../odbc/jdbc/JdbcMetaParamsRequest.java | 11 +- .../odbc/jdbc/JdbcMetaParamsResult.java | 15 +- .../odbc/jdbc/JdbcMetaPrimaryKeysRequest.java | 11 +- .../odbc/jdbc/JdbcMetaPrimaryKeysResult.java | 15 +- .../odbc/jdbc/JdbcMetaSchemasRequest.java | 11 +- .../odbc/jdbc/JdbcMetaSchemasResult.java | 11 +- .../odbc/jdbc/JdbcMetaTablesRequest.java | 11 +- .../odbc/jdbc/JdbcMetaTablesResult.java | 15 +- .../jdbc/JdbcOrderedBatchExecuteRequest.java | 14 +- .../jdbc/JdbcOrderedBatchExecuteResult.java | 11 +- .../processors/odbc/jdbc/JdbcParameterMeta.java | 7 +- .../odbc/jdbc/JdbcPrimaryKeyMeta.java | 7 +- .../processors/odbc/jdbc/JdbcQuery.java | 7 +- .../odbc/jdbc/JdbcQueryCloseRequest.java | 11 +- ...dbcQueryExecuteMultipleStatementsResult.java | 15 +- .../odbc/jdbc/JdbcQueryExecuteRequest.java | 36 +- .../odbc/jdbc/JdbcQueryExecuteResult.java | 11 +- .../odbc/jdbc/JdbcQueryFetchRequest.java | 11 +- .../odbc/jdbc/JdbcQueryFetchResult.java | 11 +- .../odbc/jdbc/JdbcQueryMetadataRequest.java | 11 +- .../odbc/jdbc/JdbcQueryMetadataResult.java | 15 +- .../odbc/jdbc/JdbcRawBinarylizable.java | 8 +- .../processors/odbc/jdbc/JdbcRequest.java | 13 +- .../odbc/jdbc/JdbcRequestHandler.java | 72 +- .../odbc/jdbc/JdbcRequestHandlerWorker.java | 131 + .../processors/odbc/jdbc/JdbcResponse.java | 11 +- .../processors/odbc/jdbc/JdbcResult.java | 12 +- .../processors/odbc/jdbc/JdbcResultInfo.java | 7 +- .../processors/odbc/jdbc/JdbcTableMeta.java | 7 +- .../processors/odbc/odbc/OdbcColumnMeta.java | 37 +- .../odbc/odbc/OdbcConnectionContext.java | 25 +- .../processors/odbc/odbc/OdbcMessageParser.java | 16 +- .../odbc/odbc/OdbcQueryExecuteBatchRequest.java | 15 +- .../odbc/odbc/OdbcQueryExecuteRequest.java | 14 +- .../processors/odbc/odbc/OdbcQueryResults.java | 10 +- .../odbc/odbc/OdbcRequestHandler.java | 91 +- .../odbc/odbc/OdbcRequestHandlerWorker.java | 131 + .../processors/odbc/odbc/OdbcResultSet.java | 16 +- .../platform/PlatformProcessorImpl.java | 9 +- .../platform/cache/PlatformCache.java | 4 +- .../client/ClientConnectionContext.java | 17 +- .../platform/client/ClientMessageParser.java | 16 +- .../ClientCacheConfigurationSerializer.java | 11 +- ...ientCacheCreateWithConfigurationRequest.java | 6 +- .../ClientCacheGetConfigurationRequest.java | 11 +- .../ClientCacheGetConfigurationResponse.java | 11 +- ...acheGetOrCreateWithConfigurationRequest.java | 6 +- .../client/cache/ClientCacheRequest.java | 2 +- .../PlatformDotNetConfigurationClosure.java | 4 +- .../memory/PlatformOutputStreamImpl.java | 2 +- .../utils/PlatformConfigurationUtils.java | 79 +- .../processors/query/EnlistOperation.java | 91 + .../query/GridQueryFieldMetadata.java | 16 +- .../processors/query/GridQueryIndexing.java | 41 +- .../processors/query/GridQueryProcessor.java | 89 +- .../internal/processors/query/NestedTxMode.java | 60 + .../processors/query/QueryEntityEx.java | 2 +- .../internal/processors/query/QueryField.java | 2 + .../query/QueryTypeDescriptorImpl.java | 71 +- .../internal/processors/query/QueryUtils.java | 103 +- .../processors/query/UpdateSourceIterator.java | 89 + .../twostep/messages/GridQueryFailResponse.java | 2 +- .../messages/GridQueryNextPageResponse.java | 65 +- .../query/schema/SchemaOperationWorker.java | 2 +- .../processors/rest/GridRestProcessor.java | 31 +- .../message/GridClientNodeMetricsBean.java | 4 +- .../rest/protocols/tcp/GridTcpRestParser.java | 2 +- .../service/GridServiceProcessor.java | 5 +- .../GridInternalSubscriptionProcessor.java | 18 + .../processors/task/GridTaskProcessor.java | 8 +- .../processors/task/GridTaskWorker.java | 72 +- .../timeout/GridTimeoutProcessor.java | 94 + .../apache/ignite/internal/sql/SqlKeyword.java | 20 + .../apache/ignite/internal/sql/SqlLexer.java | 10 +- .../internal/sql/SqlLexerLookAheadToken.java | 2 +- .../apache/ignite/internal/sql/SqlParser.java | 85 +- .../ignite/internal/sql/SqlParserUtils.java | 14 + .../sql/command/SqlBeginTransactionCommand.java | 46 + .../command/SqlCommitTransactionCommand.java | 46 + .../command/SqlRollbackTransactionCommand.java | 46 + .../IgniteTxMvccVersionCheckedException.java | 47 + .../util/GridConcurrentSkipListSet.java | 2 +- .../ignite/internal/util/GridStringBuilder.java | 2 +- .../internal/util/IgniteExceptionRegistry.java | 2 +- .../ignite/internal/util/IgniteUtils.java | 16 + .../internal/util/SerializableTransient.java | 10 +- .../ignite/internal/util/StripedExecutor.java | 6 +- .../internal/util/TransientSerializable.java | 55 + .../util/future/GridCompoundFuture.java | 4 +- .../util/lang/gridfunc/ContainsPredicate.java | 2 +- .../lang/gridfunc/NotContainsPredicate.java | 2 +- .../internal/util/nio/GridNioFilterAdapter.java | 2 +- .../internal/util/nio/GridNioFilterChain.java | 2 +- .../ignite/internal/util/nio/GridNioServer.java | 12 +- .../unsafe/GridUnsafePartitionedMap.java | 4 +- .../util/snaptree/CopyOnWriteManager.java | 390 -- .../ignite/internal/util/snaptree/Epoch.java | 131 - .../internal/util/snaptree/EpochNode.java | 433 -- .../internal/util/snaptree/SnapTreeMap.java | 2917 -------------- .../internal/util/snaptree/package-info.java | 22 - .../visor/node/VisorSuppressedError.java | 2 +- .../ignite/internal/visor/tx/VisorTxInfo.java | 58 +- .../ignite/internal/visor/tx/VisorTxTask.java | 20 +- .../ignite/lang/IgniteProductVersion.java | 2 +- .../ignite/marshaller/MarshallerUtils.java | 22 +- .../ignite/mxbean/CacheMetricsMXBean.java | 134 +- .../ignite/mxbean/ClusterMetricsMXBean.java | 114 +- .../communication/tcp/TcpCommunicationSpi.java | 71 +- .../TcpCommunicationConnectionCheckFuture.java | 4 +- .../ignite/spi/discovery/tcp/ClientImpl.java | 2 +- .../ignite/spi/discovery/tcp/ServerImpl.java | 2 +- .../spi/discovery/tcp/TcpDiscoverySpi.java | 4 +- .../tcp/internal/TcpDiscoveryNode.java | 8 +- .../apache/ignite/ssl/SslContextFactory.java | 2 +- modules/core/src/test/config/tests.properties | 5 - ...teCacheEntryProcessorSequentialCallTest.java | 2 +- ...nerReadWriteThroughDisabledAbstractTest.java | 6 +- .../client/ClientCacheConfigurationTest.java | 7 + .../ignite/client/ClientConfigurationTest.java | 7 + .../apache/ignite/client/FunctionalTest.java | 7 + .../apache/ignite/client/IgniteBinaryTest.java | 11 +- .../java/org/apache/ignite/client/LoadTest.java | 10 +- .../apache/ignite/client/ReliabilityTest.java | 12 +- .../ignite/custom/DummyEventFilterFactory.java | 10 +- .../failure/FailureHandlerTriggeredTest.java | 2 +- .../internal/ClusterNodeMetricsSelfTest.java | 14 +- .../IgniteClientReconnectCacheTest.java | 27 +- .../ignite/internal/TaskNodeRestartTest.java | 2 +- .../internal/TestRecordingCommunicationSpi.java | 26 +- .../binary/BinaryMarshallerSelfTest.java | 35 +- .../FullyConnectedComponentSearcherTest.java | 7 + .../cache/CacheStopAndDestroySelfTest.java | 68 + .../processors/cache/GridCacheTestEntryEx.java | 73 +- ...ProjectionForCachesOnDaemonNodeSelfTest.java | 2 +- .../cache/IgniteCacheAbstractTest.java | 4 +- .../IgniteCacheStoreValueAbstractTest.java | 2 +- ...IgniteClientCacheInitializationFailTest.java | 20 +- ...ynamicCacheStartFailWithPersistenceTest.java | 4 +- ...opologyValidatorCacheGroupsAbstractTest.java | 2 +- ...yAtomicEntryProcessorDeploymentSelfTest.java | 2 +- ...eAbstractDataStructuresFailoverSelfTest.java | 16 +- .../GridCacheSequenceApiSelfAbstractTest.java | 4 +- .../GridCacheSetAbstractSelfTest.java | 4 - .../GridCacheSetFailoverAbstractSelfTest.java | 6 +- ...chePartitionedAtomicSetFailoverSelfTest.java | 2 +- ...rtitionedDataStructuresFailoverSelfTest.java | 14 + .../IgnitePartitionedSetNoBackupsSelfTest.java | 2 +- ...eplicatedDataStructuresFailoverSelfTest.java | 22 +- ...NearDisabledAtomicInvokeRestartSelfTest.java | 2 +- ...abledTransactionalInvokeRestartSelfTest.java | 2 +- .../CachePageWriteLockUnlockTest.java | 196 + .../distributed/CachePartitionStateTest.java | 2 +- .../distributed/GridCacheEventAbstractTest.java | 10 +- .../distributed/IgniteCacheCreatePutTest.java | 2 +- .../IgniteCacheFailedUpdateResponseTest.java | 2 - .../IgniteCachePartitionLossPolicySelfTest.java | 29 +- ...ptimisticTxSuspendResumeMultiServerTest.java | 2 +- .../IgniteOptimisticTxSuspendResumeTest.java | 2 +- .../dht/IgniteCacheStartWithLoadTest.java | 165 + .../GridCacheRebalancingOrderingTest.java | 2 +- ...acheStoreSessionWriteBehindAbstractTest.java | 2 +- ...TxStoreSessionWriteBehindCoalescingTest.java | 2 +- ...AtomicClientOnlyMultiJvmFullApiSelfTest.java | 2 +- ...tOnlyMultiJvmP2PDisabledFullApiSelfTest.java | 2 +- ...pyOnReadDisabledMultiJvmFullApiSelfTest.java | 2 +- .../GridCacheAtomicMultiJvmFullApiSelfTest.java | 2 +- ...tomicMultiJvmP2PDisabledFullApiSelfTest.java | 2 +- ...tomicNearEnabledMultiJvmFullApiSelfTest.java | 2 +- ...heAtomicNearOnlyMultiJvmFullApiSelfTest.java | 2 +- ...rOnlyMultiJvmP2PDisabledFullApiSelfTest.java | 2 +- ...ridCacheNearOnlyMultiJvmFullApiSelfTest.java | 2 +- ...rOnlyMultiJvmP2PDisabledFullApiSelfTest.java | 2 +- ...pyOnReadDisabledMultiJvmFullApiSelfTest.java | 2 +- ...CachePartitionedMultiJvmFullApiSelfTest.java | 2 +- ...ionedMultiJvmP2PDisabledFullApiSelfTest.java | 2 +- ...onedNearDisabledMultiJvmFullApiSelfTest.java | 2 +- ...abledMultiJvmP2PDisabledFullApiSelfTest.java | 2 +- ...ReplicatedAtomicMultiJvmFullApiSelfTest.java | 2 +- ...dCacheReplicatedMultiJvmFullApiSelfTest.java | 2 +- ...catedMultiJvmP2PDisabledFullApiSelfTest.java | 2 +- ...plicatedNearOnlyMultiJvmFullApiSelfTest.java | 2 +- ...vccAbstractBasicCoordinatorFailoverTest.java | 681 ++++ ...acheMvccAbstractCoordinatorFailoverTest.java | 148 + .../mvcc/CacheMvccAbstractFeatureTest.java | 299 ++ .../cache/mvcc/CacheMvccAbstractTest.java | 2302 +++++++++++ .../cache/mvcc/CacheMvccClusterRestartTest.java | 178 + .../CacheMvccConfigurationValidationTest.java | 191 + ...ccIteratorWithConcurrentTransactionTest.java | 64 + ...calEntriesWithConcurrentTransactionTest.java | 65 + .../mvcc/CacheMvccOperationChecksTest.java | 201 + ...eMvccPartitionedCoordinatorFailoverTest.java | 144 + .../cache/mvcc/CacheMvccProcessorTest.java | 97 + ...heMvccReplicatedCoordinatorFailoverTest.java | 30 + ...cScanQueryWithConcurrentTransactionTest.java | 76 + ...heMvccSizeWithConcurrentTransactionTest.java | 52 + .../cache/mvcc/CacheMvccTransactionsTest.java | 3687 ++++++++++++++++++ .../cache/mvcc/CacheMvccVacuumTest.java | 158 + ...cheObjectBinaryProcessorOnDiscoveryTest.java | 125 + .../persistence/IgnitePdsTaskCancelingTest.java | 6 +- ...IgnitePersistentStoreDataStructuresTest.java | 45 +- .../MemoryPolicyInitializationTest.java | 12 +- .../db/IgnitePdsDataRegionMetricsTest.java | 59 +- .../db/IgnitePdsReserveWalSegmentsTest.java | 188 + .../db/IgnitePdsUnusedWalSegmentsTest.java | 198 - .../file/IgnitePdsDiskErrorsRecoveringTest.java | 5 +- .../IgniteNodeStoppedDuringDisableWALTest.java | 5 +- ...IsReachedDuringIterationOverArchiveTest.java | 2 +- .../db/wal/IgniteWalRebalanceTest.java | 185 +- .../db/wal/IgniteWalRecoveryTest.java | 1906 --------- .../IgniteWalRecoveryWithCompactionTest.java | 33 - .../persistence/db/wal/WalCompactionTest.java | 9 +- .../db/wal/WalDeletionArchiveAbstractTest.java | 277 ++ .../db/wal/WalDeletionArchiveFsyncTest.java | 31 + .../db/wal/WalDeletionArchiveLogOnlyTest.java | 31 + .../db/wal/WalRecoveryTxLogicalRecordsTest.java | 44 - .../db/wal/reader/MockWalIteratorFactory.java | 1 + .../pagemem/FillFactorMetricTest.java | 19 + .../pagemem/FullPageIdTableTest.java | 7 + ...gnitePageMemReplaceDelayedWriteUnitTest.java | 7 + .../pagemem/IgniteThrottlingUnitTest.java | 7 + .../pagemem/NoOpPageStoreManager.java | 7 + .../persistence/pagemem/NoOpWALManager.java | 6 + .../RobinHoodBackwardShiftHashMapTest.java | 6 + .../StandaloneWalRecordsIteratorTest.java | 216 + .../IndexingSpiQueryWithH2IndexingSelfTest.java | 2 +- ...eContinuousQueryAsyncFailoverTxSelfTest.java | 2 +- ...ContinuousQueryFailoverAbstractSelfTest.java | 2 +- .../CacheContinuousQueryFailoverTxSelfTest.java | 2 +- .../ContinuousQueryMarshallerTest.java | 168 + .../ContinuousQueryPeerClassLoadingTest.java | 4 +- .../cache/transactions/TxRollbackAsyncTest.java | 403 +- .../transactions/TxRollbackOnTimeoutTest.java | 225 +- .../TxRollbackOnTopologyChangeTest.java | 16 - .../processors/database/BPlusTreeSelfTest.java | 377 +- .../database/CacheFreeListImplSelfTest.java | 55 + .../database/DataRegionMetricsSelfTest.java | 24 +- .../IgniteDbPutGetWithCacheStoreTest.java | 5 +- .../DataStreamProcessorMvccSeflTest.java | 68 + .../DataStreamProcessorMvccSelfTest.java | 70 + .../DataStreamProcessorSelfTest.java | 24 +- ...SecondaryFileSystemDualAbstractSelfTest.java | 2 +- ...gniteServiceConfigVariationsFullApiTest.java | 2 +- .../ServicePredicateAccessCacheTest.java | 6 +- .../SqlParserTransactionalKeywordsSelfTest.java | 96 + .../nio/impl/GridNioFilterChainSelfTest.java | 2 +- .../lang/utils/GridConsistentHashSelfTest.java | 8 +- .../loadtests/GridCacheLoadPopulationTask.java | 2 +- .../p2p/GridP2PJobClassLoaderSelfTest.java | 2 +- .../p2p/GridP2PLocalDeploymentSelfTest.java | 6 +- ...nSetFutureAttributeWaitListenerSelfTest.java | 2 +- ...sionSetJobAttributeWaitListenerSelfTest.java | 2 +- .../discovery/tcp/IgniteClientConnectTest.java | 2 +- .../TcpDiscoverySpiFailureTimeoutSelfTest.java | 2 +- .../spi/discovery/tcp/TestTcpDiscoverySpi.java | 2 +- .../ignite/testframework/GridTestUtils.java | 21 + .../testframework/junits/GridAbstractTest.java | 34 +- .../junits/common/GridCommonAbstractTest.java | 34 +- .../testsuites/IgniteCacheMvccTestSuite.java | 67 + .../testsuites/IgniteCacheTestSuite7.java | 5 + .../ignite/testsuites/IgnitePdsTestSuite.java | 4 + .../ignite/testsuites/IgnitePdsTestSuite2.java | 20 +- .../testsuites/IgniteUtilSelfTestSuite.java | 2 - .../ignite/util/GridCommandHandlerTest.java | 23 - .../apache/ignite/util/GridIndexFillTest.java | 259 -- .../util/mbeans/WorkersControlMXBeanTest.java | 2 +- .../development/utils/IgniteWalConverter.java | 5 +- .../query/h2/opt/GridH2SpatialIndex.java | 11 +- .../impl/v2/HadoopV2JobResourceManager.java | 3 +- .../cache/hibernate/HibernateCacheProxy.java | 10 - .../cache/query/GridCacheTwoStepQuery.java | 36 + .../query/h2/DhtResultSetEnlistFuture.java | 63 + .../query/h2/DmlStatementsProcessor.java | 352 +- .../query/h2/H2ConnectionWrapper.java | 52 +- .../processors/query/h2/H2FieldsIterator.java | 29 +- .../processors/query/h2/H2KeyValueIterator.java | 2 +- .../query/h2/H2ResultSetIterator.java | 47 +- .../processors/query/h2/H2SqlFieldMetadata.java | 28 +- .../processors/query/h2/H2StatementCache.java | 78 +- .../internal/processors/query/h2/H2Utils.java | 4 +- .../processors/query/h2/IgniteH2Indexing.java | 1023 +++-- .../query/h2/NearResultSetEnlistFuture.java | 62 + .../query/h2/PreparedStatementEx.java | 45 + .../query/h2/PreparedStatementExImpl.java | 648 +++ .../query/h2/RebuildIndexFromHashClosure.java | 47 + .../query/h2/ResultSetEnlistFuture.java | 136 + .../query/h2/ThreadLocalObjectPool.java | 103 + .../query/h2/database/H2PkHashIndex.java | 108 +- .../query/h2/database/H2RowFactory.java | 25 +- .../processors/query/h2/database/H2Tree.java | 112 +- .../query/h2/database/H2TreeFilterClosure.java | 109 + .../query/h2/database/H2TreeIndex.java | 160 +- .../h2/database/io/AbstractH2ExtrasInnerIO.java | 164 + .../h2/database/io/AbstractH2ExtrasLeafIO.java | 161 + .../query/h2/database/io/AbstractH2InnerIO.java | 74 + .../query/h2/database/io/AbstractH2LeafIO.java | 76 + .../query/h2/database/io/H2ExtrasInnerIO.java | 111 +- .../query/h2/database/io/H2ExtrasLeafIO.java | 107 +- .../query/h2/database/io/H2IOUtils.java | 94 + .../query/h2/database/io/H2InnerIO.java | 41 +- .../query/h2/database/io/H2LeafIO.java | 41 +- .../h2/database/io/H2MvccExtrasInnerIO.java | 55 + .../h2/database/io/H2MvccExtrasLeafIO.java | 54 + .../query/h2/database/io/H2MvccInnerIO.java | 58 + .../query/h2/database/io/H2MvccLeafIO.java | 58 + .../query/h2/database/io/H2RowLinkIO.java | 34 + .../query/h2/ddl/DdlStatementsProcessor.java | 83 +- .../processors/query/h2/dml/DmlAstUtils.java | 12 +- .../processors/query/h2/dml/FastUpdate.java | 17 + .../processors/query/h2/dml/UpdatePlan.java | 233 ++ .../query/h2/dml/UpdatePlanBuilder.java | 118 +- .../query/h2/opt/GridH2IndexBase.java | 36 +- .../query/h2/opt/GridH2KeyRowOnheap.java | 11 + .../query/h2/opt/GridH2KeyValueRowOnheap.java | 21 +- .../query/h2/opt/GridH2MetaTable.java | 5 + .../query/h2/opt/GridH2PlainRowFactory.java | 17 +- .../query/h2/opt/GridH2QueryContext.java | 27 +- .../processors/query/h2/opt/GridH2Row.java | 50 +- .../query/h2/opt/GridH2RowDescriptor.java | 9 +- .../query/h2/opt/GridH2SearchRow.java | 32 + .../query/h2/opt/GridH2SearchRowAdapter.java | 27 +- .../processors/query/h2/opt/GridH2Table.java | 8 +- .../query/h2/opt/GridLuceneDirectory.java | 12 +- .../query/h2/opt/GridLuceneIndex.java | 10 +- .../query/h2/opt/GridLuceneOutputStream.java | 2 +- .../query/h2/sql/GridSqlQueryParser.java | 164 +- .../query/h2/sql/GridSqlQuerySplitter.java | 18 +- .../processors/query/h2/sql/GridSqlSelect.java | 20 + .../h2/sys/view/SqlAbstractLocalSystemView.java | 27 + .../h2/sys/view/SqlSystemViewNodeMetrics.java | 210 + .../query/h2/sys/view/SqlSystemViewNodes.java | 9 +- .../query/h2/twostep/GridMapQueryExecutor.java | 522 ++- .../h2/twostep/GridMergeIndexIterator.java | 17 +- .../h2/twostep/GridReduceQueryExecutor.java | 252 +- .../query/h2/twostep/GridResultPage.java | 20 +- .../query/h2/twostep/MapQueryResults.java | 18 +- .../query/h2/twostep/ReduceQueryRun.java | 152 +- .../h2/twostep/msg/GridH2QueryRequest.java | 75 +- .../msg/GridH2SelectForUpdateTxDetails.java | 299 ++ .../twostep/msg/GridH2ValueMessageFactory.java | 12 +- .../ignite/client/FunctionalQueryTest.java | 7 + .../ignite/client/IgniteBinaryQueryTest.java | 7 + .../org/apache/ignite/client/SecurityTest.java | 7 + ...CacheScanPartitionQueryFallbackSelfTest.java | 62 + .../cache/DdlTransactionSelfTest.java | 335 ++ .../IgniteCacheAbstractFieldsQuerySelfTest.java | 104 +- .../cache/IgniteCacheAbstractQuerySelfTest.java | 54 +- .../IgniteCacheQueryH2IndexingLeakTest.java | 10 +- ...ndexingCachePartitionLossPolicySelfTest.java | 139 + ...niteCacheDistributedQueryCancelSelfTest.java | 2 +- .../IgniteCacheReplicatedQuerySelfTest.java | 27 - .../cache/index/AbstractSchemaSelfTest.java | 102 +- ...ynamicColumnsAbstractConcurrentSelfTest.java | 13 +- .../index/DynamicIndexAbstractSelfTest.java | 7 + .../cache/index/H2ConnectionLeaksSelfTest.java | 8 +- .../H2DynamicColumnsAbstractBasicSelfTest.java | 117 + .../index/H2DynamicIndexAbstractSelfTest.java | 55 +- .../cache/index/H2DynamicTableSelfTest.java | 107 +- .../cache/index/IgniteDecimalSelfTest.java | 35 +- .../cache/index/SchemaExchangeSelfTest.java | 8 +- .../index/SqlTransactionsComandsSelfTest.java | 83 + ...sactionsComandsWithMvccDisabledSelfTest.java | 83 + ...sactionsCommandsWithMvccEnabledSelfTest.java | 420 ++ .../cache/index/SqlTransactionsSelfTest.java | 421 ++ .../local/IgniteCacheLocalQuerySelfTest.java | 64 +- ...eMvccAbstractSqlCoordinatorFailoverTest.java | 138 + .../mvcc/CacheMvccBackupsAbstractTest.java | 808 ++++ .../cache/mvcc/CacheMvccBulkLoadTest.java | 123 + .../cache/mvcc/CacheMvccDmlSimpleTest.java | 200 + ...eratorWithConcurrentJdbcTransactionTest.java | 28 + ...ntriesWithConcurrentJdbcTransactionTest.java | 29 + .../mvcc/CacheMvccPartitionedBackupsTest.java | 30 + ...MvccPartitionedSelectForUpdateQueryTest.java | 44 + ...ccPartitionedSqlCoordinatorFailoverTest.java | 143 + .../CacheMvccPartitionedSqlQueriesTest.java | 30 + .../CacheMvccPartitionedSqlTxQueriesTest.java | 30 + ...cPartitionedSqlTxQueriesWithReducerTest.java | 30 + .../mvcc/CacheMvccReplicatedBackupsTest.java | 30 + ...eMvccReplicatedSelectForUpdateQueryTest.java | 30 + ...vccReplicatedSqlCoordinatorFailoverTest.java | 30 + .../mvcc/CacheMvccReplicatedSqlQueriesTest.java | 30 + .../CacheMvccReplicatedSqlTxQueriesTest.java | 242 ++ ...ccReplicatedSqlTxQueriesWithReducerTest.java | 30 + ...nQueryWithConcurrentJdbcTransactionTest.java | 29 + ...cheMvccSelectForUpdateQueryAbstractTest.java | 374 ++ .../cache/mvcc/CacheMvccSizeTest.java | 488 +++ ...ccSizeWithConcurrentJdbcTransactionTest.java | 28 + .../mvcc/CacheMvccSqlQueriesAbstractTest.java | 1613 ++++++++ .../mvcc/CacheMvccSqlTxQueriesAbstractTest.java | 1832 +++++++++ ...MvccSqlTxQueriesWithReducerAbstractTest.java | 829 ++++ .../mvcc/CacheMvccStreamingInsertTest.java | 122 + .../db/wal/IgniteWalRecoveryTest.java | 1911 +++++++++ .../IgniteWalRecoveryWithCompactionTest.java | 33 + .../IgniteTwoRegionsRebuildIndexTest.java | 124 + .../query/SqlSystemViewsSelfTest.java | 261 +- .../query/h2/GridIndexRebuildSelfTest.java | 240 ++ ...GridIndexRebuildWithMvccEnabledSelfTest.java | 126 + .../h2/GridIndexingSpiAbstractSelfTest.java | 4 +- ...H2ResultSetIteratorNullifyOnEndSelfTest.java | 420 ++ .../query/h2/H2StatementCacheSelfTest.java | 83 + .../query/h2/PreparedStatementExSelfTest.java | 61 + .../query/h2/ThreadLocalObjectPoolSelfTest.java | 113 + .../query/h2/sql/GridQueryParsingTest.java | 1 + ...sappearedCacheCauseRetryMessageSelfTest.java | 134 + ...appearedCacheWasNotFoundMessageSelfTest.java | 123 + .../query/h2/twostep/JoinSqlTestHelper.java | 163 + .../NonCollocatedRetryMessageSelfTest.java | 146 + .../h2/twostep/RetryCauseMessageSelfTest.java | 417 ++ ...ePartitionedAtomicColumnConstraintsTest.java | 398 ++ ...ionedTransactionalColumnConstraintsTest.java | 30 + ...heReplicatedAtomicColumnConstraintsTest.java | 32 + ...catedTransactionalColumnConstraintsTest.java | 30 + .../sql/IgniteSQLColumnConstraintsTest.java | 143 + .../loadtests/h2indexing/GridTestEntity.java | 67 - .../loadtests/h2indexing/GridTreeBenchmark.java | 280 -- .../testsuites/IgniteCacheMvccSqlTestSuite.java | 90 + .../IgniteCacheQuerySelfTestSuite.java | 54 +- .../IgniteCacheQuerySelfTestSuite2.java | 9 + .../IgniteCacheQuerySelfTestSuite3.java | 2 + .../IgnitePdsWithIndexingCoreTestSuite.java | 2 + .../IgnitePdsWithIndexingTestSuite.java | 2 + .../processors/cache/mvcc/mvcc_person.csv | 2 + .../cache/mvcc/mvcc_person_broken.csv | 2 + .../processors/cache/jta/CacheJtaManager.java | 1 + modules/mesos/pom.xml | 38 +- .../apache/ignite/mesos/IgniteFramework.java | 3 +- .../ignite/mesos/resource/IgniteProvider.java | 120 +- .../ignite/mesos/IgniteSchedulerSelfTest.java | 11 + modules/ml/pom.xml | 13 +- .../clustering/kmeans/ClusterizationModel.java | 4 +- .../ml/clustering/kmeans/KMeansModel.java | 4 +- .../ml/clustering/kmeans/KMeansTrainer.java | 89 +- .../ml/composition/BaggingModelTrainer.java | 20 + .../ml/composition/ModelsComposition.java | 10 +- .../ml/composition/ModelsCompositionFormat.java | 61 + .../boosting/GDBBinaryClassifierTrainer.java | 57 +- .../boosting/GDBLearningStrategy.java | 115 +- .../boosting/GDBRegressionTrainer.java | 8 +- .../ml/composition/boosting/GDBTrainer.java | 119 +- .../LossGradientPerPredictionFunctions.java | 33 - .../convergence/ConvergenceChecker.java | 140 + .../convergence/ConvergenceCheckerFactory.java | 58 + .../mean/MeanAbsValueConvergenceChecker.java | 116 + .../MeanAbsValueConvergenceCheckerFactory.java | 47 + .../boosting/convergence/mean/package-info.java | 22 + .../MedianOfMedianConvergenceChecker.java | 126 + ...MedianOfMedianConvergenceCheckerFactory.java | 47 + .../convergence/median/package-info.java | 22 + .../boosting/convergence/package-info.java | 24 + .../simple/ConvergenceCheckerStub.java | 79 + .../simple/ConvergenceCheckerStubFactory.java | 48 + .../convergence/simple/package-info.java | 24 + .../ml/composition/boosting/loss/LogLoss.java | 36 + .../ml/composition/boosting/loss/Loss.java | 45 + .../composition/boosting/loss/SquaredError.java | 36 + .../composition/boosting/loss/package-info.java | 22 + .../WeightedPredictionsAggregator.java | 12 +- .../ignite/ml/dataset/feature/BucketMeta.java | 88 + .../dataset/feature/DistributionComputer.java | 32 + .../ignite/ml/dataset/feature/FeatureMeta.java | 65 + .../ignite/ml/dataset/feature/Histogram.java | 64 + .../ml/dataset/feature/ObjectHistogram.java | 129 + .../ignite/ml/dataset/feature/package-info.java | 24 + .../BootstrappedDatasetBuilder.java | 90 + .../BootstrappedDatasetPartition.java | 68 + .../impl/bootstrapping/BootstrappedVector.java | 87 + .../impl/bootstrapping/package-info.java | 23 + .../FeatureMatrixWithLabelsOnHeapData.java | 57 + ...eatureMatrixWithLabelsOnHeapDataBuilder.java | 76 + .../ignite/ml/knn/NNClassificationModel.java | 16 + .../ml/knn/ann/ANNClassificationModel.java | 15 +- .../ml/knn/ann/ANNClassificationTrainer.java | 107 +- .../ignite/ml/knn/ann/ANNModelFormat.java | 12 +- .../classification/KNNClassificationModel.java | 49 +- .../KNNClassificationTrainer.java | 20 +- .../ml/knn/regression/KNNRegressionTrainer.java | 19 +- .../ml/math/isolve/lsqr/AbstractLSQR.java | 6 +- .../ignite/ml/math/isolve/lsqr/LSQROnHeap.java | 10 +- .../org/apache/ignite/ml/nn/MLPTrainer.java | 186 +- .../ml/preprocessing/PreprocessingTrainer.java | 3 +- .../binarization/BinarizationPreprocessor.java | 4 +- .../binarization/BinarizationTrainer.java | 9 +- .../preprocessing/encoding/EncoderTrainer.java | 11 + .../MaxAbsScalerPartitionData.java | 48 + .../maxabsscaling/MaxAbsScalerPreprocessor.java | 77 + .../maxabsscaling/MaxAbsScalerTrainer.java | 85 + .../maxabsscaling/package-info.java | 22 + .../linear/LinearRegressionLSQRTrainer.java | 27 +- .../linear/LinearRegressionSGDTrainer.java | 159 +- .../binomial/LogisticRegressionSGDTrainer.java | 155 +- .../LogRegressionMultiClassModel.java | 9 + .../LogRegressionMultiClassTrainer.java | 76 +- .../ignite/ml/selection/cv/CrossValidation.java | 2 +- .../ml/selection/paramgrid/ParamGrid.java | 14 +- .../SVMLinearBinaryClassificationTrainer.java | 126 +- .../SVMLinearMultiClassClassificationModel.java | 9 + ...VMLinearMultiClassClassificationTrainer.java | 134 +- .../ignite/ml/trainers/DatasetTrainer.java | 166 + .../org/apache/ignite/ml/tree/DecisionTree.java | 27 +- .../tree/DecisionTreeClassificationTrainer.java | 4 +- .../ml/tree/DecisionTreeRegressionTrainer.java | 10 +- .../GDBBinaryClassifierOnTreesTrainer.java | 73 +- .../boosting/GDBOnTreesLearningStrategy.java | 24 +- .../boosting/GDBRegressionOnTreesTrainer.java | 67 +- .../ignite/ml/tree/data/DecisionTreeData.java | 36 +- .../RandomForestClassifierTrainer.java | 121 +- .../RandomForestRegressionTrainer.java | 82 +- .../tree/randomforest/RandomForestTrainer.java | 396 +- .../data/FeaturesCountSelectionStrategies.java | 47 + .../ml/tree/randomforest/data/NodeId.java | 55 + .../ml/tree/randomforest/data/NodeSplit.java | 79 + .../ml/tree/randomforest/data/TreeNode.java | 200 + .../ml/tree/randomforest/data/TreeRoot.java | 86 + .../data/impurity/GiniHistogram.java | 225 ++ .../data/impurity/GiniHistogramsComputer.java | 46 + .../data/impurity/ImpurityComputer.java | 38 + .../data/impurity/ImpurityHistogram.java | 74 + .../impurity/ImpurityHistogramsComputer.java | 211 + .../data/impurity/MSEHistogram.java | 235 ++ .../data/impurity/MSEHistogramComputer.java | 33 + .../data/impurity/package-info.java | 22 + .../ml/tree/randomforest/data/package-info.java | 22 + .../ClassifierLeafValuesComputer.java | 82 + .../data/statistics/LeafValuesComputer.java | 158 + .../data/statistics/MeanValueStatistic.java | 72 + .../NormalDistributionStatistics.java | 112 + .../NormalDistributionStatisticsComputer.java | 119 + .../RegressionLeafValuesComputer.java | 62 + .../data/statistics/package-info.java | 22 + .../ignite/ml/clustering/KMeansModelTest.java | 4 +- .../ignite/ml/clustering/KMeansTrainerTest.java | 86 +- .../ignite/ml/common/CollectionsTest.java | 9 +- .../ignite/ml/common/LocalModelsTest.java | 7 +- .../ml/composition/boosting/GDBTrainerTest.java | 81 +- .../convergence/ConvergenceCheckerTest.java | 82 + .../MeanAbsValueConvergenceCheckerTest.java | 73 + .../MedianOfMedianConvergenceCheckerTest.java | 57 + .../ignite/ml/dataset/DatasetTestSuite.java | 4 +- .../ml/dataset/feature/ObjectHistogramTest.java | 170 + .../ml/environment/LearningEnvironmentTest.java | 181 +- .../ignite/ml/knn/ANNClassificationTest.java | 51 +- .../ignite/ml/knn/KNNClassificationTest.java | 39 + .../apache/ignite/ml/knn/KNNRegressionTest.java | 40 + .../org/apache/ignite/ml/nn/MLPTrainerTest.java | 64 + .../binarization/BinarizationTrainerTest.java | 6 +- .../MaxAbsScalerPreprocessorTest.java | 55 + .../maxabsscaling/MaxAbsScalerTrainerTest.java | 76 + .../linear/LinearRegressionLSQRTrainerTest.java | 51 + .../linear/LinearRegressionSGDTrainerTest.java | 62 + .../logistic/LogRegMultiClassTrainerTest.java | 66 +- .../LogisticRegressionSGDTrainerTest.java | 46 + .../ml/svm/SVMBinaryTrainerIntegrationTest.java | 102 - .../ignite/ml/svm/SVMBinaryTrainerTest.java | 44 +- .../ignite/ml/svm/SVMMultiClassTrainerTest.java | 46 +- .../org/apache/ignite/ml/svm/SVMTestSuite.java | 1 - .../tree/DecisionTreeRegressionTrainerTest.java | 2 +- .../ignite/ml/tree/DecisionTreeTestSuite.java | 6 +- .../RandomForestClassifierTrainerTest.java | 51 +- .../RandomForestRegressionTrainerTest.java | 48 +- .../ml/tree/randomforest/RandomForestTest.java | 78 + .../randomforest/RandomForestTreeTestSuite.java | 39 + .../ml/tree/randomforest/data/TreeNodeTest.java | 79 + .../data/impurity/GiniFeatureHistogramTest.java | 254 ++ .../data/impurity/ImpurityHistogramTest.java | 69 + .../data/impurity/MSEHistogramTest.java | 135 + ...ormalDistributionStatisticsComputerTest.java | 130 + .../include/ignite/binary/binary_raw_reader.h | 22 +- .../ignite/impl/binary/binary_reader_impl.h | 11 + .../ignite/impl/binary/binary_type_impl.h | 16 +- .../cpp/common/include/ignite/common/utils.h | 2 +- .../cpp/core/include/ignite/cache/cache.h | 46 +- .../include/ignite/cache/query/query_cursor.h | 15 +- .../cpp/core/include/ignite/impl/operations.h | 150 +- modules/platforms/cpp/odbc-test/Makefile.am | 5 +- .../cpp/odbc-test/config/queries-default.xml | 6 + .../odbc-test/config/queries-transaction-32.xml | 50 + .../odbc-test/config/queries-transaction.xml | 32 + .../cpp/odbc-test/project/vs/odbc-test.vcxproj | 5 + .../project/vs/odbc-test.vcxproj.filters | 15 + .../cpp/odbc-test/src/connection_test.cpp | 136 + .../cpp/odbc-test/src/meta_queries_test.cpp | 17 + .../cpp/odbc-test/src/sql_get_info_test.cpp | 8 +- .../cpp/odbc-test/src/transaction_test.cpp | 738 ++++ modules/platforms/cpp/odbc/Makefile.am | 1 + .../include/ignite/odbc/config/configuration.h | 32 + .../odbc/config/connection_string_parser.h | 3 + .../cpp/odbc/include/ignite/odbc/connection.h | 21 +- .../ignite/odbc/diagnostic/diagnosable.h | 7 + .../odbc/diagnostic/diagnosable_adapter.h | 11 +- .../cpp/odbc/include/ignite/odbc/environment.h | 15 + .../cpp/odbc/include/ignite/odbc/message.h | 13 +- .../odbc/include/ignite/odbc/meta/column_meta.h | 47 +- .../odbc/include/ignite/odbc/nested_tx_mode.h | 81 + .../odbc/include/ignite/odbc/protocol_version.h | 7 +- .../odbc/system/ui/dsn_configuration_window.h | 8 + .../src/system/ui/dsn_configuration_window.cpp | 56 +- .../platforms/cpp/odbc/project/vs/odbc.vcxproj | 2 + .../cpp/odbc/project/vs/odbc.vcxproj.filters | 6 + .../cpp/odbc/src/config/configuration.cpp | 29 +- .../cpp/odbc/src/config/connection_info.cpp | 8 +- .../src/config/connection_string_parser.cpp | 19 + modules/platforms/cpp/odbc/src/connection.cpp | 99 +- .../odbc/src/diagnostic/diagnosable_adapter.cpp | 5 + modules/platforms/cpp/odbc/src/dsn_config.cpp | 5 + modules/platforms/cpp/odbc/src/environment.cpp | 53 +- modules/platforms/cpp/odbc/src/message.cpp | 28 +- .../platforms/cpp/odbc/src/meta/column_meta.cpp | 68 +- .../platforms/cpp/odbc/src/nested_tx_mode.cpp | 80 + modules/platforms/cpp/odbc/src/odbc.cpp | 2 + .../platforms/cpp/odbc/src/protocol_version.cpp | 4 +- .../cpp/odbc/src/query/batch_query.cpp | 4 +- .../platforms/cpp/odbc/src/query/data_query.cpp | 2 +- .../ExpiryCacheHolderTest.cs | 5 - .../IgniteSessionStateStoreProviderTest.cs | 7 +- .../DataStorageConfigurationParityTest.cs | 3 +- .../ApiParity/IgniteConfigurationParityTest.cs | 5 +- .../QueryEntityConfigurationParityTest.cs | 3 +- .../Cache/Query/Linq/CacheLinqTest.Base.cs | 20 +- .../Query/Linq/CacheLinqTest.Introspection.cs | 22 +- .../Cache/ClientCacheConfigurationTest.cs | 5 +- .../IgniteStartStopTest.cs | 23 +- .../Apache.Ignite.Core.Tests/MessagingTest.cs | 13 +- .../Apache.Ignite.Core.Tests/ReconnectTest.cs | 3 +- .../Cache/Configuration/CacheConfiguration.cs | 27 +- .../Cache/Configuration/QueryEntity.cs | 12 +- .../Cache/Configuration/QueryField.cs | 28 +- .../Configuration/QuerySqlFieldAttribute.cs | 2 + .../Client/Cache/CacheClientConfiguration.cs | 9 +- .../Configuration/DataStorageConfiguration.cs | 14 + .../Apache.Ignite.Core/IgniteConfiguration.cs | 82 +- .../IgniteConfigurationSection.xsd | 5 + .../dotnet/Apache.Ignite.Core/Ignition.cs | 3 +- .../Impl/Binary/BinaryWriterExtensions.cs | 31 +- .../Impl/Binary/IBinaryRawWriteAware.cs | 25 +- .../Apache.Ignite.Core/Impl/Cache/CacheImpl.cs | 3 +- .../Impl/Client/Cache/CacheClient.cs | 3 +- .../Cache/ClientCacheConfigurationSerializer.cs | 9 +- .../Impl/Client/ClientSocket.cs | 22 +- .../Impl/Client/IgniteClient.cs | 11 +- .../dotnet/Apache.Ignite.Core/Impl/Ignite.cs | 8 +- .../Apache.Ignite.Linq/Impl/ExpressionWalker.cs | 58 +- .../Datagrid/BinaryModeExample.cs | 3 +- .../Apache.Ignite.Examples/Sql/LinqExample.cs | 6 +- .../Apache.Ignite.Examples/Sql/SqlExample.cs | 3 +- .../nodejs/lib/internal/ClientSocket.js | 45 +- .../nodejs/lib/internal/MessageBuffer.js | 6 + ...gniteProjectionStartStopRestartSelfTest.java | 392 +- .../submitter/command/StartCommand.java | 3 +- .../web-console/backend/app/browsersHandler.js | 10 +- modules/web-console/frontend/app/app.js | 4 +- .../activities-user-dialog.controller.js | 8 +- .../activities-user-dialog.tpl.pug | 28 +- .../components/activities-user-dialog/index.js | 2 +- .../components/bs-select-menu/strip.filter.js | 2 +- .../app/components/bs-select-menu/style.scss | 4 +- .../connected-clusters-dialog/template.tpl.pug | 7 +- .../directives.js | 53 - .../expose-ignite-form-field-control/index.js | 23 - .../components/form-field-size/index.js | 1 + .../components/form-field-size/style.scss | 20 + .../components/form-field-size/template.pug | 2 +- .../app/components/grid-export/component.js | 7 +- .../components/grid-showing-rows/component.js | 2 +- .../components/grid-showing-rows/controller.js | 2 +- .../ignite-chart-series-selector/controller.js | 11 +- .../app/components/ignite-chart/controller.js | 61 +- .../app/components/ignite-chart/index.js | 1 + .../app/components/ignite-chart/template.pug | 1 + .../app/components/ignite-status/index.js | 22 + .../app/components/ignite-status/style.scss | 27 + .../input-dialog/input-dialog.tpl.pug | 6 +- .../list-of-registered-users/controller.js | 2 +- .../list-of-registered-users/template.tpl.pug | 18 +- .../cache-edit-form/templates/affinity.pug | 121 +- .../cache-edit-form/templates/concurrency.pug | 78 +- .../cache-edit-form/templates/general.pug | 139 +- .../cache-edit-form/templates/memory.pug | 87 +- .../templates/near-cache-client.pug | 40 +- .../templates/near-cache-server.pug | 42 +- .../cache-edit-form/templates/node-filter.pug | 19 +- .../cache-edit-form/templates/query.pug | 103 +- .../cache-edit-form/templates/rebalance.pug | 85 +- .../cache-edit-form/templates/statistics.pug | 17 +- .../cache-edit-form/templates/store.pug | 301 +- .../cluster-edit-form/templates/atomic.pug | 107 +- .../cluster-edit-form/templates/binary.pug | 86 +- .../templates/cache-key-cfg.pug | 12 +- .../cluster-edit-form/templates/checkpoint.pug | 72 +- .../templates/checkpoint/fs.pug | 10 +- .../templates/checkpoint/jdbc.pug | 107 +- .../templates/checkpoint/s3.pug | 489 ++- .../templates/client-connector.pug | 163 +- .../cluster-edit-form/templates/collision.pug | 27 +- .../templates/collision/custom.pug | 9 +- .../templates/collision/fifo-queue.pug | 20 +- .../templates/collision/job-stealing.pug | 59 +- .../templates/collision/priority-queue.pug | 66 +- .../templates/communication.pug | 190 +- .../cluster-edit-form/templates/connector.pug | 230 +- .../templates/data-storage.pug | 322 +- .../cluster-edit-form/templates/deployment.pug | 145 +- .../cluster-edit-form/templates/discovery.pug | 196 +- .../cluster-edit-form/templates/events.pug | 92 +- .../cluster-edit-form/templates/failover.pug | 52 +- .../cluster-edit-form/templates/general.pug | 49 +- .../templates/general/discovery/cloud.pug | 48 +- .../templates/general/discovery/google.pug | 45 +- .../templates/general/discovery/jdbc.pug | 21 +- .../templates/general/discovery/kubernetes.pug | 43 +- .../templates/general/discovery/multicast.pug | 55 +- .../templates/general/discovery/s3.pug | 31 +- .../templates/general/discovery/shared.pug | 8 +- .../templates/general/discovery/vm.pug | 3 +- .../templates/general/discovery/zookeeper.pug | 103 +- .../retrypolicy/bounded-exponential-backoff.pug | 28 +- .../discovery/zookeeper/retrypolicy/custom.pug | 11 +- .../retrypolicy/exponential-backoff.pug | 28 +- .../discovery/zookeeper/retrypolicy/forever.pug | 9 +- .../discovery/zookeeper/retrypolicy/n-times.pug | 18 +- .../zookeeper/retrypolicy/one-time.pug | 11 +- .../zookeeper/retrypolicy/until-elapsed.pug | 18 +- .../cluster-edit-form/templates/hadoop.pug | 119 +- .../templates/load-balancing.pug | 113 +- .../cluster-edit-form/templates/logger.pug | 31 +- .../templates/logger/custom.pug | 9 +- .../templates/logger/log4j.pug | 67 +- .../templates/logger/log4j2.pug | 40 +- .../cluster-edit-form/templates/marshaller.pug | 99 +- .../cluster-edit-form/templates/memory.pug | 117 +- .../cluster-edit-form/templates/metrics.pug | 52 +- .../cluster-edit-form/templates/misc.pug | 73 +- .../cluster-edit-form/templates/odbc.pug | 71 +- .../cluster-edit-form/templates/persistence.pug | 191 +- .../cluster-edit-form/templates/service.pug | 54 +- .../templates/sql-connector.pug | 88 +- .../cluster-edit-form/templates/ssl.pug | 69 +- .../cluster-edit-form/templates/swap.pug | 70 +- .../cluster-edit-form/templates/thread.pug | 103 +- .../cluster-edit-form/templates/time.pug | 47 +- .../templates/transactions.pug | 81 +- .../igfs-edit-form/templates/dual.pug | 26 +- .../igfs-edit-form/templates/fragmentizer.pug | 37 +- .../igfs-edit-form/templates/general.pug | 4 +- .../components/igfs-edit-form/templates/ipc.pug | 77 +- .../igfs-edit-form/templates/misc.pug | 126 +- .../igfs-edit-form/templates/secondary.pug | 29 +- .../model-edit-form/templates/general.pug | 53 +- .../model-edit-form/templates/query.pug | 60 +- .../model-edit-form/templates/store.pug | 40 +- .../page-configure-advanced/style.scss | 6 - .../page-configure-basic/template.pug | 8 +- .../modal-import-models/template.tpl.pug | 14 +- .../modal-preview-project/template.pug | 4 +- .../components/pc-items-table/template.pug | 3 +- .../page-configure/services/PageConfigure.js | 2 +- .../app/components/page-configure/style.scss | 7 +- .../app/components/page-profile/template.pug | 2 +- .../components/queries-notebook/controller.js | 2 +- .../components/queries-notebook/style.scss | 32 + .../queries-notebook/template.tpl.pug | 8 +- .../queries-notebooks-list/template.tpl.pug | 1 - .../app/components/ui-grid-filters/directive.js | 3 +- .../app/components/ui-grid/component.js | 10 +- .../app/components/ui-grid/controller.js | 136 +- .../app/components/ui-grid/decorator.js | 38 + .../frontend/app/components/ui-grid/index.js | 4 +- .../frontend/app/components/ui-grid/style.scss | 69 +- .../app/components/ui-grid/template.pug | 30 +- .../frontend/app/data/getting-started.json | 56 +- .../frontend/app/helpers/jade/mixins.pug | 423 +- .../app/modules/agent/AgentManager.service.js | 6 + .../agent/components/cluster-login/template.pug | 9 +- .../generator/ConfigurationGenerator.js | 2 +- .../frontend/app/modules/demo/Demo.module.js | 25 +- .../app/modules/form/panel/chevron.directive.js | 56 - .../getting-started/GettingStarted.provider.js | 16 +- .../app/modules/nodes/nodes-dialog.tpl.pug | 9 +- .../app/primitives/datepicker/index.pug | 3 +- .../app/primitives/form-field/dropdown.pug | 3 +- .../app/primitives/form-field/input.pug | 4 +- .../app/primitives/form-field/typeahead.pug | 3 +- .../frontend/app/primitives/index.js | 1 + .../frontend/app/primitives/modal/index.scss | 10 +- .../frontend/app/primitives/panel/index.scss | 13 +- .../app/primitives/spinner-circle/index.scss | 59 + .../app/primitives/timepicker/index.pug | 4 +- .../frontend/app/primitives/ui-grid/index.scss | 6 +- .../frontend/app/services/Clusters.js | 2 +- .../frontend/public/stylesheets/style.scss | 13 + .../frontend/views/sql/paragraph-rate.tpl.pug | 41 +- .../views/templates/agent-download.tpl.pug | 11 +- .../views/templates/batch-confirm.tpl.pug | 4 +- .../frontend/views/templates/confirm.tpl.pug | 5 +- .../frontend/views/templates/demo-info.tpl.pug | 14 +- .../views/templates/getting-started.tpl.pug | 31 +- .../frontend/views/templates/message.tpl.pug | 12 +- .../config/benchmark-atomic-sequence.properties | 84 + .../config/mvcc/benchmark-mvcc-messages.sh | 98 + .../config/mvcc/benchmark-mvcc-processor.sh | 95 + .../mvcc/benchmark-mvcc-updates-contention.sh | 96 + .../mvcc/benchmark-thin-native.properties | 124 + ...benchmark-jdbc-thin-inmemory-mvcc.properties | 105 + .../yardstick/IgniteBenchmarkArguments.java | 38 + .../org/apache/ignite/yardstick/IgniteNode.java | 2 + .../yardstick/IgniteThinAbstractBenchmark.java | 164 + .../ignite/yardstick/IgniteThinClient.java | 146 + .../cache/IgniteAtomicSequenceBenchmark.java | 47 - .../cache/IgnitePutAllSimpleBenchmark.java | 44 + .../yardstick/jdbc/AbstractJdbcBenchmark.java | 2 +- .../yardstick/jdbc/AbstractNativeBenchmark.java | 2 +- .../apache/ignite/yardstick/jdbc/JdbcUtils.java | 11 +- .../jdbc/NativeJavaApiPutRemoveBenchmark.java | 52 + .../mvcc/AbstractDistributedMvccBenchmark.java | 101 + .../jdbc/mvcc/MvccProcessorBenchmark.java | 61 + .../mvcc/MvccUpdateContentionBenchmark.java | 77 + .../IgniteAtomicSequenceAbstractBenchmark.java | 51 + .../IgniteAtomicSequenceAddAndGetBenchmark.java | 36 + .../IgniteAtomicSequenceGetAndAddBenchmark.java | 36 + ...eAtomicSequenceGetAndIncrementBenchmark.java | 33 + ...eAtomicSequenceIncrementAndGetBenchmark.java | 33 + .../thin/cache/IgniteThinBenchmarkUtils.java | 95 + .../cache/IgniteThinCacheAbstractBenchmark.java | 45 + .../thin/cache/IgniteThinGetBenchmark.java | 74 + .../thin/cache/IgniteThinGetTxBenchmark.java | 30 + .../thin/cache/IgniteThinPutAllBenchmark.java | 44 + .../thin/cache/IgniteThinPutAllTxBenchmark.java | 30 + .../thin/cache/IgniteThinPutBenchmark.java | 41 + .../thin/cache/IgniteThinPutGetBenchmark.java | 46 + .../thin/cache/IgniteThinPutTxBenchmark.java | 30 + .../upload/AbstractNativeBenchmark.java | 14 +- .../upload/AbstractUploadBenchmark.java | 9 +- .../yardstick/upload/model/QueryFactory.java | 30 +- .../ZkDistributedCollectDataFuture.java | 19 +- .../discovery/zk/internal/ZookeeperClient.java | 40 +- .../zk/internal/ZookeeperDiscoveryImpl.java | 43 +- .../tcp/ipfinder/zk/ZookeeperIpFinderTest.java | 9 +- .../zk/curator/FixedTestingQuorumPeerMain.java | 87 + .../tcp/ipfinder/zk/curator/TestingCluster.java | 237 ++ .../zk/curator/TestingZooKeeperServer.java | 169 + .../ZookeeperDiscoverySpiAbstractTestSuite.java | 2 +- .../zk/ZookeeperDiscoverySpiTestSuite2.java | 2 +- .../zk/internal/ZookeeperClientTest.java | 15 +- .../zk/internal/ZookeeperDiscoverySpiTest.java | 4 +- parent/pom.xml | 12 +- 1251 files changed, 87157 insertions(+), 16323 deletions(-) ----------------------------------------------------------------------
