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 2020/05/25 08:08:26 UTC
[ignite] 11/24: 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 eb0109fb0e92966848b1e6a85a014f90361a97c9
Merge: 84c302b 4bb210d
Author: Nikolay Izhikov <ni...@apache.org>
AuthorDate: Mon May 4 23:58:21 2020 +0300
Merge branch 'master' into ignite-ducktape
.travis.yml | 54 +
README.md | 76 +-
checkstyle/checkstyle-suppressions.xml | 6 +-
checkstyle/checkstyle.xml | 54 +
.../hibernate/HibernateL2CacheExample.java | 4 +-
.../ignite/examples/datagrid/hibernate/Post.java | 2 +-
.../ignite/examples/datagrid/hibernate/User.java | 2 +-
.../failover/ComputeFailoverExample.java | 2 +-
.../examples/datastructures/IgniteLockExample.java | 4 +-
.../examples/misc/lifecycle/LifecycleExample.java | 2 +-
.../spark/LogRegFromSparkThroughPMMLExample.java | 2 +-
...eeClassificationTrainerSQLInferenceExample.java | 11 +-
...onTreeClassificationTrainerSQLTableExample.java | 11 +-
.../ignite/examples/ml/util/SandboxMLCache.java | 6 +-
.../ignite/examples/spark/SharedRDDExample.java | 2 +-
.../gridify/aop/spring/GridifySpringAspect.java | 2 +-
.../ignite/gridify/GridifySetToValueTarget.java | 4 +-
.../GridifySetToXXXNonSpringAopSelfTest.java | 2 +-
.../gridify/GridifySetToXXXSpringAopSelfTest.java | 2 +-
.../ignite/gridify/NonSpringAopSelfTest.java | 2 +-
.../apache/ignite/gridify/SpringAopSelfTest.java | 2 +-
.../org/apache/ignite/gridify/TestAopTarget.java | 16 +-
.../ignite/gridify/TestAopTargetInterface.java | 16 +-
.../apache/ignite/gridify/hierarchy/Target.java | 4 +-
.../org/apache/ignite/p2p/P2PGridifySelfTest.java | 6 +-
.../java/org/test/gridify/ExternalAopTarget.java | 16 +-
.../test/gridify/ExternalNonSpringAopSelfTest.java | 4 +-
.../ignite/spi/checkpoint/s3/S3CheckpointSpi.java | 2 +-
.../spi/checkpoint/s3/S3CheckpointSpiSelfTest.java | 2 +-
.../SmallHashSetsVsReadOnlyViewBenchmark.java | 6 +-
.../GridDhtPartitionsStateValidatorBenchmark.java | 2 +-
.../misc/JmhPartitionUpdateCounterBenchmark.java | 4 +-
.../jmh/notify/JmhWaitStategyBenchmark.java | 2 +-
.../jol/GridAffinityAssignmentJolBenchmark.java | 8 +-
.../benchmarks/jol/GridMetricsJolBenchmark.java | 24 +-
.../cache/store/cassandra/CassandraCacheStore.java | 2 +-
.../cassandra/session/CassandraSessionImpl.java | 10 +-
.../tests/CassandraDirectPersistenceTest.java | 4 +-
.../apache/ignite/tests/load/LoadTestDriver.java | 4 +-
.../apache/ignite/tests/load/PersonGenerator.java | 2 +-
.../client/ClientReconnectionSelfTest.java | 2 +-
.../internal/client/ClientStartNodeTask.java | 2 +-
.../ignite/internal/client/ClientStopNodeTask.java | 2 +-
...pTaskExecutionAfterTopologyRestartSelfTest.java | 2 +-
.../ClientAbstractConnectivitySelfTest.java | 2 +-
.../client/integration/ClientAbstractSelfTest.java | 4 +-
.../client/router/TcpRouterAbstractSelfTest.java | 4 +-
.../client/util/ClientConsistentHashSelfTest.java | 2 +-
.../apache/ignite/internal/jdbc2/JdbcBlobTest.java | 4 +-
.../internal/jdbc2/JdbcConnectionSelfTest.java | 2 +-
.../jdbc2/JdbcDynamicIndexAbstractSelfTest.java | 6 +-
.../internal/jdbc2/JdbcMetadataSelfTest.java | 4 +-
.../internal/jdbc2/JdbcResultSetSelfTest.java | 2 +-
.../internal/jdbc2/JdbcStatementSelfTest.java | 4 +-
.../rest/JettyRestProcessorAbstractSelfTest.java | 783 ++++++++++++-
.../rest/JettyRestProcessorCommonSelfTest.java | 13 +-
.../rest/RestBinaryProtocolSelfTest.java | 8 +-
.../jdbc/suite/IgniteJdbcDriverTestSuite.java | 3 +
.../jdbc/thin/JdbcThinComplexDmlDdlSelfTest.java | 4 +-
.../JdbcThinConnectionMultipleAddressesTest.java | 2 +-
.../jdbc/thin/JdbcThinConnectionSelfTest.java | 24 +-
.../thin/JdbcThinConnectionTimeoutSelfTest.java | 2 +-
.../thin/JdbcThinDynamicIndexAbstractSelfTest.java | 4 +-
.../ignite/jdbc/thin/JdbcThinErrorsSelfTest.java | 2 +-
.../jdbc/thin/JdbcThinInsertStatementSelfTest.java | 2 +-
.../jdbc/thin/JdbcThinLocalQueriesSelfTest.java | 2 +-
.../ignite/jdbc/thin/JdbcThinMetadataSelfTest.java | 8 +-
.../thin/JdbcThinMissingLongArrayResultsTest.java | 2 +-
.../jdbc/thin/JdbcThinNoDefaultSchemaTest.java | 14 +-
.../thin/JdbcThinPartitionAwarenessSelfTest.java | 6 +-
...ThinPartitionAwarenessTransactionsSelfTest.java | 4 +-
.../jdbc/thin/JdbcThinResultSetSelfTest.java | 2 +-
.../jdbc/thin/JdbcThinStatementSelfTest.java | 4 +-
.../thin/JdbcThinStatementTimeoutSelfTest.java | 4 +-
.../thin/JdbcThinStreamingAbstractSelfTest.java | 2 +-
.../thin/JdbcThinTransactionsLeaksMvccTest.java | 4 +-
.../jdbc/thin/JdbcThinTransactionsSelfTest.java | 2 +-
...dbcThinTransactionsWithMvccEnabledSelfTest.java | 2 +-
.../loadtests/client/ClientCacheBenchmark.java | 8 +-
.../org/apache/ignite/qa/QaJdbcTestSuite.java} | 9 +-
.../qa/query/WarningOnBigQueryResultsBaseTest.java | 288 +++++
.../qa/query/WarningOnBigQueryResultsTest.java | 317 +++++
.../ignite/codegen/MessageCodeGenerator.java | 14 +-
...IgnitePersistenceCompatibilityAbstractTest.java | 2 +-
.../junits/IgniteCompatibilityAbstractTest.java | 2 +-
.../compress/CompressionProcessorImpl.java | 8 +-
.../AbstractPageCompressionIntegrationTest.java | 2 +-
.../src/main/java/org/apache/ignite/Ignite.java | 5 +
.../apache/ignite/IgniteJdbcThinDataSource.java | 4 +-
.../java/org/apache/ignite/IgniteSnapshot.java | 42 +
.../org/apache/ignite/IgniteSystemProperties.java | 22 +-
.../src/main/java/org/apache/ignite/Ignition.java | 55 +-
.../java/org/apache/ignite/cache/CacheManager.java | 14 +-
.../java/org/apache/ignite/cache/QueryEntity.java | 2 +-
.../rendezvous/RendezvousAffinityFunction.java | 4 +-
.../cache/eviction/AbstractEvictionPolicy.java | 4 +-
.../cache/store/jdbc/CacheJdbcBlobStore.java | 2 +-
.../org/apache/ignite/client/ClientCluster.java} | 12 +-
.../ClientClusterGroup.java} | 26 +-
.../org/apache/ignite/client/ClientCompute.java | 84 ++
.../org/apache/ignite/client/ClientException.java | 4 +-
...lientFeatureNotSupportedByServerException.java} | 18 +-
.../org/apache/ignite/client/IgniteClient.java | 24 +
.../ignite/configuration/IgniteConfiguration.java | 31 +
.../configuration/ThinClientConfiguration.java | 28 +
.../local/LocalIgfsSecondaryFileSystem.java | 4 +-
.../org/apache/ignite/internal/GridDiagnostic.java | 11 -
.../ignite/internal/GridEventConsumeHandler.java | 2 +-
.../apache/ignite/internal/GridJobContextImpl.java | 4 +-
.../apache/ignite/internal/GridJobSiblingImpl.java | 8 +-
.../ignite/internal/GridTaskSessionImpl.java | 2 +-
.../java/org/apache/ignite/internal/GridTopic.java | 14 +-
.../org/apache/ignite/internal/IgniteFeatures.java | 3 +
.../org/apache/ignite/internal/IgniteKernal.java | 15 +-
.../org/apache/ignite/internal/IgnitionEx.java | 27 +-
.../ignite/internal/MarshallerContextImpl.java | 97 +-
.../internal/MarshallerMappingFileStore.java | 31 +-
.../ignite/internal/SecurityAwareBiPredicate.java | 17 +-
.../ignite/internal/ThinProtocolFeature.java | 72 ++
.../ignite/internal/binary/BinaryPrimitives.java | 2 +-
.../binary/BinaryReaderHandlesHolderImpl.java | 2 +-
.../ignite/internal/binary/BinaryTreeMap.java | 2 +-
.../ignite/internal/binary/BinaryTreeSet.java | 2 +-
.../apache/ignite/internal/binary/BinaryUtils.java | 8 +-
.../ignite/internal/binary/BinaryWriterExImpl.java | 4 +-
.../binary/builder/BinaryBuilderReader.java | 4 +-
.../client/GridClientPartitionAffinity.java | 2 +-
.../client/impl/GridClientComputeImpl.java | 2 +-
.../connection/GridClientNioTcpConnection.java | 6 +-
.../GridClientZipOptimizedMarshaller.java | 4 +-
.../client/thin/ClientCacheAffinityMapping.java | 2 +-
.../ignite/internal/client/thin/ClientChannel.java | 26 +-
.../client/thin/ClientClusterGroupImpl.java | 67 ++
.../internal/client/thin/ClientClusterImpl.java} | 19 +-
.../internal/client/thin/ClientComputeImpl.java | 423 +++++++
.../internal/client/thin/ClientFutureImpl.java | 117 ++
.../internal/client/thin/ClientOperation.java | 42 +-
.../ignite/internal/client/thin/ClientUtils.java | 31 +-
.../client/thin/NotificationListener.java} | 22 +-
.../client/thin/ProtocolBitmaskFeature.java | 94 ++
.../internal/client/thin/ProtocolContext.java | 78 ++
.../internal/client/thin/ProtocolVersion.java | 9 +-
.../client/thin/ProtocolVersionFeature.java | 67 ++
.../internal/client/thin/ReliableChannel.java | 80 +-
.../internal/client/thin/TcpClientCache.java | 12 +-
.../internal/client/thin/TcpClientChannel.java | 347 ++++--
.../client/thin/TcpClientTransactions.java | 12 +-
.../internal/client/thin/TcpIgniteClient.java | 36 +-
.../client/util/GridClientConsistentHash.java | 8 +-
.../client/util/GridConcurrentHashSet.java | 2 +-
.../cluster/DistributedBaselineConfiguration.java | 45 +-
.../cluster/DistributedConfigurationUtils.java | 77 ++
.../ignite/internal/cluster/IgniteClusterImpl.java | 2 +-
.../commandline/ClusterStateChangeCommand.java | 2 +-
.../internal/commandline/CommandHandler.java | 2 +-
.../ignite/internal/commandline/StateCommand.java | 2 +-
.../internal/commandline/cache/CacheCommands.java | 2 +-
.../commandline/cache/CacheValidateIndexes.java | 137 ++-
.../internal/commandline/cache/CacheViewer.java | 2 +-
.../cache/argument/ValidateIndexesCommandArg.java | 9 +-
.../internal/dto/IgniteDataTransferObject.java | 5 +-
.../ignite/internal/igfs/common/IgfsLogger.java | 2 +-
.../jdbc/thin/ConnectionPropertiesImpl.java | 14 +-
.../internal/jdbc/thin/JdbcThinConnection.java | 19 +-
.../internal/jdbc/thin/JdbcThinResultSet.java | 6 +-
.../org/apache/ignite/internal/jdbc2/JdbcBlob.java | 6 +-
.../internal/jdbc2/JdbcDatabaseMetadata.java | 2 +-
.../ignite/internal/jdbc2/JdbcResultSet.java | 2 +-
.../ignite/internal/jdbc2/JdbcStatement.java | 4 +-
.../internal/managers/IgniteMBeansManager.java | 6 +
.../managers/communication/GridIoManager.java | 14 +-
.../deployment/GridDeploymentInfoBean.java | 4 +-
.../internal/managers/discovery/DiscoCache.java | 6 +-
.../DiscoveryMessageResultsCollector.java | 2 +-
.../managers/discovery/GridDiscoveryManager.java | 46 +-
.../managers/encryption/GridEncryptionManager.java | 2 +-
.../optimized/OptimizedClassDescriptor.java | 2 +-
.../optimized/OptimizedObjectInputStream.java | 4 +-
.../optimized/OptimizedObjectOutputStream.java | 2 +-
.../internal/metric/IoStatisticsHolderCache.java | 2 +-
.../internal/mxbean/IgniteStandardMXBean.java | 2 +-
.../ignite/internal/pagemem/PageIdUtils.java | 5 +-
.../ignite/internal/pagemem/store/PageStore.java | 16 +-
.../internal/pagemem/store/PageWriteListener.java} | 26 +-
.../pagemem/wal/record/MetastoreDataRecord.java | 2 +
.../pagemem/wal/record/UnwrapDataEntry.java | 14 +-
.../pagemem/wal/record/UnwrapMvccDataEntry.java | 14 +-
.../internal/pagemem/wal/record/WALRecord.java | 122 +-
...ageInitRootInlineFlagsCreatedVersionRecord.java | 4 +-
.../delta/MetaPageUpdatePartitionDataRecord.java | 2 +-
.../record/delta/PageListMetaResetCountRecord.java | 2 +-
.../affinity/GridAffinityAssignmentV2.java | 4 +-
.../processors/affinity/GridAffinityMessage.java | 4 +-
.../processors/affinity/GridAffinityProcessor.java | 2 +-
.../authentication/UserManagementOperation.java | 2 +-
.../bulkload/pipeline/CharsetDecoderBlock.java | 2 +-
.../cache/CacheAffinitySharedManager.java | 2 +-
.../processors/cache/CacheDiagnosticManager.java | 2 +-
.../internal/processors/cache/CacheEntryImpl0.java | 2 +-
.../processors/cache/CacheEvictableEntryImpl.java | 2 +-
.../processors/cache/CacheGroupContext.java | 18 +-
.../processors/cache/CacheIteratorConverter.java | 2 +-
.../processors/cache/CacheMetricsImpl.java | 8 +-
.../cache/CacheOsConflictResolutionManager.java | 2 +-
.../cache/CacheWeakQueryIteratorsHolder.java | 4 +-
.../processors/cache/ClusterCachesInfo.java | 26 +-
.../cache/DynamicCacheChangeRequest.java | 2 +-
.../internal/processors/cache/ExchangeContext.java | 6 +-
.../processors/cache/ExchangeDiscoveryEvents.java | 25 +-
.../processors/cache/GridCacheAdapter.java | 5 +
.../processors/cache/GridCacheCompoundFuture.java | 2 +-
.../cache/GridCacheCompoundIdentityFuture.java | 2 +-
.../processors/cache/GridCacheContext.java | 10 +-
.../cache/GridCacheDefaultAffinityKeyMapper.java | 2 +-
.../cache/GridCacheDeploymentManager.java | 6 +-
.../cache/GridCacheExplicitLockSpan.java | 2 +-
.../processors/cache/GridCacheFutureAdapter.java | 2 +-
.../processors/cache/GridCacheGateway.java | 2 +-
.../processors/cache/GridCacheIoManager.java | 2 +-
.../processors/cache/GridCacheMapEntry.java | 6 +-
.../processors/cache/GridCacheMessage.java | 4 +-
.../internal/processors/cache/GridCacheMvcc.java | 4 +-
.../cache/GridCachePartitionExchangeManager.java | 9 +-
.../processors/cache/GridCacheProcessor.java | 7 +-
.../internal/processors/cache/GridCacheReturn.java | 2 +-
.../processors/cache/GridCacheSharedContext.java | 19 +-
.../processors/cache/GridCacheTtlManager.java | 2 +-
.../internal/processors/cache/GridCacheUtils.java | 8 +-
.../cache/GridDeferredAckMessageSender.java | 2 +-
.../cache/IgniteCacheOffheapManagerImpl.java | 10 +-
.../processors/cache/IgniteCacheProxyImpl.java | 4 +-
.../cache/PartitionUpdateCounterDebugWrapper.java | 5 +
.../cache/PartitionUpdateCounterVolatileImpl.java | 2 +-
.../cache/ValidationOnNodeJoinUtils.java | 2 +-
.../internal/processors/cache/WalStateManager.java | 6 +-
.../cache/binary/BinaryMetadataFileStore.java | 33 +-
.../binary/CacheObjectBinaryProcessorImpl.java | 65 +-
.../datastructures/CacheDataStructuresManager.java | 8 +-
.../distributed/GridCacheTtlUpdateRequest.java | 4 +-
.../dht/CacheDistributedGetFutureAdapter.java | 2 +-
.../cache/distributed/dht/GridDhtCacheAdapter.java | 4 +-
.../cache/distributed/dht/GridDhtCacheEntry.java | 2 +-
.../cache/distributed/dht/GridDhtLockFuture.java | 6 +-
.../dht/GridDhtTransactionalCacheAdapter.java | 2 +-
.../dht/GridDhtTxAbstractEnlistFuture.java | 6 +-
.../distributed/dht/GridDhtTxEnlistFuture.java | 2 +-
.../distributed/dht/GridDhtTxFinishRequest.java | 2 +-
.../distributed/dht/GridDhtTxPrepareFuture.java | 2 +-
.../dht/GridDhtTxQueryAbstractEnlistFuture.java | 2 +-
.../dht/GridDhtTxQueryEnlistRequest.java | 2 +-
.../cache/distributed/dht/GridDhtTxRemote.java | 2 +-
.../distributed/dht/GridPartitionedGetFuture.java | 2 +-
.../dht/GridPartitionedSingleGetFuture.java | 5 +-
.../dht/PartitionUpdateCountersMessage.java | 6 +-
.../distributed/dht/atomic/GridDhtAtomicCache.java | 17 +-
.../dht/atomic/GridDhtAtomicUpdateResponse.java | 2 +-
.../atomic/GridNearAtomicSingleUpdateFuture.java | 4 +-
.../dht/atomic/GridNearAtomicUpdateFuture.java | 4 +-
.../dht/atomic/GridNearAtomicUpdateResponse.java | 2 +-
.../cache/distributed/dht/atomic/UpdateErrors.java | 2 +-
.../dht/colocated/GridDhtColocatedCache.java | 15 +-
.../dht/colocated/GridDhtColocatedLockFuture.java | 4 +-
.../preloader/GridDhtPartitionsExchangeFuture.java | 34 +-
.../dht/preloader/latch/ExchangeLatchManager.java | 2 +-
.../dht/topology/GridClientPartitionTopology.java | 6 +-
.../dht/topology/GridDhtLocalPartition.java | 2 +-
.../dht/topology/GridDhtPartitionTopologyImpl.java | 10 +-
.../dht/topology/PartitionsEvictManager.java | 14 +-
.../cache/distributed/near/GridNearGetFuture.java | 3 +-
.../cache/distributed/near/GridNearLockFuture.java | 8 +-
.../distributed/near/GridNearLockRequest.java | 4 +-
.../near/GridNearOptimisticTxPrepareFuture.java | 2 +-
.../near/GridNearPessimisticTxPrepareFuture.java | 2 +-
.../near/GridNearTransactionalCache.java | 4 +-
.../near/GridNearTxAbstractEnlistFuture.java | 4 +-
.../distributed/near/GridNearTxEnlistRequest.java | 2 +-
.../cache/distributed/near/GridNearTxLocal.java | 7 +-
.../near/GridNearTxQueryResultsEnlistRequest.java | 2 +-
.../cache/distributed/near/NearTxFinishFuture.java | 2 +-
.../cache/local/atomic/GridLocalAtomicCache.java | 225 ++--
.../internal/processors/cache/mvcc/MvccUtils.java | 4 +-
.../processors/cache/mvcc/txlog/TxLog.java | 2 +-
.../processors/cache/mvcc/txlog/TxState.java | 8 +-
.../cache/persistence/CacheDataRowAdapter.java | 6 +-
.../cache/persistence/DataRegionMetricsImpl.java | 4 +-
.../cache/persistence/DataStorageMetricsImpl.java | 6 +-
.../persistence/DataStorageMetricsSnapshot.java | 2 +-
.../cache/persistence/DbCheckpointListener.java | 6 +
.../GridCacheDatabaseSharedManager.java | 32 +-
.../cache/persistence/GridCacheOffheapManager.java | 46 +-
.../IgniteCacheDatabaseSharedManager.java | 4 +-
.../cache/persistence/RecoveryDebug.java | 4 +-
.../persistence/checkpoint/CheckpointEntry.java | 2 +-
.../pagelocktracker/PageLockTracker.java | 8 +-
.../pagelocktracker/PageLockTrackerManager.java | 8 +-
.../pagelocktracker/log/PageLockLogSnapshot.java | 2 +-
.../store/OffHeapPageMetaInfoStore.java | 2 +-
.../cache/persistence/file/AsyncFileIO.java | 2 +-
.../cache/persistence/file/EncryptedFileIO.java | 4 +-
.../cache/persistence/file/FileIOFactory.java | 2 +-
.../cache/persistence/file/FilePageStore.java | 57 +-
.../persistence/file/FilePageStoreManager.java | 281 +++--
.../cache/persistence/file/FilePageStoreV2.java | 2 +-
.../cache/persistence/freelist/PagesList.java | 6 +-
.../persistence/freelist/io/PagesListNodeIO.java | 3 +-
.../metastorage/MetastorageRowStoreEntry.java | 2 +-
.../cache/persistence/pagemem/FullPageIdTable.java | 2 +-
.../cache/persistence/pagemem/PageMemoryImpl.java | 26 +-
.../pagemem/PagesWriteThrottlePolicy.java | 4 +-
.../persistence/partstate/GroupPartitionId.java | 2 +-
.../snapshot/IgniteCacheSnapshotManager.java | 6 +-
.../snapshot/IgniteSnapshotManager.java | 1233 ++++++++++++++++++++
.../persistence/snapshot/SnapshotFutureTask.java | 1010 ++++++++++++++++
.../persistence/snapshot/SnapshotMXBeanImpl.java} | 27 +-
.../cache/persistence/snapshot/SnapshotSender.java | 234 ++++
.../cache/persistence/tree/BPlusTree.java | 60 +-
.../persistence/tree/CorruptedTreeException.java | 2 +-
.../persistence/tree/io/AbstractDataPageIO.java | 6 +-
.../cache/persistence/tree/io/BPlusIO.java | 8 +-
.../cache/persistence/tree/io/BPlusLeafIO.java | 2 +-
.../cache/persistence/tree/io/BPlusMetaIO.java | 19 +-
.../cache/persistence/tree/io/DataPageIO.java | 4 +-
.../cache/persistence/tree/io/TrackingPageIO.java | 10 +-
.../persistence/tree/reuse/ReuseListImpl.java | 2 +-
.../persistence/wal/FileWriteAheadLogManager.java | 6 +-
.../persistence/wal/SegmentedRingByteBuffer.java | 4 +-
.../wal/filehandle/AbstractFileHandle.java | 2 +-
.../cache/persistence/wal/io/FileInput.java | 2 +-
.../wal/reader/IgniteWalIteratorFactory.java | 6 +-
.../wal/reader/StandaloneGridKernalContext.java | 5 +-
.../wal/serializer/RecordDataV1Serializer.java | 4 +-
.../wal/serializer/RecordV1Serializer.java | 2 +-
.../query/GridCacheDistributedQueryManager.java | 4 +-
.../CacheContinuousQueryAcknowledgeBuffer.java | 2 +-
.../continuous/CacheContinuousQueryHandler.java | 2 +-
.../CacheContinuousQueryPartitionRecovery.java | 2 +-
.../processors/cache/store/CacheStoreManager.java | 2 +-
.../cache/store/GridCacheStoreManagerAdapter.java | 4 +-
.../cache/store/GridCacheWriteBehindStore.java | 10 +-
.../cache/transactions/IgniteTxAdapter.java | 12 +-
.../cache/transactions/IgniteTxEntry.java | 2 +-
.../IgniteTxImplicitSingleStateImpl.java | 6 +-
.../cache/transactions/IgniteTxManager.java | 22 +-
.../processors/cache/tree/AbstractDataInnerIO.java | 2 +-
.../processors/cache/tree/CacheDataTree.java | 2 +-
.../processors/cache/tree/PendingEntriesTree.java | 2 +-
.../cache/tree/mvcc/data/MvccDataRow.java | 4 +-
.../cache/tree/mvcc/data/MvccUpdateDataRow.java | 10 +-
.../processors/cache/verify/ContentionClosure.java | 2 +-
.../cache/verify/IdleVerifyException.java | 2 +-
.../processors/cache/version/GridCacheVersion.java | 4 +-
.../cacheobject/IgniteCacheObjectProcessor.java | 8 +-
.../processors/closure/GridClosureProcessor.java | 16 +-
.../processors/cluster/BaselineTopology.java | 8 +-
.../cluster/BaselineTopologyHistory.java | 2 +-
.../cluster/DiscoveryDataClusterState.java | 4 +-
.../cluster/GridClusterStateProcessor.java | 4 +-
.../processors/cluster/GridUpdateNotifier.java | 6 +-
.../processors/compress/CompressionProcessor.java | 2 +-
.../continuous/GridContinuousProcessor.java | 4 +-
.../processors/datastreamer/DataStreamerImpl.java | 4 +-
.../datastructures/AtomicDataStructureProxy.java | 2 +-
.../datastructures/DataStructuresProcessor.java | 4 +-
.../datastructures/GridCacheAnnotationHelper.java | 4 +-
.../datastructures/GridCacheAtomicLongImpl.java | 2 +-
.../GridCacheAtomicSequenceImpl.java | 2 +-
.../datastructures/GridCacheLockImpl.java | 36 +-
.../datastructures/GridCacheLockState.java | 2 +-
.../datastructures/GridCacheQueueAdapter.java | 16 +-
.../datastructures/GridCacheQueueHeader.java | 4 +-
.../datastructures/GridCacheQueueItemKey.java | 4 +-
.../datastructures/GridCacheSemaphoreImpl.java | 4 +-
.../datastructures/GridCacheSetHeader.java | 4 +-
.../datastructures/GridCacheSetImpl.java | 2 +-
.../datastructures/GridCacheSetItemKey.java | 4 +-
.../datastructures/GridSetQueryPredicate.java | 4 +-
.../processors/hadoop/HadoopClassLoader.java | 2 +-
.../internal/processors/igfs/IgfsBlockKey.java | 8 +-
.../internal/processors/igfs/IgfsDataManager.java | 2 +-
.../internal/processors/igfs/IgfsEntryInfo.java | 4 +-
.../processors/igfs/IgfsFileAffinityRange.java | 4 +-
.../internal/processors/igfs/IgfsFileImpl.java | 2 +-
.../internal/processors/igfs/IgfsFileInfo.java | 8 +-
.../processors/igfs/IgfsFragmentizerManager.java | 2 +-
.../ignite/internal/processors/igfs/IgfsImpl.java | 6 +-
.../internal/processors/igfs/IgfsIpcHandler.java | 2 +-
.../internal/processors/igfs/IgfsListingEntry.java | 4 +-
.../internal/processors/igfs/IgfsMetaManager.java | 10 +-
.../processors/igfs/IgfsOutputStreamProxyImpl.java | 2 +-
.../internal/processors/igfs/IgfsTaskArgsImpl.java | 2 +-
.../internal/processors/igfs/IgfsThread.java | 2 +-
.../ignite/internal/processors/igfs/IgfsUtils.java | 4 +-
.../meta/IgfsClientMetaIdsForPathCallable.java | 2 +-
.../meta/IgfsClientMetaInfoForPathCallable.java | 2 +-
.../client/meta/IgfsClientMetaUnlockCallable.java | 2 +-
.../IgfsMetaDirectoryListingRemoveProcessor.java | 4 +-
.../IgfsMetaDirectoryListingReplaceProcessor.java | 4 +-
.../igfs/meta/IgfsMetaFileCreateProcessor.java | 8 +-
.../igfs/meta/IgfsMetaFileLockProcessor.java | 4 +-
.../igfs/secondary/local/LocalFileSystemUtils.java | 2 +-
.../marshaller/GridMarshallerMappingProcessor.java | 17 +-
.../marshaller/MarshallerMappingItem.java | 2 +-
.../internal/processors/metric/MetricRegistry.java | 2 +-
.../metric/PushMetricsExporterAdapter.java | 7 +-
.../processors/metric/impl/MetricUtils.java | 2 +-
.../processors/odbc/ClientListenerNioListener.java | 13 +-
.../odbc/ClientListenerNioServerBuffer.java | 5 +-
.../processors/odbc/ClientListenerProcessor.java | 2 +-
.../processors/odbc/ClientListenerResponse.java | 9 +-
.../odbc/jdbc/JdbcBatchExecuteResult.java | 4 +-
.../processors/odbc/jdbc/JdbcColumnMetaV2.java | 2 +-
.../odbc/jdbc/JdbcConnectionContext.java | 2 +-
.../processors/odbc/jdbc/JdbcIndexMeta.java | 2 +-
.../odbc/jdbc/JdbcMetaColumnsResult.java | 2 +-
.../odbc/jdbc/JdbcMetaIndexesResult.java | 2 +-
.../processors/odbc/jdbc/JdbcMetaParamsResult.java | 2 +-
.../odbc/jdbc/JdbcMetaPrimaryKeysResult.java | 2 +-
.../processors/odbc/jdbc/JdbcMetaTablesResult.java | 2 +-
.../processors/odbc/jdbc/JdbcQueryCursor.java | 2 +-
.../processors/odbc/jdbc/JdbcQueryFetchResult.java | 2 +-
.../odbc/jdbc/JdbcQueryMetadataResult.java | 2 +-
.../internal/processors/odbc/jdbc/JdbcRequest.java | 2 +-
.../processors/odbc/jdbc/JdbcRequestHandler.java | 2 +-
.../odbc/odbc/OdbcConnectionContext.java | 2 +-
.../processors/odbc/odbc/OdbcQueryCloseResult.java | 2 +-
.../processors/odbc/odbc/OdbcQueryFetchResult.java | 2 +-
.../odbc/odbc/OdbcQueryMoreResultsResult.java | 2 +-
.../processors/odbc/odbc/OdbcRequestHandler.java | 6 +-
.../internal/processors/odbc/odbc/OdbcTypes.java | 2 +-
.../processors/platform/PlatformProcessorImpl.java | 15 +-
.../platform/binary/PlatformBinaryProcessor.java | 2 +-
.../processors/platform/cache/PlatformCache.java | 6 +-
.../cache/PlatformCacheEntryProcessorImpl.java | 2 +-
.../cache/query/PlatformContinuousQueryProxy.java | 2 +-
.../platform/callback/PlatformCallbackGateway.java | 37 +-
.../platform/callback/PlatformCallbackOp.java | 6 +
.../platform/client/ClientBitmaskFeature.java | 64 +
.../platform/client/ClientConnectionContext.java | 96 +-
.../processors/platform/client/ClientFlag.java | 5 +-
.../platform/client/ClientMessageParser.java | 39 +-
.../platform/client/ClientNotification.java | 105 ++
.../platform/client/ClientObjectNotification.java} | 31 +-
.../client/ClientOutgoingMessage.java} | 26 +-
.../platform/client/ClientProtocolContext.java | 87 ++
.../client/ClientProtocolVersionFeature.java | 66 ++
.../platform/client/ClientRequestHandler.java | 21 +-
.../processors/platform/client/ClientResponse.java | 13 +-
.../processors/platform/client/ClientStatus.java | 8 +-
.../cache/ClientCacheConfigurationSerializer.java | 211 +++-
.../ClientCacheCreateWithConfigurationRequest.java | 8 +-
.../cache/ClientCacheGetConfigurationRequest.java | 18 +-
.../cache/ClientCacheGetConfigurationResponse.java | 16 +-
...ntCacheGetOrCreateWithConfigurationRequest.java | 8 +-
.../ClientClusterGroupGetNodeIdsRequest.java | 9 +-
.../ClientClusterGroupGetNodesDetailsResponse.java | 5 +-
.../platform/client/compute/ClientComputeTask.java | 166 +++
.../ClientExecuteTaskRequest.java} | 65 +-
.../ClientExecuteTaskResponse.java} | 33 +-
.../platform/cluster/PlatformClusterGroup.java | 29 +-
.../platform/compute/PlatformAbstractFunc.java | 103 ++
...PlatformBalancingSingleClosureAffinityTask.java | 89 --
.../platform/compute/PlatformCallable.java} | 45 +-
.../platform/compute/PlatformClosureJob.java | 2 +
.../platform/compute/PlatformCompute.java | 91 +-
.../platform/compute/PlatformRunnable.java | 55 +
.../platform/dotnet/PlatformDotNetCacheStore.java | 2 +-
.../dotnet/PlatformDotNetConfigurationClosure.java | 4 +-
.../platform/messaging/PlatformMessaging.java | 4 +-
.../platform/services/PlatformServices.java | 6 +-
.../platform/utils/PlatformConfigurationUtils.java | 126 +-
.../processors/platform/utils/PlatformUtils.java | 23 +-
.../query/GridQueryFieldsResultAdapter.java | 2 +-
.../processors/query/GridQueryIndexing.java | 5 +-
.../processors/query/GridQueryProcessor.java | 33 +-
.../processors/query/GridRunningQueryInfo.java | 2 +-
.../internal/processors/query/QueryTypeIdKey.java | 2 +-
.../internal/processors/query/QueryUtils.java | 12 +-
.../processors/query/RunningQueryManager.java | 2 +-
.../processors/query/TableInformation.java | 2 +-
.../messages/GridQueryNextPageResponse.java | 2 +-
.../query/messages/GridQueryKillResponse.java | 2 +-
.../query/schema/SchemaIndexCacheVisitorImpl.java | 12 +-
.../processors/rest/GridRestProcessor.java | 2 +-
.../client/message/GridClientStateRequest.java | 2 +-
.../handlers/cache/GridCacheCommandHandler.java | 3 +-
.../rest/handlers/query/QueryCommandHandler.java | 3 +
.../redis/key/GridRedisExpireCommandHandler.java | 2 +-
.../redis/server/GridRedisFlushCommandHandler.java | 2 +-
.../version/GridVersionCommandHandler.java | 2 +-
.../protocols/tcp/GridTcpMemcachedNioListener.java | 2 +-
.../processors/rest/request/RestQueryRequest.java | 17 +
.../processors/security/GridSecurityProcessor.java | 24 +-
.../security/IgniteSecurityProcessor.java | 49 +-
.../security/NoOpIgniteSecurityProcessor.java | 2 +-
.../processors/security/SecurityContext.java | 2 +-
.../processors/security/SecurityUtils.java | 17 +
.../processors/service/GridServiceProcessor.java | 6 +-
.../processors/task/GridTaskProcessor.java | 4 +-
.../internal/processors/task/GridTaskWorker.java | 4 +-
.../org/apache/ignite/internal/sql/SqlLexer.java | 2 +-
.../ignite/internal/sql/SqlParseException.java | 2 +-
.../org/apache/ignite/internal/sql/SqlParser.java | 2 +-
.../internal/sql/command/SqlAlterTableCommand.java | 2 +-
.../affinity/PartitionResultMarshaler.java | 2 +-
.../apache/ignite/internal/util/GridArrays.java | 4 +-
.../ignite/internal/util/GridConsistentHash.java | 8 +-
.../org/apache/ignite/internal/util/GridDebug.java | 4 +-
.../apache/ignite/internal/util/GridIntList.java | 2 +-
.../apache/ignite/internal/util/GridLongList.java | 2 +-
.../internal/util/GridMultiCollectionWrapper.java | 4 +-
.../ignite/internal/util/GridSetWrapper.java | 2 +-
.../ignite/internal/util/GridSnapshotLock.java | 2 +-
.../ignite/internal/util/GridStringBuilder.java | 4 +-
.../apache/ignite/internal/util/GridUnsafe.java | 4 +-
.../apache/ignite/internal/util/IgniteUtils.java | 106 +-
.../ignite/internal/util/OffheapReadWriteLock.java | 2 +-
.../ignite/internal/util/StripedExecutor.java | 10 +-
.../internal/util/collection/IntHashMap.java | 2 +-
.../util/distributed/DistributedProcess.java | 50 +-
.../internal/util/distributed/InitMessage.java | 4 +-
.../internal/util/future/GridFutureAdapter.java | 10 +-
.../internal/util/future/IgniteFutureImpl.java | 2 +-
.../ignite/internal/util/io/GridFilenameUtils.java | 12 +-
.../util/io/GridReversedLinesFileReader.java | 18 +-
.../ipc/shmem/IpcSharedMemoryServerEndpoint.java | 2 +-
.../apache/ignite/internal/util/lang/GridFunc.java | 4 +-
.../util/lang/GridMetadataAwareAdapter.java | 2 +-
.../internal/util/lang/GridNodePredicate.java | 2 +-
.../util/nodestart/IgniteNodeStartUtils.java | 2 +-
.../util/offheap/unsafe/GridUnsafeMap.java | 2 +-
.../internal/util/test/GridTestPrintStream.java | 2 +-
.../util/tostring/CircularStringBuilder.java | 2 +-
.../org/apache/ignite/internal/util/typedef/X.java | 2 +-
.../internal/visor/VisorDataTransferObject.java | 4 +-
.../binary/VisorBinaryMetadataCollectorTask.java | 2 +-
.../ignite/internal/visor/cache/VisorCache.java | 4 +-
.../visor/cache/VisorCacheConfiguration.java | 4 +-
.../cache/VisorCacheLostPartitionsTaskArg.java | 2 +-
.../VisorCacheResetLostPartitionsTaskArg.java | 2 +-
.../internal/visor/cache/VisorCacheStartTask.java | 2 +-
...orFindAndDeleteGarbageInPersistenceClosure.java | 4 +-
.../compute/VisorComputeCancelSessionTaskArg.java | 4 +-
.../internal/visor/compute/VisorGatewayTask.java | 4 +-
.../internal/visor/debug/VisorThreadInfo.java | 2 +-
.../diagnostic/VisorPageLocksTrackerArgs.java | 2 +-
.../internal/visor/event/VisorGridEvent.java | 4 +-
.../internal/visor/event/VisorGridJobEvent.java | 8 +-
.../internal/visor/event/VisorGridTaskEvent.java | 4 +-
.../ignite/internal/visor/misc/VisorWalTask.java | 12 +-
.../internal/visor/misc/VisorWalTaskArg.java | 2 +-
.../node/VisorCacheRebalanceCollectorTask.java | 2 +-
.../visor/node/VisorLifecycleConfiguration.java | 2 +-
.../node/VisorNodeEventsCollectorTaskArg.java | 4 +-
.../visor/node/VisorSqlConnectorConfiguration.java | 2 +-
.../internal/visor/node/VisorSuppressedError.java | 2 +-
.../internal/visor/query/VisorQueryUtils.java | 2 +-
.../internal/visor/tx/FetchNearXidVersionTask.java | 2 +-
.../ignite/internal/visor/tx/TxVerboseId.java | 4 +-
.../ignite/internal/visor/tx/VisorTxInfo.java | 8 +-
.../internal/visor/tx/VisorTxProjection.java | 2 +-
.../ignite/internal/visor/tx/VisorTxTask.java | 6 +-
.../ignite/internal/visor/util/VisorTaskUtils.java | 2 +-
.../verify/ValidateIndexesCheckSizeIssue.java | 107 ++
.../verify/ValidateIndexesCheckSizeResult.java | 101 ++
.../verify/VisorValidateIndexesJobResult.java | 78 +-
.../visor/verify/VisorValidateIndexesTaskArg.java | 81 +-
.../java/org/apache/ignite/lang/IgniteUuid.java | 20 +-
.../org/apache/ignite/logger/java/JavaLogger.java | 2 +-
.../ignite/messaging/MessagingListenActor.java | 2 +-
.../ignite/mxbean/DataStorageMetricsMXBean.java | 2 +-
.../org/apache/ignite/mxbean/IgniteMXBean.java | 2 +-
.../org/apache/ignite/mxbean/SnapshotMXBean.java} | 21 +-
.../org/apache/ignite/plugin/PluginProvider.java | 2 +-
.../plugin/security/AuthenticationContext.java | 2 +-
.../spi/ExponentialBackoffTimeoutStrategy.java | 2 +-
.../org/apache/ignite/spi/IgniteSpiAdapter.java | 4 +-
.../spi/checkpoint/jdbc/JdbcCheckpointSpi.java | 6 +-
.../priorityqueue/PriorityQueueCollisionSpi.java | 2 +-
.../spi/communication/tcp/TcpCommunicationSpi.java | 22 +-
.../TcpCommunicationConnectionCheckFuture.java | 2 +-
.../spi/deployment/DeploymentResourceAdapter.java | 4 +-
.../ignite/spi/discovery/tcp/ClientImpl.java | 82 +-
.../ignite/spi/discovery/tcp/ServerImpl.java | 96 +-
.../ignite/spi/discovery/tcp/TcpDiscoveryImpl.java | 56 +-
.../ignite/spi/discovery/tcp/TcpDiscoverySpi.java | 2 +-
.../tcp/internal/DiscoveryDataPacket.java | 2 +-
.../tcp/internal/TcpDiscoveryStatistics.java | 4 +-
.../encryption/keystore/KeystoreEncryptionSpi.java | 4 +-
.../spi/metric/jmx/JmxMetricExporterSpi.java | 2 +-
.../systemview/jmx/JmxSystemViewExporterSpi.java | 2 +-
.../ignite/spi/systemview/jmx/SystemViewMBean.java | 4 +-
.../apache/ignite/startup/cmdline/AboutDialog.java | 2 +-
.../org/apache/ignite/stream/StreamVisitor.java | 2 +-
.../main/resources/META-INF/classnames.properties | 7 +-
.../java/org/apache/ignite/GridTestIoUtils.java | 2 +-
.../test/java/org/apache/ignite/GridTestTask.java | 2 +-
.../ignite/cache/IgniteWarmupClosureSelfTest.java | 2 +-
.../ignite/cache/ResetLostPartitionTest.java | 2 +-
.../RendezvousAffinityFunctionSimpleBenchmark.java | 2 +-
.../jdbc/CacheJdbcPojoStoreAbstractSelfTest.java | 8 +-
...CacheJdbcPojoStoreBinaryMarshallerSelfTest.java | 4 +-
...StoreBinaryMarshallerWithSqlEscapeSelfTest.java | 2 +-
.../cache/store/jdbc/CacheJdbcPojoStoreTest.java | 4 +-
...acheJdbcStoreAbstractMultithreadedSelfTest.java | 2 +-
.../org/apache/ignite/client/FunctionalTest.java | 2 +-
.../failure/FailureHandlerTriggeredTest.java | 40 +
.../ignite/igfs/IgfsFragmentizerSelfTest.java | 2 +-
.../apache/ignite/igfs/IgfsTestInputGenerator.java | 2 +-
.../internal/ClusterNodeMetricsSelfTest.java | 2 +-
...rocessorCheckGlobalStateComputeRequestTest.java | 6 +-
.../DiagnosticLogForPartitionStatesTest.java | 2 +-
.../ignite/internal/DiscoverySpiTestListener.java | 2 +-
.../ignite/internal/GridAffinityMappedTest.java | 4 +-
.../internal/GridCancelUnusedJobSelfTest.java | 2 +-
.../GridEventStorageDefaultExceptionTest.java | 2 +-
.../GridFailoverCustomTopologySelfTest.java | 4 +-
.../ignite/internal/GridGetOrStartSelfTest.java | 4 +-
.../internal/GridJobCollisionCancelSelfTest.java | 4 +-
.../ignite/internal/GridJobContextSelfTest.java | 2 +-
.../internal/GridJobMasterLeaveAwareSelfTest.java | 6 +-
.../ignite/internal/GridJobStealingSelfTest.java | 2 +-
.../GridKernalConcurrentAccessStopSelfTest.java | 2 +-
.../apache/ignite/internal/GridMbeansMiscTest.java | 2 +-
.../GridMultipleVersionsDeploymentSelfTest.java | 2 +-
.../internal/GridNonHistoryMetricsSelfTest.java | 2 +-
.../ignite/internal/GridSpiExceptionSelfTest.java | 2 +-
.../ignite/internal/GridTaskExecutionSelfTest.java | 2 +-
.../GridTaskInstanceExecutionSelfTest.java | 2 +-
.../internal/GridTopicExternalizableSelfTest.java | 14 +-
.../internal/IgniteClientReconnectCacheTest.java | 4 +-
...niteClientReconnectContinuousProcessorTest.java | 2 +-
.../internal/IgniteComputeJobOneThreadTest.java | 2 +-
...teConnectionConcurrentReserveAndRemoveTest.java | 2 +-
.../IgniteLocalNodeMapBeforeStartTest.java | 2 +-
.../internal/IgniteReflectionFactorySelfTest.java | 14 +-
.../internal/VisorManagementEventSelfTest.java | 4 +-
.../BinaryArrayIdentityResolverSelfTest.java | 2 +-
.../internal/binary/BinaryEnumsSelfTest.java | 11 +-
.../internal/binary/BinaryMarshallerSelfTest.java | 4 +-
.../binary/BinaryObjectExceptionSelfTest.java | 4 +-
.../BinarySerialiedFieldComparatorSelfTest.java | 2 +-
.../internal/client/thin/ComputeTaskTest.java | 699 +++++++++++
.../ThinClientAbstractPartitionAwarenessTest.java | 4 +-
...lientPartitionAwarenessResourceReleaseTest.java | 5 +-
.../commandline/CommandHandlerParsingTest.java | 2 +-
.../encryption/AbstractEncryptionTest.java | 2 +-
.../encryption/EncryptedCacheBigEntryTest.java | 2 +-
.../encryption/EncryptedCacheCreateTest.java | 4 +-
.../EncryptedCachePreconfiguredRestartTest.java | 2 +-
.../internal/encryption/MasterKeyChangeTest.java | 2 +-
.../GridIoManagerFileTransmissionSelfTest.java | 2 +-
.../GridDiscoveryManagerAttributesSelfTest.java | 2 +-
...edMarshallerSerialPersistentFieldsSelfTest.java | 2 +-
.../optimized/OptimizedMarshallerTest.java | 6 +-
.../optimized/OptimizedObjectStreamSelfTest.java | 8 +-
.../internal/metric/CacheMetricsAddRemoveTest.java | 4 +-
.../ignite/internal/metric/JmxExporterSpiTest.java | 14 +-
.../ignite/internal/metric/LogExporterSpiTest.java | 2 +-
.../ignite/internal/metric/MetricsSelfTest.java | 22 +-
.../ignite/internal/metric/SystemViewSelfTest.java | 26 +-
.../wal/record/WALRecordSerializationTest.java | 8 +-
.../affinity/GridAffinityAssignmentV2Test.java | 4 +-
.../GridHistoryAffinityAssignmentTest.java | 2 +-
.../Authentication1kUsersNodeRestartTest.java | 2 +-
.../AuthenticationProcessorSelfTest.java | 4 +-
.../cache/ActiveOnStartPropertyTest.java | 2 +-
.../cache/AutoActivationPropertyTest.java | 4 +-
.../cache/CacheGroupsMetricsRebalanceTest.java | 12 +-
.../cache/CacheIgniteOutOfMemoryExceptionTest.java | 2 +-
.../cache/CacheMetricsEntitiesCountTest.java | 2 +-
.../cache/CacheNearReaderUpdateTest.java | 6 +-
.../cache/CacheSerializableTransactionsTest.java | 4 +-
.../cache/CacheStoreTxPutAllMultiNodeTest.java | 2 +-
.../cache/CacheTxNotAllowReadFromBackupTest.java | 2 +-
.../processors/cache/ClusterStateAbstractTest.java | 2 +-
.../cache/ClusterStateNoRebalanceAbstractTest.java | 6 +-
.../cache/ClusterStateOnStartPropertyTest.java | 12 +-
.../cache/CrossCacheTxRandomOperationsTest.java | 4 +-
.../cache/GridCacheAbstractFullApiSelfTest.java | 8 +-
.../cache/GridCacheAbstractLocalStoreSelfTest.java | 8 +-
.../cache/GridCacheAbstractMetricsSelfTest.java | 6 +-
.../cache/GridCacheAbstractRemoveFailureTest.java | 2 +-
...idCacheAbstractUsersAffinityMapperSelfTest.java | 2 +-
.../GridCacheAsyncOperationsLimitSelfTest.java | 2 +-
...acheAtomicEntryProcessorDeploymentSelfTest.java | 4 +-
.../cache/GridCacheBasicStoreAbstractTest.java | 2 +-
.../GridCacheConcurrentGetCacheOnClientTest.java | 2 +-
.../cache/GridCacheConcurrentMapSelfTest.java | 2 +-
.../GridCacheConcurrentTxMultiNodeLoadTest.java | 6 +-
.../GridCacheConditionalDeploymentSelfTest.java | 2 +-
.../cache/GridCacheGenericTestStore.java | 2 +-
.../GridCacheInterceptorAbstractSelfTest.java | 6 +-
.../cache/GridCacheIteratorPerformanceTest.java | 2 +-
...CacheLongRunningTransactionDiagnosticsTest.java | 2 +-
.../cache/GridCacheMvccPartitionedSelfTest.java | 4 +-
.../cache/GridCacheOffheapUpdateSelfTest.java | 2 +-
.../cache/GridCacheOnCopyFlagAbstractSelfTest.java | 4 +-
.../GridCacheQuerySqlFieldInlineSizeSelfTest.java | 8 +-
.../processors/cache/GridCacheTestEntryEx.java | 2 +-
.../cache/GridEvictionPolicyMBeansTest.java | 2 +-
...LongRunningInitNewCrdFutureDiagnosticsTest.java | 2 +-
.../cache/IgniteCacheAbstractStopBusySelfTest.java | 8 +-
.../IgniteCacheConfigVariationsFullApiTest.java | 2 +-
.../IgniteCacheConfigurationTemplateTest.java | 2 +-
.../IgniteCacheExpireAndUpdateConsistencyTest.java | 2 +-
.../processors/cache/IgniteCacheGroupsTest.java | 44 +-
.../cache/IgniteCacheInvokeAbstractTest.java | 2 +-
.../cache/IgniteCachePeekModesAbstractTest.java | 8 +-
.../cache/IgniteCacheStoreValueAbstractTest.java | 8 +-
.../IgniteClientCacheInitializationFailTest.java | 2 +-
.../cache/IgniteDynamicCacheAndNodeStop.java | 2 +-
.../cache/IgniteMarshallerCacheFSRestoreTest.java | 2 +-
.../cache/IgnitePutAllLargeBatchSelfTest.java | 2 +-
.../IgniteStartCacheInTransactionSelfTest.java | 14 +-
.../IgniteTopologyValidatorGridSplitCacheTest.java | 2 +-
.../processors/cache/IgniteTxAbstractTest.java | 2 +-
.../cache/IgniteTxConfigCacheSelfTest.java | 2 +-
.../cache/IgniteTxMultiNodeAbstractTest.java | 2 +-
.../IgniteTxStoreExceptionAbstractSelfTest.java | 2 +-
...ionsExchangeOnDiscoveryHistoryOverflowTest.java | 4 +-
.../AbstractBinaryMetadataRegistrationTest.java | 25 +-
.../binary/BinaryMetadataUpdatesFlowTest.java | 21 +-
...eBinaryObjectMetadataExchangeMultinodeTest.java | 30 +-
...ridCacheClientNodeBinaryObjectMetadataTest.java | 2 +-
.../GridDataStreamerImplSelfTest.java | 14 +-
...acheAbstractDataStructuresFailoverSelfTest.java | 12 +-
...stractQueueFailoverDataConsistencySelfTest.java | 8 +-
.../GridCacheMultiNodeDataStructureTest.java | 2 +-
.../GridCacheSetAbstractSelfTest.java | 2 +-
.../IgniteClientDataStructuresAbstractTest.java | 2 +-
...IgniteExchangeLatchManagerDiscoHistoryTest.java | 4 +-
.../datastructures/IgniteLockAbstractSelfTest.java | 33 +-
.../IgniteSemaphoreAbstractSelfTest.java | 2 +-
.../local/IgniteLocalCountDownLatchSelfTest.java | 2 +-
.../IgnitePartitionedQueueNoBackupsTest.java | 3 +-
.../IgnitePartitionedSetNoBackupsSelfTest.java | 2 +-
.../distributed/CacheAbstractRestartSelfTest.java | 4 +-
.../CacheDataLossOnPartitionMoveTest.java | 2 +-
.../cache/distributed/CacheExchangeMergeTest.java | 104 +-
.../distributed/CacheGetFutureHangsSelfTest.java | 2 +-
.../CacheLateAffinityAssignmentTest.java | 8 +-
.../distributed/CacheLockChangingTopologyTest.java | 2 +-
...abledTransactionalWriteReadRestartSelfTest.java | 2 +-
.../distributed/CachePageWriteLockUnlockTest.java | 2 +-
.../CachePartitionLossDetectionOnNodeLeftTest.java | 3 +-
.../CachePartitionLostWhileClearingTest.java | 2 +-
.../CachePutAllFailoverAbstractTest.java | 2 +-
...idCacheEntrySetIterationPreloadingSelfTest.java | 2 +-
.../distributed/GridCacheLockAbstractTest.java | 4 +-
.../GridCacheMultiNodeLockAbstractTest.java | 2 +-
...GridCacheMultithreadedFailoverAbstractTest.java | 6 +-
...PartitionEvictionDuringReadThroughSelfTest.java | 4 +-
...dCachePartitionedReloadAllAbstractSelfTest.java | 2 +-
.../GridCachePreloadRestartAbstractSelfTest.java | 4 +-
.../GridCacheTransformEventSelfTest.java | 2 +-
.../IgniteAbstractTxSuspendResumeTest.java | 2 +-
.../distributed/IgniteCache150ClientsTest.java | 2 +-
.../IgniteCacheConnectionRecoveryTest.java | 4 +-
...niteCacheMessageRecoveryIdleConnectionTest.java | 2 +-
.../IgniteOptimisticTxSuspendResumeTest.java | 2 +-
.../dht/CacheGetReadFromBackupFailoverTest.java | 2 +-
.../dht/GridCacheDhtEvictionsDisabledSelfTest.java | 2 +-
...ionedOnlyP2PEnabledByteArrayValuesSelfTest.java | 2 +-
.../GridCachePartitionedUnloadEventsSelfTest.java | 2 +-
.../dht/IgniteCacheMultiTxLockSelfTest.java | 2 +-
.../dht/IgniteCachePutRetryAbstractSelfTest.java | 2 +-
.../PartitionsEvictManagerAbstractTest.java | 2 +-
.../near/GridCacheNearEvictionSelfTest.java | 2 +-
.../near/GridCacheNearMetricsSelfTest.java | 10 +-
...rtitionedP2PEnabledByteArrayValuesSelfTest.java | 2 +-
...nedAffinityExcludeNeighborsPerformanceTest.java | 4 +-
.../near/GridCachePartitionedEvictionSelfTest.java | 2 +-
.../near/GridNearCacheStoreUpdateTest.java | 2 +-
.../rebalancing/CacheManualRebalancingTest.java | 2 +-
.../GridCacheRebalancingSyncCheckDataTest.java | 2 +-
.../GridCacheRebalancingSyncSelfTest.java | 2 +-
...eRebalanceOnCachesStoppingOrDestroyingTest.java | 2 +-
.../IgniteCacheClientNearCacheExpiryTest.java | 8 +-
.../IgniteCacheExpiryPolicyAbstractTest.java | 4 +-
.../IgniteCacheNoWriteThroughAbstractTest.java | 4 +-
.../IgniteCacheStoreNodeRestartAbstractTest.java | 2 +-
.../IgniteCacheStoreSessionAbstractTest.java | 2 +-
.../GridCacheFastNodeLeftForTransactionTest.java | 2 +-
.../cache/local/GridCacheLocalLoadAllSelfTest.java | 2 +-
...heMvccAbstractBasicCoordinatorFailoverTest.java | 2 +-
.../CacheMvccAbstractCoordinatorFailoverTest.java | 4 +-
.../cache/mvcc/CacheMvccAbstractTest.java | 26 +-
.../cache/mvcc/CacheMvccTransactionsTest.java | 6 +-
.../cache/mvcc/CacheMvccTxFailoverTest.java | 4 +-
.../IgnitePdsBinaryMetadataAsyncWritingTest.java | 7 +-
...gnitePdsBinaryMetadataOnClusterRestartTest.java | 6 +-
.../IgnitePdsDestroyCacheAbstractTest.java | 4 +-
.../IgnitePdsNoSpaceLeftOnDeviceTest.java | 5 +-
.../persistence/IgnitePdsTaskCancelingTest.java | 2 +-
.../IgnitePersistentStoreCacheGroupsTest.java | 2 +-
...ocalWalModeChangeDuringRebalancingSelfTest.java | 2 +-
.../baseline/ClusterActivationEventTest.java | 2 +-
.../IgniteAbsentEvictionNodeOutOfBaselineTest.java | 4 +-
.../db/CheckpointBufferDeadlockTest.java | 33 +-
.../db/IgnitePdsPartitionPreloadTest.java | 2 +-
.../IgnitePdsWithTtlDeactivateOnHighloadTest.java | 101 +-
.../db/checkpoint/CheckpointStartLoggingTest.java | 10 +-
.../db/checkpoint/ProgressWatchdog.java | 6 +-
.../db/file/IgnitePdsThreadInterruptionTest.java | 4 +-
...ailIsReachedDuringIterationOverArchiveTest.java | 2 +-
.../db/wal/IgniteWalFlushFailoverTest.java | 2 +-
...eWalFlushMultiNodeFailoverAbstractSelfTest.java | 4 +-
.../db/wal/IgniteWalIteratorSwitchSegmentTest.java | 2 +
.../db/wal/IgniteWalSerializerVersionTest.java | 2 +-
.../db/wal/WalRecoveryTxLogicalRecordsTest.java | 4 +-
.../persistence/db/wal/WalRolloverTypesTest.java | 3 +-
.../db/wal/crc/IgniteDataIntegrityTests.java | 4 +-
.../db/wal/crc/IgnitePureJavaCrcCompatibility.java | 2 +-
...teWithoutArchiverWalIteratorInvalidCrcTest.java | 2 +-
.../db/wal/reader/IgniteWalReaderTest.java | 4 +-
.../PageLockTrackerManagerTest.java | 6 +-
.../pagemem/BPlusTreePageMemoryImplTest.java | 7 +-
.../BPlusTreeReuseListPageMemoryImplTest.java | 1 +
.../persistence/pagemem/FullPageIdTableTest.java | 4 +-
.../pagemem/IndexStoragePageMemoryImplTest.java | 1 +
.../pagemem/PageMemoryImplNoLoadTest.java | 1 +
.../persistence/pagemem/PageMemoryImplTest.java | 6 +-
.../pagemem/RobinHoodBackwardShiftHashMapTest.java | 9 +-
.../snapshot/AbstractSnapshotSelfTest.java | 513 ++++++++
.../snapshot/IgniteClusterSnapshotSelfTest.java | 945 +++++++++++++++
.../snapshot/IgniteSnapshotMXBeanTest.java | 80 ++
.../snapshot/IgniteSnapshotManagerSelfTest.java | 439 +++++++
.../standbycluster/AbstractNodeJoinTemplate.java | 18 +-
.../IgniteChangeGlobalStateCacheTest.java | 2 +-
.../IgniteChangeGlobalStateDataStructureTest.java | 2 +-
.../IgniteChangeGlobalStateServiceTest.java | 2 +-
.../IgniteChangeGlobalStateTest.java | 2 +-
.../extended/GridActivateExtensionTest.java | 6 +-
.../join/JoinInActiveNodeToActiveCluster.java | 2 +-
...InActiveNodeToActiveClusterWithPersistence.java | 2 +-
.../persistence/tree/io/TrackingPageIOTest.java | 10 +-
.../wal/AbstractWalDeltaConsistencyTest.java | 2 +-
.../reader/StandaloneWalRecordsIteratorTest.java | 2 +-
.../query/GridCacheQueryTransformerSelfTest.java | 2 +-
...ContinuousQueryAsyncFailoverMvccTxSelfTest.java | 2 +-
...acheContinuousQueryAsyncFilterListenerTest.java | 4 +-
...ntinuousQueryConcurrentPartitionUpdateTest.java | 12 +-
...eContinuousQueryFilterDeploymentFailedTest.java | 24 +-
.../CacheContinuousQueryVariationsTest.java | 4 +-
.../GridCacheContinuousQueryAbstractSelfTest.java | 4 +-
...acheContinuousQueryMultiNodesFilteringTest.java | 4 +-
...CacheWriteBehindStoreMultithreadedSelfTest.java | 2 +-
...cheClientWriteBehindStoreNonCoalescingTest.java | 6 +-
.../transactions/AtomicOperationsInTxTest.java | 2 +-
.../cache/transactions/DepthFirstSearchTest.java | 18 +-
.../transactions/PartitionUpdateCounterTest.java | 9 +-
.../TxCrossCachePartitionConsistencyTest.java | 4 +-
...acheRemoteMultiplePartitionReservationTest.java | 2 +-
.../TxDataConsistencyOnCommitFailureTest.java | 2 +-
.../cache/transactions/TxDeadlockCauseTest.java | 8 +-
.../TxDeadlockDetectionNoHangsTest.java | 2 +-
.../transactions/TxDeadlockDetectionTest.java | 2 +-
.../TxDeadlockDetectionUnmasrhalErrorsTest.java | 2 +-
.../processors/cache/transactions/TxLabelTest.java | 2 +-
.../cache/transactions/TxOnCachesStartTest.java | 4 +-
.../cache/transactions/TxOnCachesStopTest.java | 6 +-
.../TxOptimisticDeadlockDetectionTest.java | 6 +-
.../transactions/TxOptimisticReadThroughTest.java | 216 ++++
.../TxPartitionCounterStateAbstractTest.java | 28 +-
.../TxPartitionCounterStateConsistencyTest.java | 8 +-
...rtitionCounterStateOnePrimaryOneBackupTest.java | 6 +-
...titionCounterStateTwoPrimaryTwoBackupsTest.java | 2 +-
...PessimisticDeadlockDetectionCrossCacheTest.java | 2 +-
.../TxPessimisticDeadlockDetectionTest.java | 2 +-
.../TxRecoveryWithConcurrentRollbackTest.java | 6 +-
.../cache/transactions/TxRollbackAsyncTest.java | 2 +-
.../TxRollbackOnMapOnInvalidTopologyTest.java | 2 +-
.../transactions/TxRollbackOnTimeoutTest.java | 6 +-
.../TxRollbackOnTopologyChangeTest.java | 4 +-
.../TxWithSmallTimeoutAndContentionOneKeyTest.java | 4 +-
.../version/CacheVersionedEntryAbstractTest.java | 2 +-
.../IgniteContinuousQueryMetadataUpdateTest.java | 50 +-
.../processors/database/BPlusTreeSelfTest.java | 18 +-
.../database/IgniteDbDynamicCacheSelfTest.java | 4 +-
.../datastreamer/DataStreamerImplSelfTest.java | 18 +-
.../datastreamer/DataStreamerStopCacheTest.java | 2 +-
.../diagnostic/DiagnosticProcessorTest.java | 2 +-
.../failure/FailureProcessorLoggingTest.java | 2 +-
.../FailureProcessorThreadDumpThrottlingTest.java | 2 +-
.../processors/igfs/IgfsAbstractBaseSelfTest.java | 4 +-
.../processors/igfs/IgfsAbstractSelfTest.java | 30 +-
.../igfs/IgfsBackupFailoverSelfTest.java | 12 +-
...fsBlockMessageSystemPoolStarvationSelfTest.java | 2 +-
.../processors/igfs/IgfsDualAbstractSelfTest.java | 4 +-
.../internal/processors/igfs/IgfsIgniteMock.java | 8 +
...calSecondaryFileSystemDualAbstractSelfTest.java | 2 +-
.../IgfsLocalSecondaryFileSystemProxySelfTest.java | 8 +-
.../IgfsLocalSecondaryFileSystemTestAdapter.java | 2 +-
.../split/IgfsAbstractRecordResolverSelfTest.java | 2 +-
...IgfsNewLineDelimiterRecordResolverSelfTest.java | 2 +-
.../jobmetrics/GridJobMetricsSelfTest.java | 2 +-
.../IgniteMessagingConfigVariationFullApiTest.java | 2 +-
.../metastorage/DistributedMetaStorageTest.java | 26 +-
.../processors/query/DummyQueryIndexing.java | 2 +-
.../GridCacheAtomicCommandHandlerSelfTest.java | 2 +-
.../cache/GridCacheCommandHandlerSelfTest.java | 2 +-
.../AbstractRemoteSecurityContextCheckTest.java | 2 +-
.../client/AdditionalSecurityCheckTest.java | 6 +-
.../client/ThinClientPermissionCheckTest.java | 13 +-
...ThinClientSecurityContextOnRemoteNodeTest.java} | 33 +-
.../security/impl/TestSecurityProcessor.java | 14 +-
.../security/sandbox/AbstractSandboxTest.java | 2 +-
.../security/sandbox/ComputeSandboxTest.java | 4 +-
.../sandbox/DoPrivilegedOnRemoteNodeTest.java | 8 +-
.../sandbox/IgniteOperationsInsideSandboxTest.java | 2 +-
.../sandbox/IgnitionComponentProxyTest.java | 200 ++++
.../security/sandbox/MessagingSandboxTest.java | 120 ++
.../sandbox/SecuritySubjectPermissionsTest.java | 2 +-
.../service/ClosureServiceClientsNodesTest.java | 10 +-
.../GridServiceProcessorAbstractSelfTest.java | 2 +-
...ridServiceProcessorMultiNodeConfigSelfTest.java | 4 +-
.../service/GridServiceProcessorProxySelfTest.java | 8 +-
...ployment2ClassLoadersDefaultMarshallerTest.java | 4 +-
...ceDeployment2ClassLoadersJdkMarshallerTest.java | 2 +-
...oyment2ClassLoadersOptimizedMarshallerTest.java | 2 +-
.../ServiceDeploymentOnClientDisconnectTest.java | 2 +-
.../service/SystemCacheNotConfiguredTest.java | 2 +-
.../internal/sql/SqlParserKillQuerySelfTest.java | 10 +-
.../ignite/internal/util/GridArraysSelfTest.java | 4 +-
.../util/GridConcurrentMultiPairQueueTest.java | 2 +-
.../ignite/internal/util/IgniteUtilsSelfTest.java | 15 +-
.../util/collection/AbstractBaseIntMapTest.java | 2 +-
.../internal/util/collection/BitSetIntSetTest.java | 2 +-
...GridUnsafeDataInputOutputByteOrderSelfTest.java | 14 +-
.../GridUnsafeDataOutputArraySizingSelfTest.java | 2 +-
.../util/ipc/shmem/IpcSharedMemoryFakeClient.java | 2 +-
.../util/ipc/shmem/IpcSharedMemoryNodeStartup.java | 2 +-
.../ignite/internal/util/nio/GridNioSelfTest.java | 2 +-
.../util/nio/impl/GridNioFilterChainSelfTest.java | 2 +-
.../offheap/GridOffHeapMapAbstractSelfTest.java | 16 +-
.../GridOffHeapMapPerformanceAbstractTest.java | 2 +-
.../GridOffHeapPartitionedMapAbstractSelfTest.java | 8 +-
.../tostring/CircularStringBuilderSelfTest.java | 2 +-
.../util/tostring/GridToStringBuilderSelfTest.java | 12 +-
.../ignite/lang/GridBasicPerformanceTest.java | 4 +-
.../ignite/lang/GridByteArrayListSelfTest.java | 2 +-
.../lang/GridFutureListenPerformanceTest.java | 2 +-
.../lang/GridMetadataAwareAdapterLoadTest.java | 2 +-
.../org/apache/ignite/lang/IgniteUuidSelfTest.java | 32 +-
...GridBoundedConcurrentLinkedHashMapSelfTest.java | 2 +-
.../lang/utils/GridConsistentHashSelfTest.java | 2 +-
.../utils/IgniteOffheapReadWriteLockSelfTest.java | 2 +-
.../ignite/loadtests/GridSingleExecutionTest.java | 2 +-
.../loadtests/cache/GridCacheAbstractLoadTest.java | 4 +-
.../loadtests/capacity/GridCapacityLoadTest.java | 2 +-
.../communication/GridIoManagerBenchmark.java | 6 +-
.../GridTcpCommunicationBenchmark.java | 12 +-
.../loadtests/communication/GridTestMessage.java | 4 +-
.../direct/multisplit/GridMultiSplitsLoadTest.java | 2 +-
.../redeploy/GridSingleSplitsRedeployLoadTest.java | 2 +-
.../direct/stealing/GridStealingLoadTest.java | 2 +-
.../direct/stealing/GridStealingLoadTestTask.java | 2 +-
.../ignite/loadtests/dsi/GridDsiRequest.java | 2 +-
.../ignite/loadtests/dsi/GridDsiResponse.java | 2 +-
.../ignite/loadtests/dsi/GridDsiSession.java | 2 +-
.../loadtests/hashmap/GridCacheTestContext.java | 1 +
.../GridJobExecutionLoadTestClientSemaphore.java | 2 +-
.../ignite/loadtests/job/GridJobLoadTestJob.java | 2 +-
.../lang/GridConcurrentLinkedHashMapBenchmark.java | 6 +-
.../loadtests/nio/GridNioBenchmarkClient.java | 8 +-
.../ignite/loadtests/nio/GridNioBenchmarkTest.java | 2 +-
.../marshaller/MarshallerContextSelfTest.java | 4 +-
.../messaging/IgniteMessagingSendAsyncTest.java | 20 +-
.../ignite/p2p/GridP2PLocalDeploymentSelfTest.java | 10 +-
.../ignite/p2p/GridP2PRecursionTaskSelfTest.java | 2 +-
.../p2p/GridP2PRemoteClassLoadersSelfTest.java | 6 +-
.../java/org/apache/ignite/p2p/GridP2PTestJob.java | 2 +-
.../ignite/p2p/GridP2PTestTaskExecutionTest.java | 2 +-
.../ignite/platform/PlatformDeployServiceTask.java | 13 +-
.../ignite/services/ServiceThreadPoolSelfTest.java | 2 +-
...ridSessionCancelSiblingsFromFutureSelfTest.java | 2 +-
.../GridSessionCancelSiblingsFromJobSelfTest.java | 2 +-
.../GridSessionCancelSiblingsFromTaskSelfTest.java | 2 +-
.../GridSessionCheckpointAbstractSelfTest.java | 2 +-
.../GridSessionFutureWaitJobAttributeSelfTest.java | 2 +-
...GridSessionFutureWaitTaskAttributeSelfTest.java | 2 +-
.../GridSessionSetFutureAttributeSelfTest.java | 2 +-
...sionSetFutureAttributeWaitListenerSelfTest.java | 2 +-
...SessionSetJobAttributeWaitListenerSelfTest.java | 2 +-
.../session/GridSessionWaitAttributeSelfTest.java | 2 +-
...SharedFsCheckpointSpiMultiThreadedSelfTest.java | 4 +-
...FsCheckpointSpiMultipleDirectoriesSelfTest.java | 2 +-
.../GridSharedFsCheckpointSpiSelfTest.java | 2 +-
.../tcp/GridTcpCommunicationSpiConfigSelfTest.java | 133 +++
.../tcp/TcpCommunicationSpiDropNodesTest.java | 2 +-
.../tcp/TcpCommunicationSpiFaultyClientTest.java | 2 +-
.../tcp/TcpCommunicationSpiMultiJvmTest.java | 227 ++++
.../local/GridLocalDeploymentSpiSelfTest.java | 4 +-
.../FilterDataForClientNodeDiscoveryTest.java | 2 +-
.../IgniteClientReconnectMassiveShutdownTest.java | 2 +-
.../TcpClientDiscoveryMarshallerCheckSelfTest.java | 2 +-
...TcpClientDiscoverySpiCoordinatorChangeTest.java | 2 +-
.../tcp/TcpClientDiscoveryUnresolvedHostTest.java | 2 +-
.../tcp/TcpDiscoveryConcurrentStartTest.java | 2 +-
.../tcp/TcpDiscoveryMarshallerCheckSelfTest.java | 2 +-
.../tcp/TcpDiscoveryMetricsWarnLogTest.java | 133 +++
.../tcp/TcpDiscoveryMultiThreadedTest.java | 2 +-
.../spi/discovery/tcp/TcpDiscoverySelfTest.java | 36 +-
.../tcp/TcpDiscoverySpiFailureTimeoutSelfTest.java | 2 +-
.../spi/discovery/tcp/TcpDiscoverySpiSelfTest.java | 2 +-
.../tcp/TcpDiscoveryWithWrongServerTest.java | 2 +-
.../spi/discovery/tcp/TestTcpDiscoverySpi.java | 25 +
...oundRobinLoadBalancingSpiLocalNodeSelfTest.java | 2 +-
.../startup/servlet/GridServletLoaderTest.java | 4 +-
.../stream/socket/SocketStreamerSelfTest.java | 6 +-
.../ignite/testframework/GridJarClassLoader.java | 4 +-
.../apache/ignite/testframework/GridTestUtils.java | 110 +-
.../ConfigVariationsTestSuiteBuilder.java | 3 +-
.../testframework/junits/GridAbstractTest.java | 7 +-
.../junits/GridTestBinaryMarshaller.java | 93 ++
.../junits/GridTestKernalContext.java | 2 +-
.../junits/IgniteConfigVariationsAbstractTest.java | 4 +-
.../ignite/testframework/junits/IgniteMock.java | 6 +
.../junits/cache/TestThreadLocalCacheSession.java | 2 +-
.../junits/common/GridCommonAbstractTest.java | 15 +-
.../junits/multijvm/IgniteNodeRunner.java | 8 +-
.../junits/multijvm/IgniteProcessProxy.java | 14 +-
.../junits/spi/GridSpiAbstractConfigTest.java | 2 +-
.../test/ConfigVariationsTestSuiteBuilderTest.java | 4 +-
.../testframework/wal/record/RecordUtils.java | 10 +
.../IgniteBasicWithPersistenceTestSuite.java | 9 +-
.../testsuites/IgniteCacheMvccTestSuite6.java | 4 +
.../ignite/testsuites/IgniteCacheTestSuite6.java | 3 +
.../ignite/testsuites/IgniteReproducingSuite.java | 2 +-
.../IgniteSpiCommunicationSelfTestSuite.java | 2 +
.../IgniteSpiDiscoverySelfTestSuite.java | 2 +
.../ignite/testsuites/SecurityTestSuite.java | 9 +-
.../util/GridCommandHandlerAbstractTest.java | 19 +-
.../util/GridCommandHandlerClusterByClassTest.java | 6 +-
...ncurrentLinkedHashMapMultiThreadedSelfTest.java | 2 +-
.../ignite/util/GridSnapshotLockSelfTest.java | 4 +-
.../ignite/util/mbeans/GridMBeanSelfTest.java | 16 +-
...mandHandlerClusterByClassTest_cache_help.output | 3 +-
...dlerClusterByClassWithSSLTest_cache_help.output | 3 +-
modules/dev-utils/pom.xml | 28 +
.../ignite/development/utils/DataEntryWrapper.java | 89 ++
.../development/utils/IgniteWalConverter.java | 65 +-
.../utils/MetastoreDataRecordWrapper.java | 53 +
.../development/utils/ProcessSensitiveData.java} | 21 +-
.../utils/ProcessSensitiveDataUtils.java} | 46 +-
.../apache/ignite/development/utils/WalStat.java | 2 +-
.../development/utils/DevUtilsTestSuite.java} | 8 +-
.../utils/IgniteWalConverterSensitiveDataTest.java | 383 ++++++
.../file/AlignedBuffersDirectFileIO.java | 4 +-
.../file/AlignedBuffersDirectFileIOFactory.java | 2 +-
.../file/LinuxNativeIoPluginProvider.java | 4 +-
.../ignite/tests/p2p/compute/ExternalCallable.java | 2 +-
.../uri/tasks/GridUriDeploymentDependency1.java | 2 +-
.../uri/tasks/GridUriDeploymentDependency2.java | 2 +-
.../uri/tasks/GridUriDeploymentDependency9.java | 5 +-
.../ignite/tests/p2p/compute/ExternalCallable.java | 2 +-
modules/flume/README.txt | 48 -
modules/flume/licenses/apache-2.0.txt | 202 ----
modules/flume/pom.xml | 88 --
.../org/apache/ignite/stream/flume/IgniteSink.java | 196 ----
.../ignite/stream/flume/IgniteSinkConstants.java | 35 -
.../apache/ignite/stream/flume/package-info.java | 22 -
.../apache/ignite/stream/flume/IgniteSinkTest.java | 139 ---
.../ignite/stream/flume/TestEventTransformer.java | 66 --
.../apache/ignite/stream/flume/package-info.java | 22 -
.../flume/src/test/resources/example-ignite.xml | 71 --
.../gce/TcpDiscoveryGoogleStorageIpFinder.java | 6 +-
.../HadoopIgfsSecondaryFileSystemDelegateImpl.java | 2 +-
.../hadoop/impl/fs/HadoopLazyConcurrentMap.java | 2 +-
.../hadoop/impl/fs/HadoopRawLocalFileSystem.java | 6 +-
.../hadoop/impl/igfs/HadoopIgfsOutputStream.java | 2 +-
.../impl/igfs/HadoopIgfsProxyInputStream.java | 2 +-
.../hadoop/impl/igfs/HadoopIgfsWrapper.java | 2 +-
.../processors/hadoop/impl/v2/HadoopV2Job.java | 4 +-
.../hadoop/impl/v2/HadoopV2JobResourceManager.java | 4 +-
.../hadoop/impl/v2/HadoopV2TaskContext.java | 2 +-
.../hadoop/jobtracker/HadoopJobTracker.java | 10 +-
.../hadoop/shuffle/HadoopShuffleJob.java | 2 +-
.../collections/HadoopConcurrentHashMultimap.java | 2 +-
.../hadoop/shuffle/collections/HadoopSkipList.java | 2 +-
.../shuffle/direct/HadoopDirectDataOutput.java | 2 +-
.../hadoop/taskexecutor/HadoopRunnableTask.java | 4 +-
.../communication/HadoopExternalCommunication.java | 2 +-
.../hadoop/impl/HadoopAbstractMapReduceTest.java | 2 +-
.../hadoop/impl/HadoopErrorSimulator.java | 12 +-
.../hadoop/impl/HadoopFileSystemsTest.java | 2 +-
.../hadoop/impl/HadoopMapReduceTest.java | 6 +-
.../processors/hadoop/impl/HadoopSnappyTest.java | 2 +-
.../processors/hadoop/impl/HadoopSortingTest.java | 2 +-
.../hadoop/impl/HadoopTaskExecutionSelfTest.java | 8 +-
.../impl/HadoopTasksVersionsAbstractTest.java | 2 +-
.../processors/hadoop/impl/HadoopTeraSortTest.java | 2 +-
.../hadoop/impl/HadoopTestTaskContext.java | 2 +-
.../processors/hadoop/impl/HadoopTestUtils.java | 2 +-
.../hadoop/impl/igfs/Hadoop1OverIgfsProxyTest.java | 2 +-
.../IgniteHadoopFileSystemClientBasedOpenTest.java | 2 +-
.../shuffle/streams/HadoopDataStreamSelfTest.java | 6 +-
.../cache/hibernate/HibernateTimestampsRegion.java | 2 +-
.../HibernateL2CacheConfigurationSelfTest.java | 2 +-
.../cache/hibernate/HibernateL2CacheSelfTest.java | 6 +-
.../CacheHibernateStoreFactorySelfTest.java | 4 +-
.../cache/hibernate/HibernateTimestampsRegion.java | 2 +-
.../HibernateL2CacheConfigurationSelfTest.java | 2 +-
.../cache/hibernate/HibernateL2CacheSelfTest.java | 6 +-
.../CacheHibernateStoreFactorySelfTest.java | 2 +-
.../HibernateL2CacheConfigurationSelfTest.java | 2 +-
.../cache/hibernate/HibernateL2CacheSelfTest.java | 6 +-
.../CacheHibernateStoreFactorySelfTest.java | 2 +-
.../hibernate/HibernateAccessStrategyFactory.java | 2 +-
.../cache/hibernate/HibernateCacheProxy.java | 2 +-
.../ignite/internal/mxbean/SqlQueryMXBean.java | 61 +-
.../ignite/internal/mxbean/SqlQueryMXBeanImpl.java | 20 +
.../cache/query/RegisteredQueryCursor.java | 2 +-
.../query/h2/DistributedSqlConfiguration.java | 120 ++
.../h2/DurableBackgroundCleanupIndexTreeTask.java | 17 +-
.../processors/query/h2/FunctionsManager.java | 88 ++
.../internal/processors/query/h2/H2Connection.java | 2 +-
.../processors/query/h2/H2FieldsIterator.java | 11 +-
.../query/h2/H2QueryFetchSizeInterceptor.java | 92 ++
.../internal/processors/query/h2/H2QueryInfo.java | 15 +-
.../processors/query/h2/H2ResultSetIterator.java | 20 +-
.../processors/query/h2/H2TableDescriptor.java | 6 +-
.../internal/processors/query/h2/H2Utils.java | 12 +-
.../processors/query/h2/IgniteH2Indexing.java | 63 +-
.../query/h2/LongRunningQueryManager.java | 71 +-
.../processors/query/h2/MapH2QueryInfo.java | 2 +-
.../processors/query/h2/QueryParserCacheEntry.java | 2 +-
.../processors/query/h2/ReduceH2QueryInfo.java | 2 +-
.../processors/query/h2/SchemaManager.java | 6 +-
.../query/h2/affinity/PartitionExtractor.java | 4 +-
.../query/h2/database/H2PkHashIndex.java | 2 +-
.../processors/query/h2/database/H2Tree.java | 246 ++--
.../query/h2/database/H2TreeClientIndex.java | 18 +-
.../query/h2/database/H2TreeFilterClosure.java | 6 +-
.../processors/query/h2/database/H2TreeIndex.java | 188 +--
.../query/h2/database/H2TreeIndexBase.java | 79 +-
.../query/h2/database/InlineIndexColumn.java | 101 ++
.../query/h2/database/InlineIndexHelper.java | 1142 ------------------
.../inlinecolumn/AbstractInlineIndexColumn.java | 246 ++++
.../inlinecolumn/BooleanInlineIndexColumn.java | 68 ++
.../inlinecolumn/ByteInlineIndexColumn.java | 68 ++
.../inlinecolumn/BytesInlineIndexColumn.java | 148 +++
.../inlinecolumn/DateInlineIndexColumn.java | 69 ++
.../inlinecolumn/DoubleInlineIndexColumn.java | 68 ++
.../FixedStringInlineIndexColumn.java} | 27 +-
.../inlinecolumn/FloatInlineIndexColumn.java | 68 ++
.../inlinecolumn/InlineIndexColumnFactory.java | 238 ++++
.../inlinecolumn/IntegerInlineIndexColumn.java | 68 ++
.../inlinecolumn/LongInlineIndexColumn.java | 68 ++
.../ObjectBytesInlineIndexColumn.java} | 28 +-
.../inlinecolumn/ObjectHashInlineIndexColumn.java | 83 ++
.../inlinecolumn/ShortInlineIndexColumn.java | 68 ++
.../StringIgnoreCaseInlineIndexColumn.java} | 27 +-
.../inlinecolumn/StringInlineIndexColumn.java | 311 +++++
.../inlinecolumn/TimeInlineIndexColumn.java | 69 ++
.../inlinecolumn/TimestampInlineIndexColumn.java | 83 ++
.../inlinecolumn/UuidInlineIndexColumn.java | 81 ++
.../h2/database/io/AbstractH2ExtrasInnerIO.java | 7 +-
.../h2/database/io/AbstractH2ExtrasLeafIO.java | 7 +-
.../processors/query/h2/dml/DmlAstUtils.java | 4 +-
.../processors/query/h2/dml/DmlBatchSender.java | 2 +-
.../internal/processors/query/h2/dml/DmlUtils.java | 6 +-
.../processors/query/h2/dml/UpdatePlanBuilder.java | 2 +-
.../processors/query/h2/opt/GridH2IndexBase.java | 6 +-
.../query/h2/opt/GridH2RowDescriptor.java | 2 +-
.../processors/query/h2/opt/GridH2Table.java | 6 +-
.../query/h2/opt/GridLuceneDirectory.java | 2 +-
.../query/h2/opt/GridLuceneInputStream.java | 2 +-
.../processors/query/h2/opt/QueryContextKey.java | 2 +-
.../query/h2/sql/GridSqlAggregateFunction.java | 2 +-
.../processors/query/h2/sql/GridSqlAlias.java | 2 +-
.../processors/query/h2/sql/GridSqlColumn.java | 2 +-
.../query/h2/sql/GridSqlOperationType.java | 3 +-
.../query/h2/sql/GridSqlQueryParser.java | 2 +-
.../query/h2/sql/GridSqlQuerySplitter.java | 12 +-
.../query/h2/sql/SplitterQueryModel.java | 4 +-
.../h2/sys/view/SqlAbstractLocalSystemView.java | 4 +-
.../query/h2/twostep/AbstractReducer.java | 4 +-
.../query/h2/twostep/GridMapQueryExecutor.java | 6 +-
.../query/h2/twostep/GridReduceQueryExecutor.java | 8 +-
.../query/h2/twostep/MapQueryResult.java | 17 +-
.../query/h2/twostep/PartitionReservation.java | 2 +-
.../processors/query/h2/twostep/ReduceIndex.java | 12 +-
.../query/h2/twostep/ReducePartitionMapper.java | 4 +-
.../query/h2/twostep/ReduceQueryRun.java | 12 +-
.../processors/query/h2/twostep/SortedReducer.java | 8 +-
.../query/h2/twostep/msg/GridH2DmlRequest.java | 2 +-
.../query/h2/twostep/msg/GridH2QueryRequest.java | 5 +-
.../visor/verify/ValidateIndexesClosure.java | 528 +++++++--
.../visor/verify/VisorValidateIndexesTask.java | 3 +-
.../ignite/spi/systemview/SqlViewExporterSpi.java | 3 +-
.../org/apache/ignite/client/ClientTestSuite.java | 2 +
.../metric/SqlStatisticsUserQueriesFastTest.java | 4 +-
.../cache/BinarySerializationQuerySelfTest.java | 2 +-
.../CacheAbstractQueryDetailMetricsSelfTest.java | 4 +-
.../cache/CacheAbstractQueryMetricsSelfTest.java | 2 +-
.../CacheRandomOperationsMultithreadedTest.java | 2 +-
.../cache/GridCacheCrossCacheQuerySelfTest.java | 4 +-
...ridCacheFullTextQueryMultithreadedSelfTest.java | 2 +-
.../cache/GridCacheOffheapIndexGetSelfTest.java | 2 +-
.../IgniteBinaryObjectFieldsQuerySelfTest.java | 4 +-
.../IgniteCacheAbstractFieldsQuerySelfTest.java | 2 +-
.../cache/IgniteCacheAbstractQuerySelfTest.java | 8 +-
.../IgniteCacheConfigVariationsQueryTest.java | 2 +-
.../processors/cache/IgniteCacheGroupsSqlTest.java | 2 +-
...oinPartitionedAndReplicatedCollocationTest.java | 4 +-
.../cache/IgniteCacheLargeResultSelfTest.java | 4 +-
...ockPartitionOnAffinityRunAtomicCacheOpTest.java | 2 +-
.../IgniteCacheObjectKeyIndexingSelfTest.java | 148 ++-
.../cache/IgniteCacheOffheapIndexScanTest.java | 4 +-
.../cache/IgniteCacheQueryH2IndexingLeakTest.java | 4 +-
.../IgniteCacheQueryMultiThreadedSelfTest.java | 4 +-
.../IgniteCacheSqlInsertValidationSelfTest.java | 3 +-
.../cache/IgniteCacheSqlQueryErrorSelfTest.java | 2 +-
.../cache/IgniteCacheUnionDuplicatesTest.java | 2 +-
.../cache/IgniteCacheUpdateSqlQuerySelfTest.java | 2 +-
.../cache/IgniteDynamicSqlRestoreTest.java | 2 +-
.../processors/cache/WrongIndexedTypesTest.java | 76 ++
...eDistributedPartitionQueryAbstractSelfTest.java | 2 +-
...ributedPartitionQueryConfigurationSelfTest.java | 2 +-
...acheDistributedQueryDefaultTimeoutSelfTest.java | 2 +-
...tributedQueryStopOnCancelOrTimeoutSelfTest.java | 2 +-
.../IgniteCachePartitionedFieldsQuerySelfTest.java | 4 +-
...cheQueryNodeRestartDistributedJoinSelfTest.java | 4 +-
.../IgniteCacheQueryNodeRestartTxSelfTest.java | 2 +-
.../cache/encryption/EncryptedSqlTableTest.java | 4 +-
.../cache/index/AbstractIndexingCommonTest.java | 2 +-
.../cache/index/AbstractSchemaSelfTest.java | 2 +-
.../processors/cache/index/BasicIndexTest.java | 93 +-
.../cache/index/BasicJavaTypesIndexTest.java | 537 +++++++++
.../cache/index/BasicSqlTypesIndexTest.java | 583 +++++++++
.../DynamicColumnsAbstractConcurrentSelfTest.java | 2 +-
.../index/DynamicIndexAbstractBasicSelfTest.java | 8 +-
.../DynamicIndexAbstractConcurrentSelfTest.java | 4 +-
.../cache/index/H2DynamicTableSelfTest.java | 14 +-
.../processors/cache/index/H2RowCacheSelfTest.java | 6 +-
.../processors/cache/index/LongIndexNameTest.java | 4 +-
.../cache/index/QueryEntityValidationSelfTest.java | 2 +-
.../cache/index/SchemaExchangeSelfTest.java | 4 +-
.../index/StopNodeOnRebuildIndexFailureTest.java | 6 +-
...niteCacheLocalQueryCancelOrTimeoutSelfTest.java | 2 +-
.../cache/local/IgniteCacheLocalQuerySelfTest.java | 6 +-
.../cache/metric/SqlViewExporterSpiTest.java | 9 +-
...acheMvccAbstractSqlContinuousQuerySelfTest.java | 2 +-
...acheMvccAbstractSqlCoordinatorFailoverTest.java | 4 +-
.../cache/mvcc/CacheMvccBackupsAbstractTest.java | 2 +-
.../mvcc/CacheMvccBasicContinuousQueryTest.java | 6 +-
...acheMvccContinuousQueryClientReconnectTest.java | 2 +-
...eMvccPartitionedSqlCoordinatorFailoverTest.java | 4 +-
.../CacheMvccSelectForUpdateQueryBasicTest.java | 30 +-
.../mvcc/CacheMvccSelectForUpdateQueryTest.java | 4 +-
.../cache/mvcc/CacheMvccSqlLockTimeoutTest.java | 2 +-
.../mvcc/CacheMvccSqlQueriesAbstractTest.java | 2 +-
.../mvcc/CacheMvccSqlTxQueriesAbstractTest.java | 2 +-
...cheMvccSqlTxQueriesWithReducerAbstractTest.java | 30 +-
.../cache/mvcc/CacheMvccSqlUpdateCountersTest.java | 16 +-
.../mvcc/MvccDeadlockDetectionConfigTest.java | 2 +-
.../cache/mvcc/MvccRepeatableReadBulkOpsTest.java | 4 +-
.../mvcc/MvccRepeatableReadOperationsTest.java | 6 +-
.../db/IgniteCacheGroupsWithRestartsTest.java | 4 +-
...xingMultithreadedLoadContinuousRestartTest.java | 2 +-
.../db/LongDestroyDurableBackgroundTaskTest.java | 25 +-
.../IgniteClusterSnapshotWithIndexesTest.java | 274 +++++
.../processors/client/IgniteDataStreamerTest.java | 4 +-
...tStoreQueryWithMultipleClassesPerCacheTest.java | 2 +-
.../processors/database/RebuildIndexTest.java | 2 +-
.../RebuildIndexWithHistoricalRebalanceTest.java | 2 +-
...actQueryTableLockAndConnectionPoolSelfTest.java | 10 +-
.../processors/query/DisabledSqlFunctionsTest.java | 290 +++++
.../query/IgniteQueryDedicatedPoolTest.java | 2 +-
.../query/IgniteSqlDefaultValueTest.java | 2 +-
.../query/IgniteSqlEntryCacheModeAgnosticTest.java | 4 +-
.../query/IgniteSqlGroupConcatCollocatedTest.java | 4 +-
.../IgniteSqlGroupConcatNotCollocatedTest.java | 4 +-
.../query/IgniteSqlKeyValueFieldsTest.java | 10 +-
.../query/IgniteSqlNotNullConstraintTest.java | 2 +-
.../query/IgniteSqlParameterizedQueryTest.java | 2 +-
.../query/IgniteSqlQueryParallelismTest.java | 4 +-
.../processors/query/IgniteSqlRoutingTest.java | 4 +-
.../query/IgniteSqlSchemaIndexingTest.java | 2 +-
.../query/IgniteSqlSegmentedIndexSelfTest.java | 8 +-
.../IgniteSqlSkipReducerOnUpdateDmlSelfTest.java | 2 +-
.../query/IgniteSqlSplitterSelfTest.java | 6 +-
.../processors/query/KillQueryFromClientTest.java | 2 +-
.../internal/processors/query/KillQueryTest.java | 4 +-
.../processors/query/LocalQueryLazyTest.java | 6 +-
.../processors/query/LongRunningQueryTest.java | 60 +-
.../processors/query/RunningQueriesTest.java | 2 +-
.../processors/query/SqlIllegalSchemaSelfTest.java | 2 +-
.../SqlIncompatibleDataTypeExceptionTest.java | 10 +-
.../processors/query/SqlSystemViewsSelfTest.java | 10 +-
.../SqlTwoCachesInGroupWithSameEntryTest.java | 2 +-
.../query/h2/GridIndexFullRebuildTest.java | 2 +-
.../query/h2/GridIndexRebuildSelfTest.java | 4 +-
.../H2ResultSetIteratorNullifyOnEndSelfTest.java | 2 +-
.../query/h2/IgniteSqlBigIntegerKeyTest.java | 2 +-
.../query/h2/IgniteSqlQueryMinMaxTest.java | 2 +-
...ountTableStatisticsSurvivesNodeRestartTest.java | 4 +-
.../query/h2/RowCountTableStatisticsUsageTest.java | 22 +-
.../query/h2/TableStatisticsAbstractTest.java | 6 +-
.../query/h2/database/InlineIndexHelperTest.java | 704 -----------
.../inlinecolumn/InlineIndexColumnTest.java | 1014 ++++++++++++++++
.../query/h2/sql/AbstractH2CompareQueryTest.java | 2 +-
.../query/h2/sql/BaseH2CompareQueryTest.java | 14 +-
.../query/h2/sql/GridQueryParsingTest.java | 2 +-
.../query/h2/sql/H2CompareBigQueryTest.java | 38 +-
.../twostep/AbstractPartitionPruningBaseTest.java | 2 +-
.../AndOperationExtractPartitionSelfTest.java | 4 +-
.../BetweenOperationExtractPartitionSelfTest.java | 6 +-
.../DisappearedCacheCauseRetryMessageSelfTest.java | 10 +-
...DisappearedCacheWasNotFoundMessageSelfTest.java | 6 +-
.../InOperationExtractPartitionSelfTest.java | 2 +-
...neOrSinglePartitionsQueryOptimizationsTest.java | 10 +-
.../h2/twostep/RetryCauseMessageSelfTest.java | 2 +-
.../h2/twostep/SqlDataTypeConversionTest.java | 4 +-
.../processors/query/oom/AbstractQueryOOMTest.java | 2 +-
...achePartitionedAtomicColumnConstraintsTest.java | 4 +-
.../h2indexing/FetchingQueryCursorStressTest.java | 8 +-
.../tcp/GridOrderedMessageCancelSelfTest.java | 4 +-
.../IgniteBinaryCacheQueryTestSuite.java | 5 +
.../IgniteBinaryCacheQueryTestSuite2.java | 3 +
...teCacheWithIndexingAndPersistenceTestSuite.java | 2 +
.../IgniteCacheWithIndexingTestSuite.java | 9 +-
.../testsuites/IgnitePdsWithIndexingTestSuite.java | 4 +-
.../util/GridCommandHandlerBrokenIndexTest.java | 6 +-
.../GridCommandHandlerIndexingCheckSizeTest.java | 547 +++++++++
...idCommandHandlerIndexingClusterByClassTest.java | 128 +-
...ndHandlerIndexingClusterByClassWithSSLTest.java | 2 +-
.../util/GridCommandHandlerIndexingTest.java | 2 +-
.../util/GridCommandHandlerIndexingUtils.java | 297 ++++-
.../apache/ignite/util/KillCommandsMXBeanTest.java | 2 +-
.../apache/ignite/util/KillCommandsSQLTest.java | 2 +-
.../org/apache/ignite/util/KillCommandsTests.java | 2 +-
.../apache/ignite/logger/jcl/JclLoggerTest.java | 2 +-
.../cache/GridJtaLifecycleAwareSelfTest.java | 5 +-
.../stream/kafka/connect/IgniteSourceTask.java | 2 +-
.../kubernetes/TcpDiscoveryKubernetesIpFinder.java | 2 +-
.../logger/log4j/GridLog4jLoggingFileTest.java | 2 +-
.../ignite/logger/log4j2/Log4j2LoggerSelfTest.java | 2 +-
.../ignite/ml/clustering/gmm/GmmPartitionData.java | 2 +-
.../WeightedPredictionsAggregator.java | 6 +-
.../java/org/apache/ignite/ml/dataset/Dataset.java | 2 +-
.../ignite/ml/dataset/feature/BucketMeta.java | 4 +-
.../ignite/ml/dataset/feature/ObjectHistogram.java | 6 +-
.../extractor/impl/BinaryObjectVectorizer.java | 2 +-
.../extractor/impl/DoubleArrayVectorizer.java | 2 +-
.../feature/extractor/impl/DummyVectorizer.java | 2 +-
.../extractor/impl/LabeledDummyVectorizer.java | 2 +-
.../bootstrapping/BootstrappedDatasetBuilder.java | 2 +-
.../impl/cache/CacheBasedDatasetBuilder.java | 9 +-
.../ignite/ml/dataset/primitive/SimpleDataset.java | 2 +-
.../builder/data/SimpleDatasetDataBuilder.java | 2 +-
.../parallelism/NoParallelismStrategy.java | 2 +-
.../parallelism/ParallelismStrategy.java | 2 +-
.../ignite/ml/knn/ann/ANNClassificationModel.java | 2 +-
.../java/org/apache/ignite/ml/math/Tracer.java | 2 +-
.../datastructures/EmptyFileException.java | 2 +-
.../ignite/ml/math/isolve/lsqr/AbstractLSQR.java | 2 +-
.../ignite/ml/math/isolve/lsqr/LSQROnHeap.java | 2 +-
.../ml/math/primitives/vector/VectorUtils.java | 2 +-
.../storage/VectorizedViewMatrixStorage.java | 2 +-
.../compound/CompoundNaiveBayesModel.java | 3 +-
.../compound/CompoundNaiveBayesTrainer.java | 7 +-
.../java/org/apache/ignite/ml/nn/MLPTrainer.java | 8 +-
.../apache/ignite/ml/nn/MultilayerPerceptron.java | 6 +-
.../ignite/ml/optimization/LossFunctions.java | 2 +-
.../binarization/BinarizationPreprocessor.java | 2 +-
.../ml/preprocessing/imputing/ImputerTrainer.java | 26 +-
.../normalization/NormalizationPreprocessor.java | 4 +-
.../standardscaling/StandardScalerTrainer.java | 2 +-
.../selection/paramgrid/ParameterSetGenerator.java | 2 +-
.../selection/split/TrainTestDatasetSplitter.java | 2 +-
.../split/mapper/SHA256UniformMapper.java | 2 +-
.../ignite/ml/structures/LabeledVectorSet.java | 17 +-
.../structures/LabeledVectorSetTestTrainPair.java | 4 +-
.../preprocessing/LabeledDatasetLoader.java | 2 +-
.../ml/tree/DecisionTreeClassificationTrainer.java | 4 +-
.../apache/ignite/ml/tree/data/TreeDataIndex.java | 6 +-
.../RandomForestClassifierTrainer.java | 2 +-
.../ignite/ml/tree/randomforest/data/TreeNode.java | 2 +-
.../data/statistics/LeafValuesComputer.java | 2 +-
.../java/org/apache/ignite/ml/util/LRUCache.java | 2 +-
.../org/apache/ignite/ml/common/TrainerTest.java | 2 +-
.../convergence/ConvergenceCheckerTest.java | 2 +-
.../mean/MeanAbsValueConvergenceCheckerTest.java | 4 +-
.../MedianOfMedianConvergenceCheckerTest.java | 2 +-
.../ml/dataset/primitive/SimpleDatasetTest.java | 4 +-
.../primitive/SimpleLabeledDatasetTest.java | 4 +-
.../ml/environment/deploy/MLDeployingTest.java | 2 +-
.../ignite/ml/knn/KNNClassificationTest.java | 6 +-
.../ignite/ml/math/isolve/lsqr/LSQROnHeapTest.java | 2 +-
.../vector/storage/AbstractStorageTest.java | 6 +-
.../encoding/FrequencyEncoderPreprocessorTest.java | 2 +-
.../encoding/OneHotEncoderPreprocessorTest.java | 6 +-
.../encoding/StringEncoderPreprocessorTest.java | 2 +-
.../imputing/ImputerPreprocessorTest.java | 2 +-
.../MinMaxScalerPreprocessorTest.java | 10 +-
.../NormalizationPreprocessorTest.java | 2 +-
.../util/SimpleStepFunctionCompressorTest.java | 2 +-
.../RandomForestRegressionTrainerTest.java | 2 +-
.../data/impurity/GiniFeatureHistogramTest.java | 2 +-
.../data/impurity/ImpurityHistogramTest.java | 2 +-
.../data/impurity/MSEHistogramTest.java | 2 +-
.../ml/xgboost/parser/XGBoostModelLexer.java | 62 +-
.../ml/xgboost/parser/XGBoostModelParser.java | 81 +-
.../cpp/thin-client/src/impl/data_channel.cpp | 30 +-
.../cpp/thin-client/src/impl/data_channel.h | 12 +
.../Interop/AffinityCallBenchmark.cs | 74 ++
.../Apache.Ignite.Core.Tests.DotNetCore.csproj | 10 +
.../install-package.ps1 | 4 +-
.../Cache/Platform/PlatformCacheTest.cs | 12 +-
.../Cache/Query/CacheQueriesTest.cs | 2 +-
.../Cache/Query/Linq/CacheLinqTest.Aggregates.cs | 1 +
.../Cache/Query/Linq/CacheLinqTest.Misc.cs | 1 -
.../Client/ClientProtocolCompatibilityTest.cs | 12 +-
.../Compute/ComputeApiTest.cs | 166 ++-
.../Config/full-config.xml | 2 +-
.../Dataload/DataStreamerTest.cs | 2 +
.../Dataload/DataStreamerTestTopologyChange.cs | 3 +-
.../Deployment/PeerAssemblyLoadingAllApisTest.cs | 17 +-
.../Deployment/PeerAssemblyLoadingTest.cs | 42 +-
.../IgniteConfigurationSerializerTest.cs | 7 +-
.../Log/CustomLoggerTest.cs | 9 -
.../Apache.Ignite.Core.Tests/TestUtils.Common.cs | 27 +
.../Apache.Ignite.Core/Apache.Ignite.Core.csproj | 1 +
.../Cache/Configuration/CacheConfiguration.cs | 27 +-
.../Cache/Configuration/QueryEntity.cs | 12 +-
.../Cache/Configuration/QueryField.cs | 21 +-
.../dotnet/Apache.Ignite.Core/Compute/ICompute.cs | 69 +-
.../Configuration/ClientConnectorConfiguration.cs | 4 +-
.../Configuration/DataRegionConfiguration.cs | 18 +-
.../Configuration/DataStorageConfiguration.cs | 15 +-
.../Configuration/ThinClientConfiguration.cs | 13 +
.../Apache.Ignite.Core/IgniteConfiguration.cs | 34 +-
.../IgniteConfigurationSection.xsd | 5 +
.../dotnet/Apache.Ignite.Core/Ignition.cs | 2 +-
.../Impl/Binary/BinaryWriterExtensions.cs | 46 +-
.../Impl/Binary/IBinaryRawWriteAware.cs | 23 -
.../Apache.Ignite.Core/Impl/Binary/Marshaller.cs | 14 +
.../Apache.Ignite.Core/Impl/Cache/CacheImpl.cs | 3 +-
.../Cache/ClientCacheConfigurationSerializer.cs | 141 ++-
.../Apache.Ignite.Core/Impl/Client/ClientSocket.cs | 32 +-
.../Impl/Cluster/ClusterGroupImpl.cs | 27 +-
.../Apache.Ignite.Core/Impl/Compute/Compute.cs | 40 +-
.../Apache.Ignite.Core/Impl/Compute/ComputeImpl.cs | 133 ++-
.../Impl/Compute/ComputeJobHolder.cs | 88 +-
.../Impl/Compute/ComputeRunner.cs | 97 ++
.../dotnet/Apache.Ignite.Core/Impl/Ignite.cs | 11 +-
.../Impl/PlatformTargetAdapter.cs | 3 +-
.../Impl/Unmanaged/UnmanagedCallbackOp.cs | 4 +-
.../Impl/Unmanaged/UnmanagedCallbacks.cs | 48 +
.../Apache.Ignite.DotNetCore.sln.DotSettings | 1 +
modules/platforms/dotnet/DEVNOTES.txt | 2 +-
modules/platforms/dotnet/build.ps1 | 2 +-
modules/platforms/dotnet/docfx/index.md | 2 -
.../http/jetty/GridJettyObjectMapper.java | 79 +-
.../protocols/http/jetty/GridJettyRestHandler.java | 381 +++---
.../http/jetty/GridJettyRestProtocol.java | 4 +-
.../jetty/IgniteBinaryObjectJsonDeserializer.java | 123 ++
.../spark/JavaStandaloneIgniteRDDSelfTest.java | 2 +-
.../spark/JavaStandaloneIgniteRDDSelfTest.java | 2 +-
.../support/IgniteRepositoryFactoryBean.java | 2 +-
.../misc/PersonExpressionRepository.java | 2 +-
.../java/org/apache/ignite/IgniteSpringBean.java | 5 +
.../util/spring/IgniteSpringHelperImpl.java | 2 +-
.../jdbc/CacheJdbcBlobStoreFactorySelfTest.java | 4 +-
.../CacheSpringStoreSessionListenerSelfTest.java | 27 +
.../resource/GridLoggerInjectionSelfTest.java | 6 +-
.../p2p/GridP2PUserVersionChangeSelfTest.java | 2 +-
.../util/nodestart/StartNodeCallableImpl.java | 2 +-
.../tools/ant/beautifier/GridJavadocAntTask.java | 2 +-
.../ignite/tools/javadoc/IgniteLinkTaglet.java | 2 +-
modules/twitter/README.txt | 32 -
modules/twitter/licenses/apache-2.0.txt | 202 ----
modules/twitter/pom.xml | 131 ---
.../ignite/stream/twitter/OAuthSettings.java | 86 --
.../ignite/stream/twitter/TwitterStreamer.java | 294 -----
.../apache/ignite/stream/twitter/package-info.java | 22 -
.../stream/twitter/IgniteTwitterStreamerTest.java | 252 ----
.../ignite/stream/twitter/TwitterStreamerImpl.java | 79 --
.../apache/ignite/stream/twitter/package-info.java | 22 -
.../deployment/uri/GridUriDeploymentDiscovery.java | 4 +-
.../uri/GridUriDeploymentJarVerifier.java | 12 +-
.../uri/GridUriDeploymentSpringDocument.java | 2 +-
.../uri/GridUriDeploymentSpringParser.java | 4 +-
.../deployment/uri/GridUriDeploymentUriParser.java | 10 +-
.../spi/deployment/uri/UriDeploymentSpi.java | 4 +-
.../uri/scanners/UriDeploymentScannerManager.java | 2 +-
.../scanners/http/UriDeploymentHttpScanner.java | 2 +-
.../uri/GridUriDeploymentMd5CheckSelfTest.java | 2 +-
.../scanners/http/GridHttpDeploymentSelfTest.java | 2 +-
.../WebConsoleConfigurationSelfTest.java | 4 +-
.../ignite/console/agent/db/DbMetadataReader.java | 2 +-
.../agent/db/dialect/DatabaseMetadataDialect.java | 2 +-
.../agent/db/dialect/JdbcMetadataDialect.java | 2 +-
.../agent/db/dialect/MySQLMetadataDialect.java | 2 +-
.../agent/db/dialect/OracleMetadataDialect.java | 4 +-
.../ignite/console/agent/rest/RestExecutor.java | 2 +-
.../ignite/console/demo/AgentClusterDemo.java | 2 +-
.../demo/service/DemoCachesLoadService.java | 2 +-
.../ignite/console/demo/task/DemoComputeTask.java | 2 +-
.../console/agent/rest/RestExecutorSelfTest.java | 2 +-
.../ignite/cache/websession/WebSessionFilter.java | 6 +-
.../servlet/ServletContextListenerStartup.java | 2 +-
.../internal/websession/WebSessionSelfTest.java | 8 +-
.../config/benchmark-inline-index.properties | 90 ++
.../ignite/yardstick/IgniteBenchmarkArguments.java | 52 +
.../org/apache/ignite/yardstick/IgniteNode.java | 2 +-
.../yardstick/IgniteThinAbstractBenchmark.java | 10 +-
.../cache/IgniteCacheAbstractBenchmark.java | 4 +-
.../yardstick/cache/IgnitePutTxLoadBenchmark.java | 6 +-
.../org/apache/ignite/yardstick/cache/Loader.java | 6 +-
.../dml/IgniteSqlInsertIndexedValue2Benchmark.java | 2 +-
.../dml/IgniteSqlInsertIndexedValue8Benchmark.java | 2 +-
.../cache/dml/IgniteSqlMergeQueryBenchmark.java | 2 +-
.../cache/jdbc/JdbcAbstractBenchmark.java | 2 +-
.../yardstick/cache/jdbc/RdbmsBenchmark.java | 2 +-
.../load/IgniteCacheRandomOperationBenchmark.java | 2 +-
.../yardstick/cache/load/model/ModelUtil.java | 2 +-
.../ignite/yardstick/cache/model/History.java | 2 +-
.../ignite/yardstick/cache/model/Person8.java | 2 +-
.../yardstick/cache/model/Person8NotIndexed.java | 2 +-
.../yardstick/jdbc/AbstractJdbcBenchmark.java | 6 +-
.../yardstick/jdbc/DisjointRangeGenerator.java | 2 +-
.../yardstick/jdbc/JdbcSqlUpdateBenchmark.java | 2 +-
.../jdbc/vendors/BaseSelectRangeBenchmark.java | 2 +-
.../yardstick/sql/IgniteInlineIndexBenchmark.java | 136 +++
.../thin/cache/IgniteThinBenchmarkUtils.java | 12 +-
.../ignite/yardstick/upload/CopyBenchmark.java | 6 +-
.../ignite/yardstick/upload/InsertBenchmark.java | 2 +-
.../yardstickframework/probes/TotalTimeProbe.java | 6 +-
.../org/apache/ignite/yarn/ClusterProperties.java | 2 +-
modules/zeromq/README.txt | 37 -
modules/zeromq/licenses/apache-2.0.txt | 202 ----
modules/zeromq/pom.xml | 75 --
.../ignite/stream/zeromq/IgniteZeroMqStreamer.java | 151 ---
.../ignite/stream/zeromq/ZeroMqTypeSocket.java | 56 -
.../apache/ignite/stream/zeromq/package-info.java | 21 -
.../stream/zeromq/IgniteZeroMqStreamerTest.java | 261 -----
.../apache/ignite/stream/zeromq/package-info.java | 21 -
modules/zookeeper/pom.xml | 6 +
.../spi/discovery/zk/internal/ZkIgnitePaths.java | 2 +-
.../zk/internal/ZookeeperDiscoveryImpl.java | 4 +-
.../zk/ZookeeperDiscoverySpiTestSuite2.java | 2 +-
...ZookeeperDiscoveryCommunicationFailureTest.java | 6 +-
.../ZookeeperDiscoverySpiSaslAuthAbstractTest.java | 2 +-
.../zk/internal/ZookeeperDiscoverySpiTestBase.java | 2 +-
.../internal/ZookeeperDiscoverySpiTestHelper.java | 4 +-
parent/pom.xml | 3 +-
pom.xml | 79 +-
1550 files changed, 25337 insertions(+), 10390 deletions(-)