You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ni...@apache.org on 2021/04/23 13:37:32 UTC
[ignite] 01/01: Merge branch 'master' into ignite-ducktape
This is an automated email from the ASF dual-hosted git repository.
nizhikov pushed a commit to branch ignite-ducktape
in repository https://gitbox.apache.org/repos/asf/ignite.git
commit 389f42a3e1b4aaf8c9c8718159e69e9026c199b7
Merge: 6a80994 bec58b0
Author: Nikolay <ni...@apache.org>
AuthorDate: Fri Apr 23 16:36:54 2021 +0300
Merge branch 'master' into ignite-ducktape
RELEASE_NOTES.txt | 2 +-
assembly/dependencies-apache-ignite-slim.xml | 1 +
assembly/libs/README.txt | 1 +
checkstyle/checkstyle.xml | 5 +
docs/_data/toc.yaml | 4 +
docs/_docs/clustering/discovery-in-the-cloud.adoc | 44 +-
docs/_docs/code-snippets/java/pom.xml | 5 +
.../ignite/snippets/DiscoveryInTheCloud.java | 24 +
.../performance-statistics.adoc | 82 ++
.../spring/spring-data.adoc | 79 +-
.../spring/spring-tx.adoc | 466 ++++++++++
docs/_docs/includes/cpp-prerequisites.adoc | 2 +-
docs/_docs/includes/dotnet-prerequisites.adoc | 2 +-
docs/_docs/includes/java9.adoc | 2 +-
docs/_docs/includes/partition-awareness.adoc | 8 -
docs/_docs/includes/prereqs.adoc | 2 +-
.../kubernetes/generic-configuration.adoc | 20 +-
.../monitoring-metrics/performance-statistics.adoc | 6 +-
docs/_docs/monitoring-metrics/system-views.adoc | 153 ++++
docs/_docs/quick-start/java.adoc | 2 +-
docs/_docs/setup.adoc | 1 +
modules/azure/README.txt | 32 +
modules/azure/pom.xml | 342 +++++++
.../azure/TcpDiscoveryAzureBlobStoreIpFinder.java | 382 ++++++++
.../spi/discovery/tcp/ipfinder/package-info.java} | 15 +-
...TcpDiscoveryAzureBlobStoreIpFinderSelfTest.java | 91 ++
.../tcp/ipfinder/azure/package-info.java} | 15 +-
.../ignite/testsuites/IgniteAzureTestSuite.java | 61 ++
.../jmh/cache/JmhCacheAsyncListenBenchmark.java | 162 ++++
.../common/RunningQueryInfoCheckInitiatorTest.java | 420 +++++++++
.../ignite/internal/jdbc2/JdbcCursorLeaksTest.java | 202 +++++
.../internal/jdbc2/JdbcMetadataSelfTest.java | 11 +-
.../jdbc/suite/IgniteJdbcDriverTestSuite.java | 4 +
.../ignite/jdbc/thin/JdbcThinMetadataSelfTest.java | 78 +-
.../thin/JdbcThinStreamingAbstractSelfTest.java | 4 +-
.../SystemViewRowAttributeWalkerGenerator.java | 18 +
.../clients/AbstractClientCompatibilityTest.java | 8 +
.../clients/JavaThinCompatibilityTest.java | 26 +
.../IndexAbstractCompatibilityTest.java | 92 ++
.../persistence/IndexTypesCompatibilityTest.java | 334 +++++++
...java => InlineJavaObjectCompatibilityTest.java} | 93 +-
.../IgniteCompatibilityBasicTestSuite.java | 6 +-
.../cache/CacheIndexesForceRebuild.java | 2 +-
.../PerformanceStatisticsCommand.java | 4 +
.../PerformanceStatisticsSubCommand.java | 3 +
.../GridCommandHandlerIndexForceRebuildTest.java | 156 +++-
.../GridCommandHandlerIndexRebuildStatusTest.java | 27 +-
.../util/PerformanceStatisticsCommandTest.java | 34 +
.../org/apache/ignite/IgniteSystemProperties.java | 3 +-
.../apache/ignite/cache/query/SqlFieldsQuery.java | 53 ++
.../java/org/apache/ignite/client/ClientCache.java | 62 +-
.../ClientDisconnectListener.java} | 21 +-
.../ignite/configuration/IgniteConfiguration.java | 37 +
.../apache/ignite/internal/GridKernalContext.java | 16 +
.../ignite/internal/GridKernalContextImpl.java | 22 +
.../org/apache/ignite/internal/IgniteKernal.java | 28 +-
.../ignite/internal/IgniteNodeAttributes.java | 3 -
.../org/apache/ignite/internal/IgnitionEx.java | 23 +-
.../internal/cache/query/index/AbstractIndex.java} | 27 +-
.../ignite/internal/cache/query/index/Index.java | 69 ++
.../query/index/IndexDefinition.java} | 12 +-
.../query/index/IndexFactory.java} | 16 +-
.../internal/cache/query/index/IndexName.java | 88 ++
.../internal/cache/query/index/IndexProcessor.java | 588 ++++++++++++
.../query/index/NullsOrder.java} | 17 +-
.../ignite/internal/cache/query/index/Order.java} | 34 +-
.../internal/cache/query/index/SingleCursor.java | 58 ++
.../query/index/SortOrder.java} | 17 +-
.../DurableBackgroundCleanupIndexTreeTask.java | 302 +++++++
.../query/index/sorted/IndexKeyDefinition.java | 68 ++
.../query/index/sorted/IndexKeyTypeSettings.java | 81 ++
.../cache/query/index/sorted/IndexKeyTypes.java | 133 +++
.../cache/query/index/sorted/IndexRow.java | 86 ++
.../cache/query/index/sorted/IndexRowCache.java} | 19 +-
.../query/index/sorted/IndexRowCacheRegistry.java} | 22 +-
.../query/index/sorted/IndexRowComparator.java | 46 +
.../query/index/sorted/IndexRowCompartorImpl.java | 71 ++
.../cache/query/index/sorted/IndexRowImpl.java | 176 ++++
.../query/index/sorted/IndexSearchRowImpl.java | 78 ++
.../cache/query/index/sorted/IndexValueCursor.java | 72 ++
.../query/index/sorted/InlineIndexRowHandler.java | 69 ++
.../sorted/InlineIndexRowHandlerFactory.java} | 18 +-
.../cache/query/index/sorted/MetaPageInfo.java | 96 ++
.../query/index/sorted/SortedIndexDefinition.java | 62 ++
.../query/index/sorted/SortedSegmentedIndex.java | 102 +++
.../index/sorted/ThreadLocalRowHandlerHolder.java | 62 ++
.../sorted/defragmentation/DefragIndexFactory.java | 324 +++++++
.../defragmentation/IndexingDefragmentation.java | 269 ++++++
.../index/sorted/inline/IndexQueryContext.java} | 37 +-
.../query/index/sorted/inline/InlineIndex.java} | 28 +-
.../index/sorted/inline/InlineIndexFactory.java | 102 +++
.../query/index/sorted/inline/InlineIndexImpl.java | 473 ++++++++++
.../index/sorted/inline/InlineIndexKeyType.java} | 71 +-
.../sorted/inline/InlineIndexKeyTypeRegistry.java | 188 ++++
.../query/index/sorted/inline/InlineIndexTree.java | 658 ++++++++++++++
.../sorted/inline}/InlineObjectBytesDetector.java | 79 +-
.../index/sorted/inline/InlineRecommender.java | 141 +++
.../sorted/inline/InlineTreeFilterClosure.java} | 47 +-
.../sorted/inline/JavaObjectKeySerializer.java} | 27 +-
.../sorted/inline/io/AbstractInlineInnerIO.java | 166 ++++
.../sorted/inline/io/AbstractInlineLeafIO.java | 166 ++++
.../index/sorted/inline/io/AbstractInnerIO.java} | 44 +-
.../index/sorted/inline/io/AbstractLeafIO.java} | 50 +-
.../index/sorted/inline/io/IORowHandler.java} | 47 +-
.../query/index/sorted/inline/io/InlineIO.java} | 21 +-
.../index/sorted/inline/io/InlineInnerIO.java} | 15 +-
.../index/sorted/inline/io/InlineLeafIO.java} | 16 +-
.../query/index/sorted/inline/io/InnerIO.java} | 16 +-
.../query/index/sorted/inline/io/LeafIO.java} | 14 +-
.../query/index/sorted/inline/io/MvccIO.java} | 25 +-
.../index/sorted/inline/io/MvccInlineInnerIO.java} | 24 +-
.../index/sorted/inline/io/MvccInlineLeafIO.java} | 24 +-
.../query/index/sorted/inline/io/MvccInnerIO.java} | 18 +-
.../query/index/sorted/inline/io/MvccLeafIO.java} | 18 +-
.../inline/types/BooleanInlineIndexKeyType.java | 59 ++
.../inline/types/ByteInlineIndexKeyType.java | 59 ++
.../inline/types/BytesInlineIndexKeyType.java} | 88 +-
.../inline/types/DateInlineIndexKeyType.java | 69 ++
.../sorted/inline/types/DateValueConstants.java | 46 +
.../inline/types/DoubleInlineIndexKeyType.java | 59 ++
.../inline/types/FloatInlineIndexKeyType.java | 59 ++
.../inline/types/IntegerInlineIndexKeyType.java | 61 ++
.../inline/types/LongInlineIndexKeyType.java | 61 ++
.../inline/types/NullableInlineIndexKeyType.java | 232 +++++
.../types/ObjectByteArrayInlineIndexKeyType.java | 69 ++
.../inline/types/ObjectHashInlineIndexKeyType.java | 64 ++
.../inline/types/ShortInlineIndexKeyType.java | 59 ++
.../types/SignedBytesInlineIndexKeyType.java} | 21 +-
.../inline/types/StringInlineIndexKeyType.java} | 106 +--
.../types/StringNoCompareInlineIndexKeyType.java | 55 ++
.../inline/types/TimeInlineIndexKeyType.java | 61 ++
.../inline/types/TimestampInlineIndexKeyType.java | 82 ++
.../inline/types/UuidInlineIndexKeyType.java | 74 ++
.../index/sorted/keys/AbstractDateIndexKey.java} | 27 +-
.../index/sorted/keys/AbstractTimeIndexKey.java} | 20 +-
.../sorted/keys/AbstractTimestampIndexKey.java} | 29 +-
.../query/index/sorted/keys/BooleanIndexKey.java} | 39 +-
.../query/index/sorted/keys/ByteIndexKey.java} | 41 +-
.../query/index/sorted/keys/BytesCompareUtils.java | 59 ++
.../query/index/sorted/keys/BytesIndexKey.java} | 39 +-
.../index/sorted/keys/CacheJavaObjectIndexKey.java | 85 ++
.../query/index/sorted/keys/DecimalIndexKey.java} | 40 +-
.../query/index/sorted/keys/DoubleIndexKey.java} | 39 +-
.../query/index/sorted/keys/FloatIndexKey.java} | 41 +-
.../query/index/sorted/keys/IndexKey.java} | 24 +-
.../query/index/sorted/keys/IndexKeyFactory.java | 99 ++
.../query/index/sorted/keys/IntegerIndexKey.java} | 41 +-
.../index/sorted/keys/JavaObjectIndexKey.java | 109 +++
.../query/index/sorted/keys/LongIndexKey.java} | 41 +-
.../query/index/sorted/keys/NullIndexKey.java} | 33 +-
.../index/sorted/keys/PlainJavaObjectIndexKey.java | 64 ++
.../query/index/sorted/keys/ShortIndexKey.java} | 40 +-
.../index/sorted/keys/SignedBytesIndexKey.java} | 23 +-
.../query/index/sorted/keys/StringIndexKey.java} | 42 +-
.../query/index/sorted/keys/UuidIndexKey.java} | 41 +-
.../thin/ClientCacheEntryListenerHandler.java | 265 ++++++
.../thin/ClientCacheEntryListenersRegistry.java | 61 ++
.../ignite/internal/client/thin/ClientChannel.java | 9 +-
.../internal/client/thin/ClientComputeImpl.java | 249 ++---
.../client/thin/ClientContinuousQueryCursor.java | 61 ++
.../internal/client/thin/ClientJCacheAdapter.java | 194 ++++
.../thin/ClientJCacheEntryListenerAdapter.java | 70 ++
...onListener.java => ClientNotificationType.java} | 33 +-
.../internal/client/thin/ClientOperation.java | 21 +-
.../internal/client/thin/NotificationListener.java | 12 +-
.../internal/client/thin/ReliableChannel.java | 50 +-
.../internal/client/thin/TcpClientCache.java | 128 ++-
.../internal/client/thin/TcpClientChannel.java | 113 ++-
.../internal/client/thin/TcpIgniteClient.java | 23 +-
.../ignite/internal/cluster/IgniteClusterImpl.java | 2 +-
.../internal/jdbc2/JdbcCloseCursorTask.java} | 31 +-
.../ignite/internal/jdbc2/JdbcConnection.java | 48 +
.../jdbc2/JdbcQueryMultipleStatementsTask.java | 11 +
.../jdbc2/JdbcQueryMultipleStatementsTaskV3.java | 72 ++
.../ignite/internal/jdbc2/JdbcResultSet.java | 18 +-
.../ignite/internal/jdbc2/JdbcStatement.java | 29 +-
.../jdbc2/JdbcStreamedPreparedStatement.java | 2 +-
.../communication/GridIoMessageFactory.java | 4 -
.../managers/discovery/GridDiscoveryManager.java | 78 +-
.../managers/encryption/CacheGroupPageScanner.java | 234 +++--
.../managers/encryption/GridEncryptionManager.java | 8 +
.../managers/indexing/IndexesRebuildTask.java | 170 ++++
...ryViewWalker.java => AtomicLongViewWalker.java} | 38 +-
...wWalker.java => AtomicReferenceViewWalker.java} | 38 +-
...ewWalker.java => AtomicSequenceViewWalker.java} | 40 +-
...iewWalker.java => AtomicStampedViewWalker.java} | 40 +-
...ewWalker.java => CountDownLatchViewWalker.java} | 40 +-
.../systemview/walker/QueueViewWalker.java | 61 ++
.../systemview/walker/ReentrantLockViewWalker.java | 60 ++
.../systemview/walker/SemaphoreViewWalker.java | 60 ++
...{SqlQueryViewWalker.java => SetViewWalker.java} | 41 +-
.../systemview/walker/SqlQueryViewWalker.java | 4 +-
.../cache/CacheAffinitySharedManager.java | 37 +-
.../cache/DynamicCacheChangeRequest.java | 2 +-
.../internal/processors/cache/ExchangeActions.java | 4 +-
.../cache/GatewayProtectedCacheProxy.java | 4 +-
.../processors/cache/GridCacheEvictionManager.java | 2 +-
.../processors/cache/GridCacheMapEntry.java | 12 +-
.../cache/GridCachePartitionExchangeManager.java | 12 +-
.../processors/cache/GridCachePreloader.java | 3 +-
.../cache/GridCachePreloaderAdapter.java | 2 +-
.../processors/cache/GridCacheProcessor.java | 11 +-
.../processors/cache/GridCacheSharedContext.java | 7 +-
.../processors/cache/IgniteCacheFutureImpl.java | 8 +-
.../cache/IgniteCacheOffheapManager.java | 7 +
.../cache/IgniteCacheOffheapManagerImpl.java | 7 +-
.../processors/cache/IgniteCacheProxyImpl.java | 26 +-
.../cache/IgniteFinishedCacheFutureImpl.java | 2 +-
.../cache/PartitionUpdateCounterErrorWrapper.java | 182 ++++
.../cache/PartitionUpdateCounterTrackingImpl.java | 31 +-
.../internal/processors/cache/WalStateManager.java | 42 +-
.../datastructures/CacheDataStructuresManager.java | 10 +
.../distributed/GridCacheTxRecoveryFuture.java | 2 +-
.../distributed/dht/GridDhtTxPrepareFuture.java | 55 +-
.../distributed/dht/atomic/GridDhtAtomicCache.java | 80 --
.../dht/colocated/GridDhtColocatedLockFuture.java | 2 +-
.../dht/preloader/FinishPreloadingTask.java | 21 +-
.../dht/preloader/GridDhtPartitionDemander.java | 85 +-
.../preloader/GridDhtPartitionsExchangeFuture.java | 87 +-
.../dht/preloader/GridDhtPreloader.java | 4 +-
.../dht/topology/GridDhtLocalPartition.java | 2 +-
.../dht/topology/GridDhtPartitionTopologyImpl.java | 6 +-
.../dht/topology/GridDhtPartitionsReservation.java | 5 +-
.../near/GridNearOptimisticTxPrepareFuture.java | 2 +-
.../near/GridNearTxPrepareResponse.java | 2 +-
.../msg/PartitionCountersNeighborcastRequest.java | 173 ----
.../msg/PartitionCountersNeighborcastResponse.java | 141 ---
.../cache/persistence/DataRegionMetricsImpl.java | 10 +
.../GridCacheDatabaseSharedManager.java | 81 +-
.../cache/persistence/GridCacheOffheapManager.java | 26 +-
.../IgniteCacheDatabaseSharedManager.java | 11 +-
.../processors/cache/persistence/IndexStorage.java | 12 +
.../cache/persistence/IndexStorageImpl.java | 13 +
.../persistence/checkpoint/CheckpointManager.java | 6 +-
.../cache/persistence/checkpoint/Checkpointer.java | 61 +-
.../checkpoint/LightweightCheckpointManager.java | 6 +-
.../checkpoint/PartitionDestroyQueue.java | 18 +-
.../CachePartitionDefragmentationManager.java | 4 +-
.../file/FileVersionCheckingFactory.java | 2 +-
.../cache/persistence/pagemem/PageMemoryImpl.java | 4 +-
.../cache/persistence/wal/SegmentRouter.java | 8 +-
.../wal/reader/StandaloneGridKernalContext.java | 12 +
.../cache/transactions/IgniteTxHandler.java | 59 +-
.../cache/transactions/IgniteTxManager.java | 49 +-
.../PartitionCountersNeighborcastFuture.java | 237 -----
.../processors/cache/tree/AbstractDataLeafIO.java | 2 +-
.../cache/tree/mvcc/data/MvccDataRow.java | 2 +-
.../processors/cluster/ClusterProcessor.java | 7 +
.../cluster/GridClusterStateProcessor.java | 2 +
.../autoadjust/BaselineAutoAdjustData.java | 11 +-
.../autoadjust/BaselineAutoAdjustScheduler.java | 40 +-
.../autoadjust/BaselineTopologyUpdater.java | 8 +-
.../processors/datastreamer/DataStreamerImpl.java | 41 +-
.../datastructures/AtomicDataStructureProxy.java | 2 +-
.../datastructures/DataStructuresProcessor.java | 158 +++-
.../datastructures/GridCacheQueueProxy.java | 10 +
.../datastructures/GridCacheSetProxy.java | 10 +
.../processors/diagnostic/DiagnosticProcessor.java | 222 +++--
.../diagnostic/PageHistoryDiagnoster.java | 350 --------
.../processors/failure/FailureProcessor.java | 2 +-
.../internal/processors/job/GridJobWorker.java | 5 +
.../localtask/DurableBackgroundTasksProcessor.java | 72 +-
.../persistence/DistributedMetaStorageImpl.java | 57 +-
.../processors/metric/GridMetricManager.java | 10 +-
.../internal/processors/metric/MetricRegistry.java | 8 +-
.../ClientListenerAbstractConnectionContext.java | 42 +-
.../processors/odbc/ClientListenerNioListener.java | 12 +-
.../odbc/jdbc/JdbcConnectionContext.java | 7 +-
.../processors/odbc/jdbc/JdbcRequestHandler.java | 4 +-
.../odbc/odbc/OdbcConnectionContext.java | 9 +-
.../processors/odbc/odbc/OdbcRequestHandler.java | 13 +-
.../FilePerformanceStatisticsReader.java | 57 ++
.../FilePerformanceStatisticsWriter.java | 78 +-
.../performancestatistics/OperationType.java | 18 +-
.../PerformanceStatisticsHandler.java | 44 +
.../PerformanceStatisticsMBeanImpl.java | 5 +
.../PerformanceStatisticsProcessor.java | 165 +++-
.../platform/client/ClientConnectionContext.java | 6 +-
.../cache/ClientCacheSqlFieldsQueryRequest.java | 2 +
.../platform/utils/PlatformConfigurationUtils.java | 40 +
.../processors/query/GridQueryIndexing.java | 78 +-
.../processors/query/GridQueryProcessor.java | 224 +++--
.../processors/query/GridQueryRowCacheCleaner.java | 2 +-
.../processors/query/GridRunningQueryInfo.java | 15 +-
.../processors/query/IndexRebuildAware.java | 145 +++
.../internal/processors/query/QueryEntityEx.java | 26 +-
.../internal/processors/query/QueryUtils.java | 2 +-
.../processors/query/RunningQueryManager.java | 11 +-
.../schema/SchemaIndexCacheCompoundFuture.java | 49 +
.../query/schema/SchemaIndexCacheFuture.java} | 32 +-
.../schema/SchemaIndexCachePartitionWorker.java | 20 +-
.../query/schema/SchemaIndexCacheVisitorImpl.java | 7 +-
...SchemaIndexOperationCancellationException.java} | 23 +-
.../processors/security/SecurityUtils.java | 2 +-
.../apache/ignite/internal/sql/SqlParserUtils.java | 2 +-
.../apache/ignite/internal/util/GridCleaner.java | 2 +-
.../apache/ignite/internal/util/GridLeanSet.java | 2 +-
.../apache/ignite/internal/util/IgniteUtils.java | 4 +-
.../util/distributed/DistributedProcess.java | 7 +-
.../internal/util/future/IgniteFutureImpl.java | 24 +-
.../internal/util/nio/GridNioSessionImpl.java | 2 +-
.../ignite/internal/util/worker/CycleThread.java | 2 +-
.../VisorPerformanceStatisticsOperation.java | 3 +
.../VisorPerformanceStatisticsTask.java | 5 +
.../IgniteProducer.java} | 18 +-
.../ignite/mxbean/PerformanceStatisticsMBean.java | 4 +
.../checkpoint/sharedfs/SharedFsCheckpointSpi.java | 2 +-
.../tcp/internal/ConnectionClientPool.java | 25 +-
.../tcp/internal/GridNioServerWrapper.java | 2 +-
.../ignite/spi/discovery/tcp/ServerImpl.java | 65 +-
.../ignite/spi/discovery/tcp/TcpDiscoverySpi.java | 26 +-
.../tcp/internal/TcpDiscoveryStatistics.java | 12 +-
.../tcp/ipfinder/vm/TcpDiscoveryVmIpFinder.java | 104 ++-
.../ignite/spi/systemview/view/SqlQueryView.java | 6 +
.../datastructures/AbstractDataStructureView.java | 58 ++
.../view/datastructures/AtomicLongView.java | 48 +
.../view/datastructures/AtomicReferenceView.java | 50 ++
.../view/datastructures/AtomicSequenceView.java | 57 ++
.../view/datastructures/AtomicStampedView.java | 59 ++
.../view/datastructures/CountDownLatchView.java | 64 ++
.../systemview/view/datastructures/QueueView.java | 89 ++
.../view/datastructures/ReentrantLockView.java | 82 ++
.../view/datastructures/SemaphoreView.java | 82 ++
.../systemview/view/datastructures/SetView.java | 78 ++
.../main/resources/META-INF/classnames.properties | 2 +
.../src/test/config/class_list_test_excluded.txt | 17 +
.../test/java/org/apache/ignite/GridTestJob.java | 2 +-
...JdbcPojoWriteBehindStoreWithCoalescingTest.java | 12 +-
.../org/apache/ignite/client/ReliabilityTest.java | 14 -
.../internal/GridNodeMetricsLogSelfTest.java | 1 +
...ientCheckClusterGroupLocalIdAfterReconnect.java | 142 +++
.../inline/InlineIndexKeyTypeRegistryTest.java | 89 ++
.../client/thin/AbstractThinClientTest.java | 22 +
.../client/thin/CacheEntryListenersTest.java | 774 ++++++++++++++++
.../internal/client/thin/ComputeTaskTest.java | 29 +-
.../internal/client/thin/ReliableChannelTest.java | 10 +-
.../encryption/AbstractEncryptionTest.java | 2 +
.../encryption/CacheGroupReencryptionTest.java | 9 +-
.../IgniteTopologyPrintFormatSelfTest.java | 212 +++--
.../ignite/internal/metric/MetricsSelfTest.java | 14 +-
.../ignite/internal/metric/SystemMetricsTest.java | 66 ++
.../ignite/internal/metric/SystemViewSelfTest.java | 677 ++++++++++++++
.../cache/CacheAsyncContinuationExecutorTest.java | 254 ++++++
...eAsyncContinuationSynchronousExecutorTest.java} | 26 +-
.../cache/CacheSerializableTransactionsTest.java | 15 +-
.../ClientFastReplyCoordinatorFailureTest.java | 2 +-
.../GridCacheAsyncOperationsLimitSelfTest.java | 4 +-
.../cache/GridCacheReferenceCleanupSelfTest.java | 7 +
.../IgniteAbstractDynamicCacheStartFailTest.java | 6 +-
.../SetTxTimeoutOnPartitionMapExchangeTest.java | 2 +-
.../GridCacheQueueClientDisconnectTest.java | 2 +-
...GridExchangeFreeCellularSwitchAbstractTest.java | 134 ++-
...ngeFreeCellularSwitchComplexOperationsTest.java | 76 +-
...ridExchangeFreeCellularSwitchIsolationTest.java | 532 ++++++-----
...changeFreeCellularSwitchTxContinuationTest.java | 264 ++++++
...idExchangeFreeCellularSwitchTxCountersTest.java | 242 +++++
.../IgniteCacheNearRestartRollbackSelfTest.java | 2 +
.../rebalancing/RebalanceStatisticsTest.java | 3 +-
.../CorruptedTreeFailureHandlingTest.java | 40 +-
.../IgniteDataStorageMetricsSelfTest.java | 11 -
.../IgnitePdsNoSpaceLeftOnDeviceTest.java | 3 +-
...IgnitePdsSpuriousRebalancingOnNodeJoinTest.java | 10 +-
.../db/CheckpointBufferDeadlockTest.java | 62 +-
.../db/SlowCheckpointFileIOFactory.java | 86 ++
.../persistence/db/wal/IgniteLocalWalSizeTest.java | 31 +-
.../persistence/db/wal/IgniteWalRebalanceTest.java | 195 +++-
.../db/wal/WriteAheadLogManagerSelfTest.java | 10 -
.../db/wal/crc/IgniteDataIntegrityTests.java | 4 +-
.../pagemem/BPlusTreePageMemoryImplTest.java | 7 +-
.../BPlusTreeReuseListPageMemoryImplTest.java | 7 +-
.../IgnitePageMemReplaceDelayedWriteUnitTest.java | 12 +-
.../pagemem/IgniteThrottlingUnitTest.java | 10 +-
.../pagemem/IndexStoragePageMemoryImplTest.java | 7 +-
.../pagemem/PageMemoryImplNoLoadTest.java | 7 +-
.../persistence/pagemem/PageMemoryImplTest.java | 6 +-
.../pagemem/PagesWriteThrottleSmokeTest.java | 56 +-
.../persistence/tree/io/TrackingPageIOTest.java | 2 +-
.../persistence/wal/WalArchiveConsistencyTest.java | 10 -
.../wal/WalEnableDisableWithNodeShutdownTest.java | 46 +-
.../wal/WalEnableDisableWithRestartsTest.java | 203 +++++
.../transactions/PartitionUpdateCounterTest.java | 9 +-
.../cache/transactions/TxOnCachesStopTest.java | 2 +-
.../TxPartitionCounterStateConsistencyTest.java | 6 +-
...ounterStateOnePrimaryTwoBackupsFailAllTest.java | 4 +-
...teOnePrimaryTwoBackupsHistoryRebalanceTest.java | 160 ++++
...titionCounterStateOnePrimaryTwoBackupsTest.java | 18 +-
...titionCounterStateTwoPrimaryTwoBackupsTest.java | 2 +-
.../TxRecoveryWithConcurrentRollbackTest.java | 140 ++-
.../cache/transactions/TxRollbackAsyncTest.java | 14 +-
.../transactions/TxRollbackOnTimeoutTest.java | 101 ++-
.../TxRollbackOnTopologyChangeTest.java | 2 +-
.../processors/cluster/BaselineAutoAdjustTest.java | 184 +++-
.../ClusterNameBeforeActivation.java} | 38 +-
.../processors/database/CacheFreeListSelfTest.java | 9 +-
.../database/DataRegionMetricsSelfTest.java | 10 +-
.../DataStreamerCommunicationSpiExceptionTest.java | 143 +++
.../diagnostic/DiagnosticProcessorTest.java | 313 ++++---
.../DistributedMetaStorageClassloadingTest.java | 205 +++++
.../AbstractPerformanceStatisticsTest.java | 54 +-
.../performancestatistics/CheckpointTest.java | 228 +++++
.../PerformanceStatisticsRotateFileTest.java | 118 +++
.../processors/query/DummyQueryIndexing.java | 55 +-
.../compute/ComputePermissionCheckTest.java | 2 +-
.../util/future/IgniteCacheFutureImplTest.java | 2 +-
.../ignite/platform/PlatformTestExecutor.java} | 18 +-
.../ignite/platform/PlatformThreadUtils.java | 9 +
...municationSpiSkipWaitHandshakeOnClientTest.java | 2 +-
...cpClientDiscoverySpiFailureTimeoutSelfTest.java | 8 +-
.../tcp/TcpClientDiscoveryUnresolvedHostTest.java | 2 +-
.../tcp/TcpDiscoveryIpFinderFailureTest.java | 395 ++++++++
.../spi/discovery/tcp/TestDynamicIpFinder.java} | 39 +-
.../vm/TcpDiscoveryVmIpFinderDnsResolveTest.java | 630 +++++++++++++
.../junits/common/GridCommonAbstractTest.java | 123 ++-
.../ignite/testsuites/IgniteBasicTestSuite.java | 2 +
.../IgniteBasicWithPersistenceTestSuite.java | 6 +-
.../testsuites/IgniteCacheMvccTestSuite5.java | 4 +
.../ignite/testsuites/IgniteCacheTestSuite.java | 6 +
.../ignite/testsuites/IgniteCacheTestSuite5.java | 4 +
.../ignite/testsuites/IgniteCacheTestSuite9.java | 6 +-
.../testsuites/IgniteClientReconnectTestSuite.java | 2 +
.../ignite/testsuites/IgnitePdsTestSuite.java | 6 +-
.../IgniteSpiDiscoverySelfTestSuite.java | 7 +-
...ridCommandHandlerClusterByClassTest_help.output | 3 +
...andHandlerClusterByClassWithSSLTest_help.output | 3 +
.../development/utils/IgniteWalConverter.java | 11 -
.../utils/IgniteWalConverterArgumentsTest.java | 34 +
.../processors/query/h2/opt/GeoSpatialIndex.java | 65 ++
.../query/h2/opt/GeoSpatialIndexDefinition.java | 58 ++
.../query/h2/opt/GeoSpatialIndexFactory.java | 69 ++
.../query/h2/opt/GeoSpatialIndexImpl.java | 395 ++++++++
.../processors/query/h2/opt/GeoSpatialUtils.java | 71 ++
.../processors/query/h2/opt/GeometryIndexKey.java} | 39 +-
.../query/h2/opt/GridH2SpatialIndex.java | 371 +-------
.../processors/query/h2/CommandProcessor.java | 17 +-
.../processors/query/h2/ConnectionManager.java | 13 +
.../h2/DurableBackgroundCleanupIndexTreeTask.java | 195 ----
.../query/h2/H2JavaObjectSerializer.java | 27 +-
.../processors/query/h2/H2TableDescriptor.java | 22 +-
.../processors/query/h2/H2TableEngine.java | 11 +-
.../internal/processors/query/h2/H2Utils.java | 38 +-
.../processors/query/h2/IgniteH2Indexing.java | 393 ++------
.../query/h2/IndexRebuildFullClosure.java | 49 -
.../query/h2/IndexRebuildPartialClosure.java | 91 --
.../processors/query/h2/QueryDescriptor.java | 14 +-
.../internal/processors/query/h2/QueryParser.java | 3 +-
.../processors/query/h2/SchemaManager.java | 13 +-
.../query/h2/database/H2PkHashIndex.java | 44 +-
.../processors/query/h2/database/H2Tree.java | 997 ---------------------
.../query/h2/database/H2TreeClientIndex.java | 47 +-
.../processors/query/h2/database/H2TreeIndex.java | 612 +++----------
.../query/h2/database/H2TreeIndexBase.java | 92 --
.../inlinecolumn/AbstractInlineIndexColumn.java | 246 -----
.../inlinecolumn/BooleanInlineIndexColumn.java | 68 --
.../inlinecolumn/ByteInlineIndexColumn.java | 68 --
.../inlinecolumn/DateInlineIndexColumn.java | 69 --
.../inlinecolumn/DoubleInlineIndexColumn.java | 68 --
.../inlinecolumn/FloatInlineIndexColumn.java | 68 --
.../inlinecolumn/InlineIndexColumnFactory.java | 238 -----
.../inlinecolumn/IntegerInlineIndexColumn.java | 68 --
.../inlinecolumn/LongInlineIndexColumn.java | 68 --
.../inlinecolumn/ObjectHashInlineIndexColumn.java | 175 ----
.../inlinecolumn/ShortInlineIndexColumn.java | 68 --
.../inlinecolumn/TimeInlineIndexColumn.java | 69 --
.../inlinecolumn/TimestampInlineIndexColumn.java | 83 --
.../inlinecolumn/UuidInlineIndexColumn.java | 81 --
.../h2/database/io/AbstractH2ExtrasInnerIO.java | 169 ----
.../h2/database/io/AbstractH2ExtrasLeafIO.java | 166 ----
.../defragmentation/IndexingDefragmentation.java | 495 ----------
.../processors/query/h2/index/H2RowComparator.java | 135 +++
.../query/h2/index/QueryIndexDefinition.java | 206 +++++
.../h2/index/QueryIndexKeyDefinitionProvider.java | 80 ++
.../query/h2/index/QueryIndexRowHandler.java | 172 ++++
.../query/h2/index/QueryRowHandlerFactory.java | 48 +
.../h2/index/client/ClientIndexDefinition.java | 79 ++
.../query/h2/index/client/ClientIndexFactory.java | 57 ++
.../query/h2/index/client/ClientInlineIndex.java | 153 ++++
.../query/h2/index/keys/DateIndexKey.java | 58 ++
.../query/h2/index/keys/H2ValueWrapperMixin.java | 44 +
.../query/h2/index/keys/TimeIndexKey.java | 58 ++
.../query/h2/index/keys/TimestampIndexKey.java | 63 ++
.../processors/query/h2/opt/GridH2Table.java | 210 ++---
.../processors/query/h2/opt/H2CacheRow.java | 2 +-
.../internal/processors/query/h2/opt/H2Row.java | 3 +-
.../processors/query/h2/opt/join/RangeSource.java | 12 +-
.../org/apache/ignite/client/ClientTestSuite.java | 2 +
.../CacheGroupMetricsWithIndexBuildFailTest.java | 12 +-
.../cache/index/AbstractIndexingCommonTest.java | 11 +-
.../processors/cache/index/BasicIndexTest.java | 56 +-
.../DynamicEnableIndexingConcurrentSelfTest.java | 21 +-
.../index/DynamicIndexAbstractBasicSelfTest.java | 2 +-
.../cache/index/ForceRebuildIndexTest.java | 317 +++++++
.../cache/index/H2RowCachePageEvictionTest.java | 14 +-
.../processors/cache/index/H2RowCacheSelfTest.java | 26 +-
.../index/H2TreeCorruptedTreeExceptionTest.java | 5 +-
.../processors/cache/index/IndexMetricsTest.java | 10 +-
.../cache/index/IndexesRebuildTaskEx.java | 207 +++++
.../cache/index/StopRebuildIndexTest.java | 311 +++++++
.../IgnitePdsIndexingDefragmentationTest.java | 20 +-
.../db/LongDestroyDurableBackgroundTaskTest.java | 247 ++---
.../MultipleParallelCacheDeleteDeadlockTest.java | 157 ++--
.../persistence/db/wal/IgniteWalRecoveryTest.java | 3 +-
.../CleanupIndexTreeCheckpointFailoverTest.java | 127 +++
.../processors/query/SqlSystemViewsSelfTest.java | 9 +-
.../query/WrongQueryEntityFieldTypeTest.java | 3 +
.../query/h2/GridIndexRebuildSelfTest.java | 31 +-
.../inlinecolumn/InlineIndexColumnTest.java | 166 ++--
.../IgniteBinaryCacheQueryTestSuite.java | 5 +-
...teCacheWithIndexingAndPersistenceTestSuite.java | 4 +-
.../testsuites/IgnitePdsWithIndexingTestSuite.java | 6 +-
.../KubernetesDiscoveryAbstractTest.java} | 64 +-
.../discovery/TestClusterClientConnection.java | 52 ++
.../TestKubernetesIpFinderDisconnection.java | 123 +++
.../testsuites/IgniteKubernetesTestSuite.java | 4 +-
.../cpp/examples/include/ignite/examples/person.h | 2 +-
.../examples/query-example/src/query_example.cpp | 4 +-
.../Cache/CacheTestAsyncAwait.cs | 115 +++
.../Cache/Query/Linq/CacheLinqTest.Base.cs | 31 +
.../Cache/Query/Linq/CacheLinqTest.Strings.cs | 71 ++
.../Client/Cache/CacheTestAsyncAwait.cs | 2 +-
.../Compute/CancellationTest.cs | 2 +-
.../Compute/ComputeApiTest.cs | 6 +-
.../ComputeTestAsyncAwait.cs} | 29 +-
.../Config/full-config.xml | 2 +-
.../Config/spring-test.xml | 4 +
.../IgniteConfigurationSerializerTest.cs | 5 +-
.../IgniteConfigurationTest.cs | 2 +
.../Apache.Ignite.Core.Tests/ProjectFilesTest.cs | 16 +-
.../Services/PlatformTestService.cs | 1 +
.../Apache.Ignite.Core.Tests/TestUtilsJni.cs | 21 +
.../Apache.Ignite.Core/Apache.Ignite.Core.csproj | 1 +
.../Configuration/AsyncContinuationExecutor.cs | 60 ++
.../Apache.Ignite.Core/IgniteConfiguration.cs | 17 +-
.../IgniteConfigurationSection.xsd | 12 +
.../Impl/Compute/ComputeTaskHolder.cs | 20 +-
.../Apache.Ignite.Core/Impl/Unmanaged/Jni/Env.cs | 2 +-
.../Apache.Ignite.Linq/Impl/MethodVisitor.cs | 54 ++
modules/platforms/dotnet/DEVNOTES.txt | 6 +-
modules/platforms/dotnet/build.ps1 | 2 +-
modules/platforms/dotnet/release/verify-nuget.ps1 | 2 +-
.../org/apache/ignite/spark/impl/QueryHelper.scala | 2 +-
.../org/apache/ignite/spark/impl/QueryHelper.scala | 2 +-
.../jdbc/NativeJavaApiPutRemoveBenchmark.java | 2 +-
.../jdbc/NativeSqlInsertDeleteBenchmark.java | 2 +-
.../zk/internal/ZookeeperDiscoveryStatistics.java | 18 +-
parent/pom.xml | 4 +-
pom.xml | 1 +
546 files changed, 26528 insertions(+), 10083 deletions(-)