Merge remote-tracking branch 'remotes/origin/master' into ignite-3478-tree
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/f7a1b8b4 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/f7a1b8b4 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/f7a1b8b4 Branch: refs/heads/ignite-3478-tree Commit: f7a1b8b4f67c8ce471fc29c6aa23f19531d428f6 Parents: 27ed6157 2bc75a3 Author: sboikov <[email protected]> Authored: Tue Oct 24 11:46:23 2017 +0300 Committer: sboikov <[email protected]> Committed: Tue Oct 24 11:46:23 2017 +0300 ---------------------------------------------------------------------- RELEASE_NOTES.txt | 98 ++ assembly/dependencies-fabric-lgpl.xml | 4 + assembly/dependencies-fabric.xml | 4 + assembly/dependencies-sqlline.xml | 53 + assembly/release-fabric-base.xml | 1 - examples/config/example-data-regions.xml | 106 ++ examples/config/example-memory-policies.xml | 108 -- .../example-persistent-store.xml | 14 +- .../examples/datagrid/DataRegionsExample.java | 113 ++ .../datagrid/MemoryPoliciesExample.java | 114 -- .../ignite/examples/CacheExamplesSelfTest.java | 6 +- .../benchmarks/jmh/tree/BPlusTreeBenchmark.java | 8 +- .../internal/jdbc2/JdbcConnectionSelfTest.java | 13 +- .../internal/jdbc2/JdbcMetadataSelfTest.java | 40 +- .../internal/jdbc2/JdbcStatementSelfTest.java | 130 +- .../JettyRestProcessorAbstractSelfTest.java | 4 +- .../jdbc/suite/IgniteJdbcDriverTestSuite.java | 11 + .../JdbcThinAbstractDmlStatementSelfTest.java | 16 +- .../thin/JdbcThinAutoCloseServerCursorTest.java | 8 +- .../thin/JdbcThinComplexDmlDdlSelfTest.java | 10 +- ...omplexDmlDdlSkipReducerOnUpdateSelfTest.java | 33 + .../jdbc/thin/JdbcThinComplexQuerySelfTest.java | 2 +- .../jdbc/thin/JdbcThinConnectionSelfTest.java | 22 +- .../JdbcThinDynamicIndexAbstractSelfTest.java | 2 +- .../jdbc/thin/JdbcThinEmptyCacheSelfTest.java | 2 +- .../thin/JdbcThinInsertStatementSelfTest.java | 1 - ...ertStatementSkipReducerOnUpdateSelfTest.java | 33 + ...rgeStatementSkipReducerOnUpdateSelfTest.java | 33 + .../jdbc/thin/JdbcThinMetadataSelfTest.java | 53 +- .../JdbcThinMissingLongArrayResultsTest.java | 2 +- .../jdbc/thin/JdbcThinNoDefaultSchemaTest.java | 5 +- .../thin/JdbcThinPreparedStatementSelfTest.java | 2 +- .../jdbc/thin/JdbcThinResultSetSelfTest.java | 2 +- .../jdbc/thin/JdbcThinStatementSelfTest.java | 46 +- ...ateStatementSkipReducerOnUpdateSelfTest.java | 33 + .../ignite/codegen/MessageCodeGenerator.java | 2 + modules/compatibility/pom.xml | 13 + .../DummyPersistenceCompatibilityTest.java | 8 +- .../junits/IgniteCompatibilityAbstractTest.java | 6 +- .../junits/IgniteCompatibilityNodeRunner.java | 2 +- .../org/apache/ignite/DataRegionMetrics.java | 130 ++ .../apache/ignite/DataRegionMetricsAdapter.java | 106 ++ .../org/apache/ignite/DataStorageMetrics.java | 114 ++ .../ignite/DataStorageMetricsAdapter.java | 101 ++ .../src/main/java/org/apache/ignite/Ignite.java | 48 +- .../org/apache/ignite/IgniteJdbcDriver.java | 16 +- .../org/apache/ignite/IgniteJdbcThinDriver.java | 3 +- .../apache/ignite/IgniteSystemProperties.java | 4 +- .../java/org/apache/ignite/MemoryMetrics.java | 11 +- .../org/apache/ignite/PersistenceMetrics.java | 4 +- .../org/apache/ignite/cache/CacheMetrics.java | 20 + .../ignite/cache/query/SqlFieldsQuery.java | 7 + .../configuration/CacheConfiguration.java | 36 +- .../configuration/DataPageEvictionMode.java | 8 +- .../configuration/DataRegionConfiguration.java | 406 ++++++ .../configuration/DataStorageConfiguration.java | 882 +++++++++++++ .../configuration/IgniteConfiguration.java | 46 +- .../configuration/MemoryConfiguration.java | 9 +- .../MemoryPolicyConfiguration.java | 32 +- .../PersistentStoreConfiguration.java | 4 +- .../apache/ignite/configuration/WALMode.java | 9 +- .../org/apache/ignite/igfs/IgfsMetrics.java | 4 +- .../apache/ignite/internal/IgniteKernal.java | 79 +- .../ignite/internal/IgniteNodeAttributes.java | 4 + .../ignite/internal/IgniteServicesImpl.java | 4 +- .../org/apache/ignite/internal/IgnitionEx.java | 132 +- .../ignite/internal/MarshallerContextImpl.java | 3 +- .../internal/MarshallerMappingFileStore.java | 15 +- .../ignite/internal/binary/BinaryMetadata.java | 8 +- .../connection/GridClientNioTcpConnection.java | 2 + .../internal/jdbc/thin/JdbcThinConnection.java | 10 +- .../jdbc/thin/JdbcThinDatabaseMetadata.java | 90 +- .../jdbc/thin/JdbcThinPreparedStatement.java | 5 +- .../internal/jdbc/thin/JdbcThinStatement.java | 9 +- .../internal/jdbc/thin/JdbcThinTcpIo.java | 39 +- .../internal/jdbc/thin/JdbcThinUtils.java | 6 + .../internal/jdbc2/JdbcBatchUpdateTask.java | 3 +- .../ignite/internal/jdbc2/JdbcConnection.java | 27 +- .../internal/jdbc2/JdbcDatabaseMetadata.java | 228 +++- .../jdbc2/JdbcQueryMultipleStatementsTask.java | 168 +++ .../ignite/internal/jdbc2/JdbcQueryTask.java | 164 +-- .../internal/jdbc2/JdbcQueryTaskResult.java | 120 ++ .../ignite/internal/jdbc2/JdbcQueryTaskV3.java | 105 ++ .../ignite/internal/jdbc2/JdbcResultSet.java | 175 ++- .../internal/jdbc2/JdbcSqlFieldsQuery.java | 105 -- .../ignite/internal/jdbc2/JdbcStatement.java | 274 ++-- .../internal/jdbc2/JdbcStatementResultInfo.java | 73 + .../jdbc2/JdbcStreamedPreparedStatement.java | 19 +- .../discovery/GridDiscoveryManager.java | 31 +- .../pagemem/impl/PageMemoryNoStoreImpl.java | 32 +- .../ignite/internal/pagemem/wal/WALPointer.java | 4 +- .../internal/pagemem/wal/record/DataEntry.java | 13 +- .../internal/pagemem/wal/record/DataRecord.java | 20 +- .../pagemem/wal/record/SnapshotRecord.java | 58 + .../pagemem/wal/record/TimeStampRecord.java | 57 + .../internal/pagemem/wal/record/TxRecord.java | 52 +- .../pagemem/wal/record/UnwrapDataEntry.java | 22 +- .../internal/pagemem/wal/record/WALRecord.java | 6 +- .../cache/CacheAffinitySharedManager.java | 25 +- .../cache/CacheClusterMetricsMXBeanImpl.java | 10 + .../processors/cache/CacheGroupContext.java | 29 +- .../processors/cache/CacheGroupData.java | 17 +- .../processors/cache/CacheGroupDescriptor.java | 19 +- .../cache/CacheLocalMetricsMXBeanImpl.java | 10 + .../processors/cache/CacheMetricsImpl.java | 14 +- .../processors/cache/CacheMetricsSnapshot.java | 10 + .../processors/cache/ClusterCachesInfo.java | 14 +- .../cache/DynamicCacheChangeRequest.java | 18 + .../processors/cache/GridCacheAdapter.java | 36 +- .../cache/GridCacheAffinityManager.java | 2 +- .../processors/cache/GridCacheContext.java | 8 +- .../processors/cache/GridCacheEntryEx.java | 3 +- .../processors/cache/GridCacheMapEntry.java | 18 +- .../processors/cache/GridCacheProcessor.java | 153 ++- .../processors/cache/GridCacheUtils.java | 55 + .../cache/IgniteCacheOffheapManagerImpl.java | 48 +- .../cache/binary/BinaryMetadataFileStore.java | 7 +- .../binary/CacheObjectBinaryProcessorImpl.java | 10 +- .../GridDistributedTxRemoteAdapter.java | 5 +- .../distributed/dht/GridDhtLocalPartition.java | 61 +- .../dht/atomic/GridDhtAtomicCache.java | 3 +- .../dht/preloader/GridDhtPartitionDemander.java | 9 - .../distributed/near/GridNearGetRequest.java | 2 +- .../distributed/near/GridNearLockRequest.java | 2 +- .../cache/distributed/near/GridNearTxLocal.java | 2 +- .../near/GridNearTxPrepareRequest.java | 2 +- .../local/atomic/GridLocalAtomicCache.java | 2 +- .../cache/persistence/CacheDataRowAdapter.java | 2 +- .../cache/persistence/DataRegion.java | 84 ++ .../persistence/DataRegionMetricsImpl.java | 304 +++++ .../DataRegionMetricsMXBeanImpl.java | 136 ++ .../persistence/DataRegionMetricsSnapshot.java | 121 ++ .../persistence/DataStorageMetricsImpl.java | 297 +++++ .../persistence/DataStorageMetricsSnapshot.java | 144 ++ .../GridCacheDatabaseSharedManager.java | 171 ++- .../persistence/GridCacheOffheapManager.java | 22 +- .../IgniteCacheDatabaseSharedManager.java | 538 ++++---- .../cache/persistence/MemoryMetricsImpl.java | 286 ---- .../persistence/MemoryMetricsMXBeanImpl.java | 131 -- .../persistence/MemoryMetricsSnapshot.java | 112 -- .../cache/persistence/MemoryPolicy.java | 84 -- .../persistence/PersistenceMetricsImpl.java | 297 ----- .../persistence/PersistenceMetricsSnapshot.java | 144 -- .../processors/cache/persistence/RowStore.java | 38 +- .../evict/FairFifoPageEvictionTracker.java | 6 +- .../evict/PageAbstractEvictionTracker.java | 6 +- .../evict/Random2LruPageEvictionTracker.java | 8 +- .../evict/RandomLruPageEvictionTracker.java | 8 +- .../persistence/file/AsyncFileIOFactory.java | 28 +- .../cache/persistence/file/FilePageStore.java | 6 +- .../persistence/file/FilePageStoreManager.java | 74 +- .../cache/persistence/file/FilePageStoreV2.java | 4 +- .../file/FileVersionCheckingFactory.java | 6 +- .../filename/PdsConsistentIdProcessor.java | 11 +- .../persistence/freelist/FreeListImpl.java | 12 +- .../cache/persistence/freelist/PagesList.java | 7 +- .../persistence/pagemem/PageMemoryImpl.java | 48 +- .../snapshot/IgniteCacheSnapshotManager.java | 3 + .../cache/persistence/wal/FileWALPointer.java | 3 + .../wal/FileWriteAheadLogManager.java | 84 +- .../wal/reader/IgniteWalIteratorFactory.java | 12 +- .../wal/reader/StandaloneGridKernalContext.java | 11 +- .../reader/StandaloneWalRecordsIterator.java | 37 +- .../wal/serializer/RecordDataV1Serializer.java | 6 +- .../wal/serializer/RecordDataV2Serializer.java | 49 +- .../wal/serializer/RecordV2Serializer.java | 3 +- .../wal/serializer/TxRecordSerializer.java | 3 +- .../cache/query/GridCacheQueryManager.java | 158 ++- .../query/GridCacheQuerySqlMetadataJobV2.java | 154 +++ .../query/GridCacheQuerySqlMetadataV2.java | 101 ++ .../cache/query/GridCacheSqlMetadata.java | 8 + .../cache/query/GridCacheSqlQuery.java | 24 + .../cache/query/IgniteQueryErrorCode.java | 2 +- .../cache/query/SqlFieldsQueryEx.java | 158 +++ .../cache/ratemetrics/HitRateMetrics.java | 2 +- .../cache/transactions/IgniteTxAdapter.java | 3 +- .../transactions/IgniteTxLocalAdapter.java | 2 +- .../processors/cache/tree/CacheDataTree.java | 4 +- .../cache/tree/PendingEntriesTree.java | 2 +- .../processors/cluster/ClusterProcessor.java | 39 +- .../cluster/GridClusterStateProcessor.java | 3 +- .../processors/cluster/GridUpdateNotifier.java | 224 ++-- .../cluster/HttpIgniteUpdatesChecker.java | 29 +- .../processors/igfs/IgfsDataManager.java | 4 +- .../processors/odbc/jdbc/JdbcColumnMeta.java | 10 + .../processors/odbc/jdbc/JdbcColumnMetaV2.java | 74 ++ .../odbc/jdbc/JdbcConnectionContext.java | 11 +- .../odbc/jdbc/JdbcMetaColumnsResult.java | 28 +- .../odbc/jdbc/JdbcMetaColumnsResultV2.java | 50 + .../odbc/jdbc/JdbcRequestHandler.java | 51 +- .../processors/odbc/jdbc/JdbcResult.java | 8 + .../odbc/odbc/OdbcConnectionContext.java | 13 +- .../odbc/odbc/OdbcRequestHandler.java | 14 +- .../platform/client/ClientIntResponse.java | 46 + .../platform/client/ClientLongResponse.java | 46 + .../platform/client/ClientMessageParser.java | 133 ++ .../cache/ClientCacheClearKeyRequest.java | 44 + .../cache/ClientCacheClearKeysRequest.java | 44 + .../client/cache/ClientCacheClearRequest.java | 44 + .../cache/ClientCacheContainsKeyRequest.java | 45 + .../cache/ClientCacheContainsKeysRequest.java | 45 + .../client/cache/ClientCacheGetAllRequest.java | 46 + .../client/cache/ClientCacheGetAllResponse.java | 57 + .../ClientCacheGetAndPutIfAbsentRequest.java | 45 + .../cache/ClientCacheGetAndPutRequest.java | 45 + .../cache/ClientCacheGetAndRemoveRequest.java | 45 + .../cache/ClientCacheGetAndReplaceRequest.java | 45 + .../client/cache/ClientCacheGetRequest.java | 9 +- .../client/cache/ClientCacheGetSizeRequest.java | 57 + .../client/cache/ClientCacheKeyRequest.java | 48 + .../cache/ClientCacheKeyValueRequest.java | 48 + .../client/cache/ClientCacheKeysRequest.java | 68 + .../client/cache/ClientCachePutAllRequest.java | 57 + .../cache/ClientCachePutIfAbsentRequest.java | 45 + .../client/cache/ClientCachePutRequest.java | 13 +- .../cache/ClientCacheRemoveAllRequest.java | 44 + .../cache/ClientCacheRemoveIfEqualsRequest.java | 45 + .../cache/ClientCacheRemoveKeyRequest.java | 45 + .../cache/ClientCacheRemoveKeysRequest.java | 44 + .../ClientCacheReplaceIfEqualsRequest.java | 50 + .../client/cache/ClientCacheReplaceRequest.java | 45 + .../client/cache/ClientCacheRequest.java | 10 +- .../platform/cluster/PlatformClusterGroup.java | 90 ++ .../utils/PlatformConfigurationUtils.java | 177 ++- .../processors/query/GridQueryIndexing.java | 47 +- .../processors/query/GridQueryProcessor.java | 111 +- .../query/QueryTypeDescriptorImpl.java | 42 +- .../query/property/QueryBinaryProperty.java | 1 - .../schema/SchemaIndexCacheVisitorClosure.java | 14 +- .../schema/SchemaIndexCacheVisitorImpl.java | 29 +- .../handlers/cache/GridCacheCommandHandler.java | 12 +- .../service/GridServiceProcessor.java | 70 +- .../ignite/internal/util/IgniteUtils.java | 62 +- .../nio/GridAbstractCommunicationClient.java | 2 +- .../visor/cache/VisorCacheConfiguration.java | 8 +- .../visor/cache/VisorMemoryMetrics.java | 6 +- .../node/VisorDataRegionConfiguration.java | 225 ++++ .../node/VisorDataStorageConfiguration.java | 453 +++++++ .../visor/node/VisorGridConfiguration.java | 29 +- .../visor/node/VisorMemoryConfiguration.java | 26 +- .../node/VisorMemoryPolicyConfiguration.java | 10 +- .../visor/node/VisorNodeDataCollectorJob.java | 6 +- .../node/VisorNodeDataCollectorJobResult.java | 4 +- .../node/VisorNodeDataCollectorTaskResult.java | 4 +- .../visor/node/VisorPersistenceMetrics.java | 8 +- .../node/VisorPersistentStoreConfiguration.java | 22 +- .../internal/visor/query/VisorQueryTask.java | 23 +- .../ignite/mxbean/DataRegionMetricsMXBean.java | 143 ++ .../ignite/mxbean/DataStorageMetricsMXBean.java | 121 ++ .../ignite/mxbean/MemoryMetricsMXBean.java | 2 + .../ignite/mxbean/PersistenceMetricsMXBean.java | 2 + .../communication/tcp/TcpCommunicationSpi.java | 378 +++--- .../spi/discovery/IgniteDiscoveryThread.java | 23 + .../ignite/spi/discovery/tcp/ServerImpl.java | 48 +- .../spi/discovery/tcp/TcpDiscoverySpi.java | 18 + .../spi/indexing/IndexingQueryCacheFilter.java | 72 + .../spi/indexing/IndexingQueryFilter.java | 12 +- .../spi/indexing/IndexingQueryFilterImpl.java | 79 ++ .../resources/META-INF/classnames.properties | 10 +- .../core/src/test/config/examples.properties | 2 +- .../ignite/cache/LargeEntryUpdateTest.java | 6 +- .../internal/ClusterNodeMetricsSelfTest.java | 8 +- .../IgniteSlowClientDetectionSelfTest.java | 6 +- .../internal/TestRecordingCommunicationSpi.java | 12 + .../pagemem/impl/PageMemoryNoLoadSelfTest.java | 8 +- .../cache/CacheClientStoreSelfTest.java | 4 +- .../cache/CacheConfigurationLeakTest.java | 15 +- .../cache/CacheDataRegionConfigurationTest.java | 172 +++ .../cache/CacheGroupsMetricsRebalanceTest.java | 6 +- .../CacheMemoryPolicyConfigurationTest.java | 172 --- .../CacheMetricsForClusterGroupSelfTest.java | 119 +- .../cache/CacheRebalancingSelfTest.java | 41 +- .../cache/CacheStopAndDestroySelfTest.java | 10 +- .../cache/GridCacheAbstractFullApiSelfTest.java | 45 +- .../processors/cache/GridCacheTestEntryEx.java | 2 +- ...StorageConfigurationConsistencySelfTest.java | 79 ++ ...dMemoryConfigurationConsistencySelfTest.java | 79 -- ...IgniteClientCacheInitializationFailTest.java | 30 +- .../IgniteClusterActivateDeactivateTest.java | 32 +- ...erActivateDeactivateTestWithPersistence.java | 30 +- .../IgniteMarshallerCacheFSRestoreTest.java | 71 +- ...niteTopologyValidatorGridSplitCacheTest.java | 358 ++++- .../cache/MemoryPolicyConfigValidationTest.java | 24 +- ...AffinityCoordinatorDynamicStartStopTest.java | 15 +- ...heapCacheMetricsForClusterGroupSelfTest.java | 19 +- .../distributed/Cache64kPartitionsTest.java | 14 +- .../CacheLateAffinityAssignmentTest.java | 9 +- .../cache/distributed/CacheStartOnJoinTest.java | 9 +- .../IgniteCacheTopologySplitAbstractTest.java | 266 ++++ .../paged/PageEvictionAbstractTest.java | 25 +- .../expiry/IgniteCacheLargeValueExpireTest.java | 6 +- .../IgniteDataStorageMetricsSelfTest.java | 237 ++++ ...tePdsBinaryMetadataOnClusterRestartTest.java | 10 +- .../IgnitePdsCacheRebalancingAbstractTest.java | 25 +- .../IgnitePdsClientNearCachePutGetTest.java | 6 +- .../IgnitePdsContinuousRestartTest.java | 28 +- .../persistence/IgnitePdsDynamicCacheTest.java | 28 +- .../IgnitePdsExchangeDuringCheckpointTest.java | 41 +- ...MarshallerMappingRestoreOnNodeStartTest.java | 6 +- .../IgnitePdsMultiNodePutGetRestartTest.java | 24 +- .../persistence/IgnitePdsPageSizesTest.java | 29 +- ...gnitePdsRecoveryAfterFileCorruptionTest.java | 39 +- .../IgnitePdsRemoveDuringRebalancingTest.java | 35 +- ...gnitePdsSingleNodePutGetPersistenceTest.java | 6 +- .../IgnitePersistenceMetricsSelfTest.java | 225 ---- ...nitePersistenceSequentialCheckpointTest.java | 6 +- .../IgnitePersistentStoreCacheGroupsTest.java | 16 +- ...IgnitePersistentStoreDataStructuresTest.java | 23 +- .../MemoryPolicyInitializationTest.java | 22 +- .../db/IgnitePdsCacheRestoreTest.java | 45 +- .../db/IgnitePdsMultiNodePutGetRestartTest.java | 23 +- ...PdsPageEvictionDuringPartitionClearTest.java | 29 +- .../db/IgnitePdsPageEvictionTest.java | 30 +- ...tePdsRebalancingOnNotStableTopologyTest.java | 28 +- .../db/IgnitePdsTransactionsHangTest.java | 26 +- .../db/IgnitePdsWholeClusterRestartTest.java | 28 +- ...faultPageSizeBackwardsCompatibilityTest.java | 21 +- .../db/file/IgnitePdsCacheIntegrationTest.java | 29 +- ...ckpointSimulationWithRealCpDisabledTest.java | 25 +- .../db/file/IgnitePdsEvictionTest.java | 25 +- .../file/IgnitePdsNoActualWalHistoryTest.java | 22 +- .../file/IgnitePdsThreadInterruptionTest.java | 51 +- .../IgniteUidAsConsistentIdMigrationTest.java | 28 +- .../persistence/db/wal/IgnitePdsWalTlbTest.java | 30 +- .../db/wal/IgniteWalFlushFailoverTest.java | 29 +- .../wal/IgniteWalHistoryReservationsTest.java | 26 +- .../db/wal/IgniteWalRecoveryPPCTest.java | 321 +++++ .../IgniteWalRecoverySeveralRestartsTest.java | 29 +- .../db/wal/IgniteWalRecoveryTest.java | 33 +- .../db/wal/IgniteWalSerializerVersionTest.java | 213 ++- .../db/wal/WalRecoveryTxLogicalRecordsTest.java | 18 +- .../db/wal/reader/IgniteWalReaderTest.java | 153 ++- .../db/wal/reader/MockWalIteratorFactory.java | 14 +- .../pagemem/BPlusTreePageMemoryImplTest.java | 6 +- .../BPlusTreeReuseListPageMemoryImplTest.java | 6 +- .../MetadataStoragePageMemoryImplTest.java | 6 +- .../pagemem/PageMemoryImplNoLoadTest.java | 6 +- .../persistence/pagemem/PageMemoryImplTest.java | 6 +- .../pagemem/PagesWriteThrottleSandboxTest.java | 40 +- .../pagemem/PagesWriteThrottleSmokeTest.java | 42 +- .../AbstractNodeJoinTemplate.java | 8 +- .../IgniteChangeGlobalStateAbstractTest.java | 31 +- .../IgniteChangeGlobalStateServiceTest.java | 2 + .../IgniteStandByClusterTest.java | 12 +- .../extended/GridActivateExtensionTest.java | 34 +- ...gniteAbstractStandByClientReconnectTest.java | 9 +- ...niteCacheContinuousQueryBackupQueueTest.java | 6 +- .../cache/transactions/TxDeadlockCauseTest.java | 15 +- .../TxPessimisticDeadlockDetectionTest.java | 21 +- .../cluster/GridUpdateNotifierSelfTest.java | 50 +- .../processors/database/BPlusTreeSelfTest.java | 8 +- .../database/DataRegionMetricsSelfTest.java | 348 +++++ .../database/FreeListImplSelfTest.java | 16 +- .../database/IgniteDbAbstractTest.java | 10 +- .../database/IgniteDbDynamicCacheSelfTest.java | 18 +- .../IgniteDbMemoryLeakAbstractTest.java | 14 +- .../database/MemoryMetricsSelfTest.java | 348 ----- .../database/MetadataStorageSelfTest.java | 8 +- .../database/SwapPathConstructionSelfTest.java | 28 +- .../processors/igfs/IgfsIgniteMock.java | 25 +- .../processors/igfs/IgfsSizeSelfTest.java | 12 +- .../GridServiceProcessorMultiNodeSelfTest.java | 71 +- .../platform/PlatformCacheWriteMetricsTask.java | 10 + .../spi/discovery/tcp/TcpDiscoverySelfTest.java | 110 ++ .../ignite/testframework/junits/IgniteMock.java | 25 +- .../junits/multijvm/IgniteProcessProxy.java | 25 +- .../ignite/testsuites/IgniteBasicTestSuite.java | 4 +- .../ignite/testsuites/IgniteCacheTestSuite.java | 4 +- .../testsuites/IgniteCacheTestSuite2.java | 4 +- .../ignite/testsuites/IgnitePdsTestSuite2.java | 4 +- .../query/h2/DmlStatementsProcessor.java | 188 ++- .../internal/processors/query/h2/H2Cursor.java | 25 +- .../processors/query/h2/H2DmlPlanKey.java | 21 +- .../processors/query/h2/H2RowDescriptor.java | 431 ------ .../internal/processors/query/h2/H2Schema.java | 17 +- .../processors/query/h2/H2TableDescriptor.java | 2 +- .../processors/query/h2/H2TableEngine.java | 5 +- .../internal/processors/query/h2/H2TypeKey.java | 64 + .../internal/processors/query/h2/H2Utils.java | 3 +- .../processors/query/h2/IgniteH2Indexing.java | 292 ++-- .../processors/query/h2/UpdateResult.java | 63 + .../query/h2/database/H2PkHashIndex.java | 26 +- .../query/h2/database/H2RowFactory.java | 8 +- .../processors/query/h2/database/H2Tree.java | 17 +- .../query/h2/database/H2TreeIndex.java | 6 +- .../query/h2/database/io/H2ExtrasInnerIO.java | 4 +- .../query/h2/database/io/H2ExtrasLeafIO.java | 4 +- .../query/h2/database/io/H2InnerIO.java | 4 +- .../query/h2/database/io/H2LeafIO.java | 4 +- .../query/h2/ddl/DdlStatementsProcessor.java | 38 +- .../processors/query/h2/dml/UpdatePlan.java | 64 +- .../query/h2/dml/UpdatePlanBuilder.java | 117 +- .../query/h2/opt/GridH2IndexBase.java | 83 +- .../query/h2/opt/GridH2KeyRowOnheap.java | 63 + .../query/h2/opt/GridH2KeyValueRowOnheap.java | 197 +-- .../query/h2/opt/GridH2MetaTable.java | 13 +- .../query/h2/opt/GridH2PlainRowFactory.java | 181 +++ .../processors/query/h2/opt/GridH2Row.java | 121 +- .../query/h2/opt/GridH2RowDescriptor.java | 410 +++++- .../query/h2/opt/GridH2RowFactory.java | 194 --- .../query/h2/opt/GridH2SearchRowAdapter.java | 103 ++ .../processors/query/h2/opt/GridH2Table.java | 108 +- .../query/h2/opt/GridLuceneIndex.java | 25 +- .../query/h2/sql/GridSqlCreateTable.java | 51 + .../query/h2/sql/GridSqlQueryParser.java | 70 +- .../query/h2/sql/GridSqlQuerySplitter.java | 33 + .../query/h2/twostep/DistributedUpdateRun.java | 133 ++ .../query/h2/twostep/GridMapQueryExecutor.java | 136 ++ .../query/h2/twostep/GridMergeIndexSorted.java | 4 +- .../h2/twostep/GridMergeIndexUnsorted.java | 4 +- .../h2/twostep/GridReduceQueryExecutor.java | 294 ++++- .../query/h2/twostep/MapNodeResults.java | 33 + .../query/h2/twostep/msg/GridH2DmlRequest.java | 516 ++++++++ .../query/h2/twostep/msg/GridH2DmlResponse.java | 250 ++++ .../twostep/msg/GridH2ValueMessageFactory.java | 6 + .../cache/IgniteCacheAbstractQuerySelfTest.java | 13 +- ...ributedJoinPartitionedAndReplicatedTest.java | 2 + ...leNodeWithIndexingPutGetPersistenceTest.java | 6 +- ...stributedPartitionQueryAbstractSelfTest.java | 8 +- .../IgniteCacheQueryNodeRestartSelfTest2.java | 8 +- ...ynamicColumnsAbstractConcurrentSelfTest.java | 57 +- .../cache/index/DynamicColumnsAbstractTest.java | 16 +- ...umnsConcurrentAtomicPartitionedSelfTest.java | 2 +- ...lumnsConcurrentAtomicReplicatedSelfTest.java | 2 +- ...currentTransactionalPartitionedSelfTest.java | 2 +- ...ncurrentTransactionalReplicatedSelfTest.java | 5 +- .../index/DynamicIndexAbstractSelfTest.java | 16 +- .../H2DynamicColumnsAbstractBasicSelfTest.java | 43 + .../cache/index/H2DynamicTableSelfTest.java | 407 +++++- .../cache/index/LongIndexNameTest.java | 4 +- ...eDbSingleNodeWithIndexingWalRestoreTest.java | 11 +- ...oreQueryWithMultipleClassesPerCacheTest.java | 8 +- .../IgnitePersistentStoreSchemaLoadTest.java | 15 +- .../query/IgniteSqlNotNullConstraintTest.java | 6 +- ...teSqlSkipReducerOnUpdateDmlFlagSelfTest.java | 800 +++++++++++ ...IgniteSqlSkipReducerOnUpdateDmlSelfTest.java | 755 +++++++++++ .../h2/GridIndexingSpiAbstractSelfTest.java | 47 +- .../h2/database/InlineIndexHelperTest.java | 20 +- .../query/h2/opt/GridH2TableSelfTest.java | 369 ------ .../IgniteCacheQuerySelfTestSuite.java | 21 + .../IgniteCacheQuerySelfTestSuite2.java | 6 + .../IgniteCacheQuerySelfTestSuite3.java | 3 - .../IgniteDistributedJoinTestSuite.java | 55 - .../IgnitePdsWithIndexingCoreTestSuite.java | 3 + .../ignite/logger/log4j2/Log4J2Logger.java | 130 +- .../log4j2/GridLog4j2CorrectFileNameTest.java | 94 -- .../log4j2/GridLog4j2InitializedTest.java | 77 -- .../log4j2/GridLog4j2LoggingFileTest.java | 68 - .../logger/log4j2/Log4j2LoggerSelfTest.java | 7 + .../log4j2/Log4j2LoggerVerboseModeSelfTest.java | 71 +- .../testsuites/IgniteLog4j2TestSuite.java | 2 + .../cpp/odbc-test/src/configuration_test.cpp | 25 +- .../cpp/odbc-test/src/queries_test.cpp | 8 + .../include/ignite/odbc/config/configuration.h | 26 + .../cpp/odbc/include/ignite/odbc/message.h | 6 +- .../odbc/include/ignite/odbc/protocol_version.h | 1 + .../odbc/system/ui/dsn_configuration_window.h | 4 + .../src/system/ui/dsn_configuration_window.cpp | 20 + .../cpp/odbc/src/config/configuration.cpp | 50 +- modules/platforms/cpp/odbc/src/connection.cpp | 5 +- modules/platforms/cpp/odbc/src/dsn_config.cpp | 4 + modules/platforms/cpp/odbc/src/message.cpp | 12 +- .../platforms/cpp/odbc/src/protocol_version.cpp | 6 +- .../Apache.Ignite.Core.Tests.csproj | 14 +- .../ApiParity/CacheConfigurationParityTest.cs | 88 ++ .../ClientConnectorConfigurationParityTest.cs | 39 + .../DataRegionConfigurationParityTest.cs | 39 + .../DataStorageConfigurationParityTest.cs | 53 + .../ApiParity/IgniteConfigurationParityTest.cs | 98 ++ .../ApiParity/ParityTest.cs | 135 ++ .../QueryEntityConfigurationParityTest.cs | 49 + .../BasicSerializableObjectsTest.cs | 3 +- .../Serializable/GenericCollectionsTest.cs | 112 ++ .../Cache/CacheConfigurationTest.cs | 6 + .../Cache/DataRegionMetricsTest.cs | 153 +++ .../Cache/DataStorageMetricsTest.cs | 107 ++ .../Cache/MemoryMetricsTest.cs | 1 + .../Cache/PersistenceTest.cs | 235 ++++ .../Cache/PersistentStoreTest.cs | 189 --- .../Cache/PersistentStoreTestObsolete.cs | 190 +++ .../Cache/Query/CacheDmlQueriesTest.cs | 4 +- .../Cache/Query/Linq/CacheLinqTest.Strings.cs | 23 + .../Client/Cache/CacheTest.cs | 687 +++++++++- .../Client/Cache/CacheTestNoMeta.cs | 4 +- .../Client/Cache/EmptyObject.cs | 54 + .../Client/ClientTestBase.cs | 9 + .../Config/full-config.xml | 18 + .../Config/spring-test.xml | 18 +- .../Apache.Ignite.Core.Tests/DeploymentTest.cs | 33 +- .../Examples/Example.cs | 6 +- .../Examples/ExamplesTest.cs | 42 +- .../IgniteConfigurationSerializerTest.cs | 135 +- .../IgniteConfigurationTest.cs | 232 ++-- .../IgniteManagerTest.cs | 10 +- .../Apache.Ignite.Core.csproj | 11 +- .../Cache/Configuration/CacheConfiguration.cs | 21 +- .../Cache/Configuration/DataPageEvictionMode.cs | 3 + .../Cache/Configuration/MemoryConfiguration.cs | 5 + .../Configuration/MemoryPolicyConfiguration.cs | 3 + .../Apache.Ignite.Core/Cache/IMemoryMetrics.cs | 4 + .../Client/Cache/ICacheClient.cs | 155 +++ .../Client/IgniteClientException.cs | 8 + .../Configuration/CheckpointWriteOrder.cs | 37 + .../Configuration/DataPageEvictionMode.cs | 59 + .../Configuration/DataRegionConfiguration.cs | 213 +++ .../Configuration/DataStorageConfiguration.cs | 466 +++++++ .../Apache.Ignite.Core/Configuration/WalMode.cs | 45 + .../Apache.Ignite.Core/IDataRegionMetrics.cs | 55 + .../Apache.Ignite.Core/IDataStorageMetrics.cs | 87 ++ .../dotnet/Apache.Ignite.Core/IIgnite.cs | 33 + .../Apache.Ignite.Core/IgniteConfiguration.cs | 41 +- .../IgniteConfigurationSection.xsd | 273 +++- .../Impl/Binary/BinaryFullTypeDescriptor.cs | 19 +- .../Binary/BinarySurrogateTypeDescriptor.cs | 8 +- .../Impl/Binary/BinarySystemHandlers.cs | 16 +- .../Impl/Binary/BinaryWriter.cs | 7 + .../Impl/Binary/IBinaryTypeDescriptor.cs | 6 +- .../Impl/Binary/Io/BinaryHeapStream.cs | 1018 +++++++++++++- .../Impl/Binary/Io/BinaryStreamBase.cs | 1249 ------------------ .../Impl/Binary/SerializableSerializer.cs | 11 +- .../Impl/Binary/Structure/BinaryStructure.cs | 147 +-- .../Binary/Structure/BinaryStructureTracker.cs | 16 +- .../Apache.Ignite.Core/Impl/Cache/CacheImpl.cs | 24 +- .../Impl/Cache/MemoryMetrics.cs | 2 + .../Impl/Client/Cache/CacheClient.cs | 260 +++- .../Apache.Ignite.Core/Impl/Client/ClientOp.cs | 21 +- .../Impl/Cluster/ClusterGroupImpl.cs | 53 + .../Common/IgniteConfigurationXmlSerializer.cs | 11 +- .../Impl/DataRegionMetrics.cs | 61 + .../Impl/DataStorageMetrics.cs | 87 ++ .../dotnet/Apache.Ignite.Core/Impl/Ignite.cs | 22 + .../Apache.Ignite.Core/Impl/IgniteUtils.cs | 21 + .../PersistentStore/PersistentStoreMetrics.cs | 2 + .../PersistentStore/CheckpointWriteOrder.cs | 3 + .../PersistentStore/IPersistentStoreMetrics.cs | 2 + .../PersistentStoreConfiguration.cs | 4 + .../PersistentStore/WalMode.cs | 3 + .../Impl/CacheQueryExpressionVisitor.cs | 5 + .../Apache.Ignite.Linq/Impl/MethodVisitor.cs | 59 +- .../Apache.Ignite.Examples.csproj | 2 + .../examples/Apache.Ignite.Examples/App.config | 4 + .../ThinClient/ThinClientPutGetExample.cs | 93 ++ .../ThinClient/ThinClientQueryExample.cs | 147 +++ .../http/jetty/GridJettyObjectMapper.java | 3 + .../org/apache/ignite/IgniteSpringBean.java | 27 +- modules/sqlline/bin/sqlline.bat | 112 ++ modules/sqlline/bin/sqlline.sh | 54 + modules/sqlline/pom.xml | 83 ++ .../top/VisorActivationCommandSpec.scala | 13 +- modules/web-console/DEVNOTES.txt | 6 + modules/web-console/backend/app/agentSocket.js | 21 +- .../web-console/backend/app/browsersHandler.js | 9 +- modules/web-console/backend/app/mongo.js | 56 + .../ignite_modules/migrations/README.txt | 4 + modules/web-console/backend/index.js | 53 +- .../web-console/backend/migrations/README.txt | 4 + modules/web-console/backend/package.json | 5 +- modules/web-console/frontend/.eslintrc | 2 +- modules/web-console/frontend/app/app.js | 3 + .../app/components/list-editable/component.js | 36 + .../list-editable-cols/cols.directive.js | 79 ++ .../list-editable-cols/cols.style.scss | 51 + .../list-editable-cols/cols.template.pug | 29 + .../components/list-editable-cols/index.js | 28 + .../list-editable-cols/row.directive.js | 40 + .../app/components/list-editable/controller.js | 79 ++ .../app/components/list-editable/index.js | 27 + .../app/components/list-editable/style.scss | 132 ++ .../app/components/list-editable/template.pug | 49 + .../page-configure-basic/controller.js | 10 +- .../helpers/jade/form/form-field-dropdown.pug | 2 +- .../frontend/app/helpers/jade/mixins.pug | 9 +- .../app/modules/agent/AgentManager.service.js | 25 +- .../app/modules/agent/decompress.worker.js | 34 + .../generator/AbstractTransformer.js | 5 + .../generator/ConfigurationGenerator.js | 114 +- .../generator/defaults/Cluster.service.js | 40 + .../frontend/app/modules/sql/sql.controller.js | 50 +- .../states/configuration/caches/store.pug | 4 +- .../configuration/clusters/attributes.pug | 4 +- .../clusters/collision/job-stealing.pug | 4 +- .../configuration/clusters/data-storage.pug | 255 ++++ .../states/configuration/clusters/memory.pug | 4 +- .../configuration/clusters/persistence.pug | 4 +- .../states/configuration/domains/general.pug | 2 +- .../states/configuration/domains/query.pug | 8 +- .../app/primitives/form-field/index.scss | 15 + .../frontend/app/primitives/ui-grid/index.scss | 4 + .../frontend/app/services/Clusters.js | 6 + .../frontend/app/services/JavaTypes.service.js | 15 + .../app/services/LegacyUtils.service.js | 16 +- .../frontend/app/services/Version.service.js | 6 +- .../frontend/app/utils/SimpleWorkerPool.js | 119 ++ .../frontend/controllers/clusters-controller.js | 69 +- .../frontend/controllers/domains-controller.js | 7 +- modules/web-console/frontend/package.json | 10 +- .../frontend/public/images/icons/index.js | 2 + .../frontend/public/images/icons/info.svg | 3 + .../frontend/public/images/icons/sort.svg | 1 + .../frontend/public/stylesheets/style.scss | 8 + modules/web-console/frontend/tsconfig.json | 12 + .../views/configuration/clusters.tpl.pug | 8 +- .../web-console/frontend/views/sql/sql.tpl.pug | 24 +- .../agent/handlers/AbstractListener.java | 6 +- .../yardstick/IgniteBenchmarkArguments.java | 8 +- .../org/apache/ignite/yardstick/IgniteNode.java | 15 +- parent/pom.xml | 4 + pom.xml | 17 + 608 files changed, 26994 insertions(+), 9761 deletions(-) ----------------------------------------------------------------------
