This is an automated email from the ASF dual-hosted git repository. gvvinblade pushed a commit to branch ignite-12248 in repository https://gitbox.apache.org/repos/asf/ignite.git
commit 2413ae01374e484a92600bc810887c0ee928a7f8 Merge: fc01a9d acb4dac Author: Igor Seliverstov <[email protected]> AuthorDate: Tue Oct 22 11:48:34 2019 +0300 Merge branch 'ignite-master' into ignite-12248 .../rest/RestBinaryProtocolSelfTest.java | 2 +- .../rest/RestProcessorMultiStartSelfTest.java | 4 +- .../ignite/jdbc/thin/JdbcThinMetadataSelfTest.java | 3 +- .../SystemViewRowAttributeWalkerGenerator.java | 2 + .../org/apache/ignite/IgniteSystemProperties.java | 8 + .../apache/ignite/internal/GridKernalContext.java | 4 +- .../ignite/internal/GridKernalContextImpl.java | 10 +- .../org/apache/ignite/internal/IgniteKernal.java | 6 +- .../communication/GridIoMessageFactory.java | 6 + .../managers/discovery/GridDiscoveryManager.java | 12 + .../managers/systemview/GridSystemViewManager.java | 37 +- .../managers/systemview/SystemViewAdapter.java | 42 +- .../systemview/walker/ClusterNodeViewWalker.java | 61 +++ .../apache/ignite/internal/pagemem/PageUtils.java | 4 +- .../internal/pagemem/wal/record/WALRecord.java | 7 +- .../delta/MetaPageUpdatePartitionDataRecord.java | 19 +- .../delta/MetaPageUpdatePartitionDataRecordV2.java | 22 +- ...va => MetaPageUpdatePartitionDataRecordV3.java} | 57 +-- .../cache/CacheAffinitySharedManager.java | 24 +- .../processors/cache/CacheGroupContext.java | 19 + .../processors/cache/CacheGroupMetricsImpl.java | 23 +- .../internal/processors/cache/CacheObject.java | 3 + .../processors/cache/GridCacheContext.java | 8 +- .../processors/cache/GridCacheMapEntry.java | 319 ++++++++------- .../cache/GridCachePartitionExchangeManager.java | 12 +- .../cache/IgniteCacheOffheapManager.java | 93 ++++- .../cache/IgniteCacheOffheapManagerImpl.java | 395 +++++++++++++++--- .../processors/cache/IncompleteCacheObject.java | 19 + .../processors/cache/IncompleteObject.java | 2 +- .../processors/cache/PartitionUpdateCounter.java | 4 +- .../processors/cache/TombstoneCacheObject.java | 94 +++++ .../binary/CacheObjectBinaryProcessorImpl.java | 6 +- .../preloader/GridDhtPartitionsExchangeFuture.java | 23 +- .../dht/preloader/InitNewCoordinatorFuture.java | 23 +- .../dht/topology/GridDhtLocalPartition.java | 293 +++++++++----- .../dht/topology/GridDhtPartitionTopologyImpl.java | 5 +- .../dht/topology/PartitionsEvictManager.java | 366 +++++++++++++---- .../processors/cache/mvcc/txlog/TxLog.java | 8 +- .../processors/cache/persistence/CacheDataRow.java | 5 + .../cache/persistence/CacheDataRowAdapter.java | 61 ++- .../GridCacheDatabaseSharedManager.java | 2 +- .../cache/persistence/GridCacheOffheapManager.java | 384 +++++++++++------- .../IgniteCacheDatabaseSharedManager.java | 107 ++++- .../cache/persistence/file/FilePageStore.java | 4 +- .../file/FileVersionCheckingFactory.java | 2 +- .../persistence/freelist/AbstractFreeList.java | 34 +- .../cache/persistence/freelist/CacheFreeList.java | 7 +- .../cache/persistence/freelist/PagesList.java | 439 ++++++++++++++++++++- .../cache/persistence/metastorage/MetaStorage.java | 10 +- .../pagemem/DelayedPageReplacementTracker.java | 2 +- .../partstorage/PartitionMetaStorage.java | 2 +- .../partstorage/PartitionMetaStorageImpl.java | 6 +- .../persistence/tree/io/PagePartitionMetaIO.java | 29 +- .../persistence/tree/io/PagePartitionMetaIOV2.java | 25 +- .../persistence/tree/reuse/ReuseListImpl.java | 20 +- .../persistence/wal/FileWriteAheadLogManager.java | 4 +- .../wal/filehandle/FsyncFileWriteHandle.java | 6 +- .../wal/reader/StandaloneGridKernalContext.java | 4 +- .../wal/serializer/RecordDataV1Serializer.java | 11 + .../internal/processors/cache/tree/DataRow.java | 6 +- .../processors/metric/impl/MetricUtils.java | 9 + .../processors/rest/GridRestProcessor.java | 2 +- .../processors/rest/IgniteRestProcessor.java} | 14 +- .../ignite/spi/discovery/tcp/ServerImpl.java | 22 +- .../systemview/jmx/JmxSystemViewExporterSpi.java | 2 +- .../spi/systemview/view/ClusterNodeView.java | 119 ++++++ .../internal/binary/BinaryMarshallerSelfTest.java | 5 + .../internal/managers/GridManagerStopSelfTest.java | 2 + .../ignite/internal/metric/SystemViewSelfTest.java | 48 +++ .../cache/CacheDeferredDeleteSanitySelfTest.java | 6 +- .../cache/GridCacheAbstractFullApiSelfTest.java | 7 +- .../IgniteCacheConfigVariationsFullApiTest.java | 2 +- .../PartitionsExchangeCoordinatorFailoverTest.java | 203 ++++++++-- .../GridBinaryCacheEntryMemorySizeSelfTest.java | 13 +- .../CacheRemoveWithTombstonesLoadTest.java | 414 +++++++++++++++++++ .../distributed/CacheRemoveWithTombstonesTest.java | 289 ++++++++++++++ .../CacheRemoveWithTombstonesFailoverTest.java | 187 +++++++++ .../DropCacheContextDuringEvictionTest.java | 24 +- .../PartitionsEvictManagerAbstractTest.java | 113 +++--- .../PartitionsEvictionTaskFailureHandlerTest.java | 72 +++- .../persistence/IgnitePdsCorruptedStoreTest.java | 46 ++- .../db/checkpoint/CheckpointFreeListTest.java | 74 ++++ ...eWalFlushMultiNodeFailoverAbstractSelfTest.java | 7 +- .../db/wal/WalRecoveryTxLogicalRecordsTest.java | 113 ++++-- .../persistence/freelist/FreeListCachingTest.java | 218 ++++++++++ .../database/BPlusTreeReuseSelfTest.java | 10 +- .../processors/database/CacheFreeListSelfTest.java | 8 +- .../rest/RestProcessorInitializationTest.java | 163 ++++++++ .../processors/security/AbstractSecurityTest.java | 5 +- .../processors/security/InvalidServerTest.java | 65 +++ .../client/ThinClientPermissionCheckTest.java | 2 +- .../security/impl/TestSecurityPluginProvider.java | 9 +- .../security/impl/TestSecurityProcessor.java | 16 +- .../testframework/junits/GridAbstractTest.java | 9 +- .../testsuites/IgniteCacheMvccTestSuite9.java | 8 + .../ignite/testsuites/IgniteCacheTestSuite9.java | 7 + .../ignite/testsuites/IgnitePdsTestSuite2.java | 3 + .../testsuites/IgniteRestHandlerTestSuite.java | 4 +- .../ignite/testsuites/SecurityTestSuite.java | 2 + .../processors/query/h2/SchemaManager.java | 2 - .../query/h2/database/H2PkHashIndex.java | 4 +- .../processors/query/h2/opt/H2CacheRow.java | 5 + .../query/h2/sys/view/SqlSystemViewNodes.java | 99 ----- .../metric/sql/MetricRegistryLocalSystemView.java | 2 +- .../cache/metric/SqlViewExporterSpiTest.java | 167 ++++---- .../processors/query/SqlSystemViewsSelfTest.java | 8 +- .../ignite/ml/clustering/gmm/GmmTrainer.java | 2 +- .../main/java/org/apache/ignite/ml/math/Blas.java | 6 +- .../ignite/ml/math/distances/DistanceMeasure.java | 2 +- .../ml/math/distances/EuclideanDistance.java | 2 +- .../ignite/ml/math/distances/HammingDistance.java | 2 +- .../ml/math/distances/ManhattanDistance.java | 2 +- .../EmptyFileException.java | 6 +- .../FileParsingException.java | 4 +- .../NoLabelVectorException.java | 4 +- .../{knn => datastructures}/package-info.java | 2 +- .../{ => math}/CardinalityException.java | 2 +- .../{ => math}/ColumnIndexException.java | 2 +- .../math/exceptions/{ => math}/IndexException.java | 2 +- .../{ => math}/MathIllegalArgumentException.java | 3 +- .../{ => math}/MathRuntimeException.java | 2 +- .../exceptions/{ => math}/NoDataException.java | 2 +- .../{ => math}/NonSquareMatrixException.java | 2 +- .../exceptions/{ => math}/RowIndexException.java | 2 +- .../{ => math}/SingularMatrixException.java | 2 +- .../math/exceptions/{ => math}/package-info.java | 2 +- .../ignite/ml/math/exceptions/package-info.java | 2 +- .../ml/math/primitives/matrix/AbstractMatrix.java | 6 +- .../ml/math/primitives/matrix/LUDecomposition.java | 4 +- .../ignite/ml/math/primitives/matrix/Matrix.java | 4 +- .../ml/math/primitives/vector/AbstractVector.java | 4 +- .../ignite/ml/math/primitives/vector/Vector.java | 4 +- .../vector/impl/VectorizedViewMatrix.java | 2 +- .../storage/VectorizedViewMatrixStorage.java | 2 +- .../ignite/ml/nn/ReplicatedVectorMatrix.java | 2 +- .../apache/ignite/ml/structures/DatasetRow.java | 2 +- .../ignite/ml/structures/LabeledVectorSet.java | 6 +- .../preprocessing/LabeledDatasetLoader.java | 8 +- .../org/apache/ignite/ml/util/SandboxMLCache.java | 2 +- .../java/org/apache/ignite/ml/math/BlasTest.java | 2 +- .../primitives/matrix/LUDecompositionTest.java | 4 +- .../math/primitives/vector/AbstractVectorTest.java | 2 +- .../primitives/vector/MatrixVectorViewTest.java | 2 +- .../vector/VectorImplementationsTest.java | 2 +- .../linear/LinearRegressionModelTest.java | 2 +- .../logistic/LogisticRegressionModelTest.java | 2 +- .../ignite/ml/structures/LabeledVectorSetTest.java | 10 +- .../org/apache/ignite/ml/svm/SVMModelTest.java | 2 +- .../primitives/vector/VectorGeneratorTest.java | 2 +- .../Apache.Ignite.Core/Impl/Binary/BinaryUtils.cs | 4 +- ...avaEmbeddedIgniteRDDWithLocalStoreSelfTest.java | 7 - .../dml/IgniteSqlInsertIndexedValue1Benchmark.java | 47 +++ .../dml/IgniteSqlInsertIndexedValue2Benchmark.java | 47 +++ .../dml/IgniteSqlInsertIndexedValue8Benchmark.java | 48 +++ .../dml/IgniteSqlUpdateFilteredBenchmark.java | 89 +++++ 155 files changed, 5074 insertions(+), 1123 deletions(-) diff --cc modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/SchemaManager.java index 6e5103b,59120d0..cea1081 --- a/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/SchemaManager.java +++ b/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/SchemaManager.java @@@ -55,10 -55,8 +55,9 @@@ import org.apache.ignite.internal.proce import org.apache.ignite.internal.processors.query.h2.sys.view.SqlSystemViewCacheGroupsIOStatistics; import org.apache.ignite.internal.processors.query.h2.sys.view.SqlSystemViewNodeAttributes; import org.apache.ignite.internal.processors.query.h2.sys.view.SqlSystemViewNodeMetrics; - import org.apache.ignite.internal.processors.query.h2.sys.view.SqlSystemViewNodes; import org.apache.ignite.internal.processors.query.h2.sys.view.SqlSystemViewQueryHistoryMetrics; import org.apache.ignite.internal.processors.query.h2.sys.view.SqlSystemViewRunningQueries; +import org.apache.ignite.internal.processors.query.schema.SchemaChangeListener; import org.apache.ignite.internal.processors.query.schema.SchemaIndexCacheVisitor; import org.apache.ignite.internal.util.GridConcurrentHashSet; import org.apache.ignite.internal.util.typedef.F;
